webhook

Documentation

Index

• type WebhookProvider
  • func NewWebhookProvider(u string) (*WebhookProvider, error)
  • func (p WebhookProvider) AdjustEndpoints(e []*endpoint.Endpoint) ([]*endpoint.Endpoint, error)
  • func (p WebhookProvider) ApplyChanges(ctx context.Context, changes *plan.Changes) error
  • func (p WebhookProvider) GetDomainFilter() endpoint.DomainFilterInterface
  • func (p WebhookProvider) Records(ctx context.Context) ([]*endpoint.Endpoint, error)

Types

type WebhookProvider

type WebhookProvider struct {
	DomainFilter endpoint.DomainFilter
	// contains filtered or unexported fields
}

func NewWebhookProvider

func NewWebhookProvider(u string) (*WebhookProvider, error)

func (WebhookProvider) AdjustEndpoints

func (p WebhookProvider) AdjustEndpoints(e []*endpoint.Endpoint) ([]*endpoint.Endpoint, error)

AdjustEndpoints will call the provider doing a POST on `/adjustendpoints` which will return a list of modified endpoints based on a provider specific requirement. This method returns an empty slice in case there is a technical error on the provider's side so that no endpoints will be considered.

func (WebhookProvider) ApplyChanges

func (p WebhookProvider) ApplyChanges(ctx context.Context, changes *plan.Changes) error

ApplyChanges will make a POST to remoteServerURL/records with the changes

func (WebhookProvider) GetDomainFilter

func (p WebhookProvider) GetDomainFilter() endpoint.DomainFilterInterface

GetDomainFilter make calls to get the serialized version of the domain filter

func (WebhookProvider) Records

func (p WebhookProvider) Records(ctx context.Context) ([]*endpoint.Endpoint, error)

Records will make a GET call to remoteServerURL/records and return the results