producers

Documentation

Index

• type GoogleProducer
  • func NewGoogleProducer() (*GoogleProducer, error)
  • func (gp *GoogleProducer) ComputeZones() []string
  • func (gp *GoogleProducer) Endpoints() ([]*pkg.Endpoint, error)
• type Producer
  • func New(name string) (Producer, error)

Types

type GoogleProducer

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

GoogleProducer reads data from compute engine

func NewGoogleProducer

func NewGoogleProducer() (*GoogleProducer, error)

NewGoogleProducer creates new GoogleProducer

func (*GoogleProducer) ComputeZones

func (gp *GoogleProducer) ComputeZones() []string

ComputeZones provides all compute zones managed by the producer

func (*GoogleProducer) Endpoints

func (gp *GoogleProducer) Endpoints() ([]*pkg.Endpoint, error)

Endpoints provides endpoints read from compute engine.

type Producer

type Producer interface {

	// compute zones which are managed
	ComputeZones() []string

	// all endpoints in the from managed compute zones
	Endpoints() ([]*pkg.Endpoint, error)
}

Producer provides endpoints which should be synchronized

func New

func New(name string) (Producer, error)

New creates a new producer