reapers

Documentation

Index

• type AllocationInfo
• type EndpointGetter
• type EndpointLister
• type EndpointPatcher
• type EndpointReaper
  • func NewEndpointReaper(ciliumClient EndpointUpdater, nomadAllocations AllocationInfo, ...) (*EndpointReaper, error)
  • func (e *EndpointReaper) Run(ctx context.Context) (<-chan bool, error)
• type EndpointUpdater
• type EventStreamer
• type NodeReaper
  • func NewNodeReaper(ctx context.Context, nomad_client *nomad_api.Client, ...) (*NodeReaper, error)
  • func (n *NodeReaper) Run() (<-chan bool, error)

Types

type AllocationInfo

type AllocationInfo interface {
	Info(allocID string, q *nomad_api.QueryOptions) (*nomad_api.Allocation, *nomad_api.QueryMeta, error)
}

type EndpointGetter

type EndpointGetter interface {
	EndpointGet(id string) (*models.Endpoint, error)
}

type EndpointLister

type EndpointLister interface {
	EndpointList() ([]*models.Endpoint, error)
}

type EndpointPatcher

type EndpointPatcher interface {
	EndpointPatch(id string, ep *models.EndpointChangeRequest) error
}

type EndpointReaper

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

func NewEndpointReaper

func NewEndpointReaper(ciliumClient EndpointUpdater, nomadAllocations AllocationInfo, nomadEventStream EventStreamer, nodeID string) (*EndpointReaper, error)

NewEndpointReaper creates a new EndpointReaper. This will run an initial reconciliation before returning the reaper

func (*EndpointReaper) Run

func (e *EndpointReaper) Run(ctx context.Context) (<-chan bool, error)

Run the reaper until the context given in the contructor is cancelled. This function is non blocking and will only return errors if something occurs during startup return a channel to notify of consul client failures

type EndpointUpdater

type EndpointUpdater interface {
	EndpointLister
	EndpointGetter
	EndpointPatcher
}

type EventStreamer

type EventStreamer interface {
	Stream(ctx context.Context, topics map[nomad_api.Topic][]string, index uint64, q *nomad_api.QueryOptions) (<-chan *nomad_api.Events, error)
}

type NodeReaper

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

func NewNodeReaper

func NewNodeReaper(ctx context.Context, nomad_client *nomad_api.Client, consul_client *consul_api.Client) (*NodeReaper, error)

NewNodeReaper creates a new NodeReaper. This will run an initial reconciliation before returning the reaper

func (*NodeReaper) Run

func (n *NodeReaper) Run() (<-chan bool, error)

Run the reaper until the context given in the contructor is cancelled. This function is non blocking and will only return errors if something occurs during startup return a channel to notify of nomad client failure