Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultResolveInterval = 45 * time.Second
Variables ¶
This section is empty.
Functions ¶
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 ¶ added in v1.17.0
type EventDispatch ¶ added in v1.16.0
type EventDispatch interface {
Notify(msg *common.UpdateRecordRequest) error
}
type HttpDispatch ¶ added in v1.16.0
type HttpDispatch struct {
// contains filtered or unexported fields
}
func NewHttpDispatcher ¶ added in v1.16.0
func NewHttpDispatcher(url string) (*HttpDispatch, error)
func (*HttpDispatch) Notify ¶ added in v1.16.0
func (h *HttpDispatch) Notify(msg *common.UpdateRecordRequest) error
type Reconciler ¶ added in v1.9.0
type Reconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶ added in v1.9.0
func NewReconciler(dispatchers map[string]EventDispatch, stopAfterFirstSuccess bool) (*Reconciler, error)
func (*Reconciler) RegisterUpdate ¶ added in v1.9.0
func (r *Reconciler) RegisterUpdate(env *common.UpdateRecordRequest) error
func (*Reconciler) Run ¶ added in v1.9.0
func (r *Reconciler) Run()
type SqsDispatch ¶ added in v1.18.0
type SqsDispatch struct {
// contains filtered or unexported fields
}
func NewSqsDispatcher ¶ added in v1.18.0
func NewSqsDispatcher(sqsConf conf.SqsConfig, provider credentials.Provider) (*SqsDispatch, error)
func (*SqsDispatch) Notify ¶ added in v1.18.0
func (h *SqsDispatch) Notify(msg *common.UpdateRecordRequest) error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.