delivery

Documentation

Index

• type Service
  • func NewService(opts *natsio.NatsOptions, clusterOperator cluster.Operator, ...) *Service
  • func (s *Service) Close()
  • func (s *Service) DeliverCmd(ctx context.Context, toNode string, cmds []string, timeout time.Duration) ([]byte, error)
  • func (s *Service) DeliverLogRequest(ctx context.Context, operation *service.LogOperation) (opResp oplog.LogContentResponse, err error)
  • func (s *Service) DeliverStep(ctx context.Context, step *v1.Step, opts *service.Options) error
  • func (s *Service) DeliverTaskOperation(ctx context.Context, operation *v1.Operation, opts *service.Options) error
  • func (s *Service) PrepareRun(stopCh <-chan struct{}) error
  • func (s *Service) Run(stopCh <-chan struct{}) error
  • func (s *Service) SyncClusterCondition(op *v1.Operation)
  • func (s *Service) UpdateNodeLeaseOperation(msg *nats.Msg, data []byte) *service.CommonReply

Types

type Service

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

func NewService

func NewService(opts *natsio.NatsOptions, clusterOperator cluster.Operator, leaseOperator lease.Operator, opOperator operation.Operator) *Service

func (*Service) Close

func (s *Service) Close()

func (*Service) DeliverCmd

func (s *Service) DeliverCmd(ctx context.Context, toNode string, cmds []string, timeout time.Duration) ([]byte, error)

func (*Service) DeliverLogRequest

func (s *Service) DeliverLogRequest(ctx context.Context, operation *service.LogOperation) (opResp oplog.LogContentResponse, err error)

func (*Service) DeliverStep

func (s *Service) DeliverStep(ctx context.Context, step *v1.Step, opts *service.Options) error

func (*Service) DeliverTaskOperation

func (s *Service) DeliverTaskOperation(ctx context.Context, operation *v1.Operation, opts *service.Options) error

func (*Service) PrepareRun

func (s *Service) PrepareRun(stopCh <-chan struct{}) error

func (*Service) Run

func (s *Service) Run(stopCh <-chan struct{}) error

func (*Service) SyncClusterCondition

func (s *Service) SyncClusterCondition(op *v1.Operation)

func (*Service) UpdateNodeLeaseOperation

func (s *Service) UpdateNodeLeaseOperation(msg *nats.Msg, data []byte) *service.CommonReply