forked from infobloxopen/infoblox-go-client
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
b91e06d
commit 6775107
Showing
10 changed files
with
1,051 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,136 @@ | ||
| package ibclient | ||
|
|
||
| import "fmt" | ||
|
|
||
| func (objMgr *ObjectManager) CreateMXRecord( | ||
| dnsView string, | ||
| fqdn string, | ||
| mx string, | ||
| preference uint32, | ||
| ttl uint32, | ||
| useTtl bool, | ||
| comment string, | ||
| eas EA) (*RecordMX, error) { | ||
|
|
||
| if dnsView == "" { | ||
| dnsView = "default" | ||
| } | ||
|
|
||
| if fqdn == "" || mx == "" { | ||
| return nil, fmt.Errorf("'fqdn' and 'mail_exchanger' fields must not be empty") | ||
| } | ||
|
|
||
| if preference < 0 || preference > 65535 { | ||
| return nil, fmt.Errorf("'preference' is not in range 0 to 65535") | ||
| } | ||
|
|
||
| recordMx := NewRecordMX(RecordMX{ | ||
| View: dnsView, | ||
| Fqdn: fqdn, | ||
| MX: mx, | ||
| Preference: preference, | ||
| Ttl: ttl, | ||
| UseTtl: useTtl, | ||
| Comment: comment, | ||
| Ea: eas, | ||
| }) | ||
|
|
||
| ref, err := objMgr.connector.CreateObject(recordMx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| recordMx.Ref = ref | ||
| return recordMx, err | ||
| } | ||
|
|
||
| func (objMgr *ObjectManager) GetMXRecordByRef(ref string) (*RecordMX, error) { | ||
| recordMX := NewEmptyRecordMX() | ||
| err := objMgr.connector.GetObject(recordMX, ref, NewQueryParams(false, nil), &recordMX) | ||
|
|
||
| return recordMX, err | ||
| } | ||
|
|
||
| func (objMgr *ObjectManager) GetMXRecord(dnsView string, fqdn string, mx string) (*RecordMX, error) { | ||
| if dnsView == "" || fqdn == "" { | ||
| return nil, fmt.Errorf("'DNS view' and 'fqdn' are required to retrieve a unique mx record") | ||
| } | ||
| var res []RecordMX | ||
|
|
||
| recordMX := NewEmptyRecordMX() | ||
| sf := map[string]string{ | ||
| "view": dnsView, | ||
| "name": fqdn, | ||
| "mail_exchanger": mx, | ||
| } | ||
| queryParams := NewQueryParams(false, sf) | ||
| err := objMgr.connector.GetObject(recordMX, "", queryParams, &res) | ||
|
|
||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| if res == nil || len(res) == 0 { | ||
| return nil, NewNotFoundError( | ||
| fmt.Sprintf( | ||
| "MX record with name '%s' and MX '%s' in DNS view '%s' is not found", | ||
| fqdn, mx, dnsView)) | ||
| } | ||
|
|
||
| return &res[0], nil | ||
| } | ||
|
|
||
| func (objMgr *ObjectManager) UpdateMXRecord( | ||
| ref string, | ||
| dnsView string, | ||
| fqdn string, | ||
| mx string, | ||
| preference uint32, | ||
| ttl uint32, | ||
| useTtl bool, | ||
| comment string, | ||
| eas EA) (*RecordMX, error) { | ||
|
|
||
| res, err := objMgr.GetMXRecordByRef(ref) | ||
|
|
||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| if dnsView != res.View { | ||
| return nil, fmt.Errorf("changing 'dns_view' field after object creation is not allowed") | ||
| } | ||
|
|
||
| if preference < 0 || preference > 65535 { | ||
| return nil, fmt.Errorf("'preference' is not in range 0 to 65535") | ||
| } | ||
|
|
||
| if mx == "" { | ||
| return nil, fmt.Errorf("'mail_exchanger' field must not be empty") | ||
| } | ||
| recordMx := NewRecordMX(RecordMX{ | ||
| View: dnsView, | ||
| Fqdn: fqdn, | ||
| MX: mx, | ||
| Preference: preference, | ||
| Ttl: ttl, | ||
| UseTtl: useTtl, | ||
| Comment: comment, | ||
| Ea: eas, | ||
| }) | ||
|
|
||
| recordMx.Ref = ref | ||
|
|
||
| nw_ref, err := objMgr.connector.UpdateObject(recordMx, ref) | ||
|
|
||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| recordMx.Ref = nw_ref | ||
|
|
||
| return recordMx, err | ||
| } | ||
|
|
||
| func (objMgr *ObjectManager) DeleteMXRecord(ref string) (string, error) { | ||
| return objMgr.connector.DeleteObject(ref) | ||
| } |
Oops, something went wrong.