dataflow

Documentation

Index

• type ChainerServer
  • func NewChainerServer(logger log.FieldLogger, eventHub *coordinator.EventHub, ...) *ChainerServer
  • func (c *ChainerServer) PipelineUpdateEvent(ctx context.Context, message *chainer.PipelineUpdateStatusMessage) (*chainer.PipelineUpdateStatusResponse, error)
  • func (c *ChainerServer) StartGrpcServer(agentPort uint) error
  • func (c *ChainerServer) StopSendPipelineEvents()
  • func (c *ChainerServer) SubscribePipelineUpdates(req *chainer.PipelineSubscriptionRequest, ...) error
• type ChainerSubscription

Types

type ChainerServer

type ChainerServer struct {
	chainer.UnimplementedChainerServer
	// contains filtered or unexported fields
}

func NewChainerServer

func NewChainerServer(logger log.FieldLogger, eventHub *coordinator.EventHub, pipelineHandler pipeline.PipelineHandler, namespace string, loadBalancer util.LoadBalancer) *ChainerServer

func (*ChainerServer) PipelineUpdateEvent

func (c *ChainerServer) PipelineUpdateEvent(ctx context.Context, message *chainer.PipelineUpdateStatusMessage) (*chainer.PipelineUpdateStatusResponse, error)

func (*ChainerServer) StartGrpcServer

func (c *ChainerServer) StartGrpcServer(agentPort uint) error

func (*ChainerServer) StopSendPipelineEvents

func (c *ChainerServer) StopSendPipelineEvents()

func (*ChainerServer) SubscribePipelineUpdates

func (c *ChainerServer) SubscribePipelineUpdates(req *chainer.PipelineSubscriptionRequest, stream chainer.Chainer_SubscribePipelineUpdatesServer) error

type ChainerSubscription

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