delivery

package
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 5, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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, terminationChan *chan struct{}) *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 added in v1.3.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.