kubernetes

Documentation

Index

• Constants
• type Discovery
  • func New(logger log.Logger) *Discovery
  • func (k *Discovery) EarliestNode(ctx context.Context) (*discovery.Node, error)
  • func (k *Discovery) ID() string
  • func (k *Discovery) Nodes(ctx context.Context) ([]*discovery.Node, error)
  • func (k *Discovery) Start(ctx context.Context, meta discovery.Meta) error
  • func (k *Discovery) Stop() error
  • func (k *Discovery) Watch(ctx context.Context) (<-chan discovery.Event, error)

Constants

const (
	Namespace       string = "namespace"         // Namespace specifies the kubernetes namespace
	ActorSystemName        = "actor_system_name" // ActorSystemName specifies the actor system name
	ApplicationName        = "app_name"          // ApplicationName specifies the application name. This often matches the actor system name
)

Types

type Discovery

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

Discovery represents the kubernetes discovery

func New

func New(logger log.Logger) *Discovery

New returns an instance of the kubernetes discovery provider

func (*Discovery) EarliestNode

func (k *Discovery) EarliestNode(ctx context.Context) (*discovery.Node, error)

EarliestNode returns the earliest node. This is based upon the node timestamp

func (*Discovery) ID

func (k *Discovery) ID() string

ID returns the discovery id

func (*Discovery) Nodes

func (k *Discovery) Nodes(ctx context.Context) ([]*discovery.Node, error)

Nodes returns the list of up and running Nodes at a given time

func (*Discovery) Start

func (k *Discovery) Start(ctx context.Context, meta discovery.Meta) error

Start the discovery engine

func (*Discovery) Stop

func (k *Discovery) Stop() error

Stop shutdown the discovery engine

func (*Discovery) Watch

func (k *Discovery) Watch(ctx context.Context) (<-chan discovery.Event, error)

Watch returns event based upon node lifecycle