consumers

Documentation

Index

• type AWSClient
• type Consumer
  • func NewAWSRoute53Consumer(awsRecordGroupID string) (Consumer, error)
  • func NewGoogleCloudDNSConsumer(googleProject, googleRecordGroupID string) (Consumer, error)
  • func NewStdoutConsumer() (Consumer, error)
  • func NewSynchronizedConsumer(consumer Consumer) (Consumer, error)
• type SynchronizedConsumer
  • func (s *SynchronizedConsumer) Process(endpoint *pkg.Endpoint) error
  • func (s *SynchronizedConsumer) Sync(endpoints []*pkg.Endpoint) error

Types

type AWSClient

type AWSClient interface {
	ListRecordSets(zoneID string) ([]*route53.ResourceRecordSet, error)
	ChangeRecordSets(upsert, del, create []*route53.ResourceRecordSet, zoneID string) error
	GetCanonicalZoneIDs(lbDNS []string) (map[string]string, error) //get hosted zone ids for the LBs
	GetHostedZones() (map[string]string, error)                    //get all route53 hosted zones for the account
}

AWSClient interface

type Consumer

type Consumer interface {
	Sync([]*pkg.Endpoint) error
	Consume(<-chan *pkg.Endpoint, chan<- error, <-chan struct{}, *sync.WaitGroup)
	Process(*pkg.Endpoint) error
}

Consumer interface

func NewAWSRoute53Consumer

func NewAWSRoute53Consumer(awsRecordGroupID string) (Consumer, error)

NewAWSRoute53Consumer reates a Consumer instance to sync and process DNS entries in AWS Route53.

func NewGoogleCloudDNSConsumer

func NewGoogleCloudDNSConsumer(googleProject, googleRecordGroupID string) (Consumer, error)

NewGoogleCloudDNSConsumer creates

func NewStdoutConsumer

func NewStdoutConsumer() (Consumer, error)

func NewSynchronizedConsumer

func NewSynchronizedConsumer(consumer Consumer) (Consumer, error)

NewSynchronizedConsumer provides a consumer that can execute only one operation at a time, and blocks concurrent operations until the current one finishes.

type SynchronizedConsumer

type SynchronizedConsumer struct {
	sync.Mutex
	Consumer
}

func (*SynchronizedConsumer) Process

func (s *SynchronizedConsumer) Process(endpoint *pkg.Endpoint) error

func (*SynchronizedConsumer) Sync

func (s *SynchronizedConsumer) Sync(endpoints []*pkg.Endpoint) error