client

Documentation

Index

• Constants
• func WithForceSendUpdate() func(c *Client) error
• func WithInterval(interval time.Duration) func(c *Client) error
• type Client
  • func NewClient(resolver resolvers.IpResolver, signature verification.SignatureKeypair, ...) (*Client, error)
  • func (client *Client) GetLastStateChange() time.Time
  • func (client *Client) GetState() states.State
  • func (client *Client) Resolve(prev *common.DnsRecord) (*common.DnsRecord, error)
  • func (client *Client) Run()
  • func (client *Client) SetState(state states.State)
• type EventDispatch
• type Opts
• type Reconciler
  • func NewReconciler(dispatchers map[string]EventDispatch, stopAfterFirstSuccess bool) (*Reconciler, error)
  • func (r *Reconciler) RegisterUpdate(env *common.UpdateRecordRequest) error
  • func (r *Reconciler) Run()

Constants

const DefaultResolveInterval = 45 * time.Second

Functions

func WithForceSendUpdate

func WithForceSendUpdate() func(c *Client) error

func WithInterval

func WithInterval(interval time.Duration) func(c *Client) error

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(resolver resolvers.IpResolver, signature verification.SignatureKeypair, reconciler *Reconciler, notifyImpl notification.Notification, opts ...Opts) (*Client, error)

func (*Client) GetLastStateChange

func (client *Client) GetLastStateChange() time.Time

func (*Client) GetState

func (client *Client) GetState() states.State

func (*Client) Resolve

func (client *Client) Resolve(prev *common.DnsRecord) (*common.DnsRecord, error)

func (*Client) Run

func (client *Client) Run()

func (*Client) SetState

func (client *Client) SetState(state states.State)

type EventDispatch

type EventDispatch interface {
	Notify(msg *common.UpdateRecordRequest) error
}

type Opts

type Opts func(c *Client) error

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(dispatchers map[string]EventDispatch, stopAfterFirstSuccess bool) (*Reconciler, error)

func (*Reconciler) RegisterUpdate

func (r *Reconciler) RegisterUpdate(env *common.UpdateRecordRequest) error

func (*Reconciler) Run

func (r *Reconciler) Run()