tools

Documentation

Index

• Variables
• type ActorCache
  • func NewActorCache(control *control.Client) *ActorCache
  • func (pc *ActorCache) Get(id api.UUID) (api.Actor, error)
• type ActorMap
  • func NewActorMap(ctx context.Context, client *api.Client, log zerolog.Logger) (*ActorMap, error)
  • func (am *ActorMap) Close()
  • func (am *ActorMap) IsOnline(id api.UUID) (bool, bool)
  • func (am *ActorMap) List() (list []ActorState)
  • func (am *ActorMap) ListOnline() []api.UUID
  • func (am *ActorMap) SetOnline(id api.UUID, online bool)
• type ActorState
• type PipelineCache
  • func NewPipelineCache(control *control.Client) *PipelineCache
  • func (pc *PipelineCache) Get(id api.UUID) (api.PipelineInfo, error)

Variables

var ErrNoSuchActor = errors.New("no such pipeline")

ErrNoSuchActor is returned if the pipeline does not exist

var ErrNoSuchPipeline = errors.New("no such pipeline")

ErrNoSuchPipeline is returned if the pipeline does not exist

Types

type ActorCache

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

ActorCache caches the pipeline definitions

func NewActorCache

func NewActorCache(control *control.Client) *ActorCache

NewActorCache creates a ActorCache instance

func (*ActorCache) Get

func (pc *ActorCache) Get(id api.UUID) (api.Actor, error)

Get returns a pipeline info

type ActorMap

type ActorMap struct {
	Events chan ActorState
	// contains filtered or unexported fields
}

ActorMap holds a map of actors->status and keep it in sync by subscribing to actor events

func NewActorMap

func NewActorMap(ctx context.Context, client *api.Client, log zerolog.Logger) (*ActorMap, error)

NewActorMap initialize the map and starts listening

func (*ActorMap) Close

func (am *ActorMap) Close()

Close stops the sync

func (*ActorMap) IsOnline

func (am *ActorMap) IsOnline(id api.UUID) (bool, bool)

IsOnline returns the status of an actor

func (*ActorMap) List

func (am *ActorMap) List() (list []ActorState)

List returns the list of actors

func (*ActorMap) ListOnline

func (am *ActorMap) ListOnline() []api.UUID

ListOnline returns a list of online actors

func (*ActorMap) SetOnline

func (am *ActorMap) SetOnline(id api.UUID, online bool)

SetOnline force the status of an actor

type ActorState

type ActorState struct {
	ID     api.UUID
	Name   string
	Kind   api.Actor_Kind
	Online bool
}

ActorState is emitted by the ActorMap when a actor status changes

type PipelineCache

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

PipelineCache caches the pipeline definitions

func NewPipelineCache

func NewPipelineCache(control *control.Client) *PipelineCache

NewPipelineCache creates a PipelineCache instance

func (*PipelineCache) Get

func (pc *PipelineCache) Get(id api.UUID) (api.PipelineInfo, error)

Get returns a pipeline info