deploy

Documentation

Index

• type ConditionFunc
• type ConditionFuncs
• type Service
  • func (s *Service) Cancel(in *pb.DeployMetaRequest, stream pb.DeployFlow_CancelServer) error
  • func (s *Service) Continue(_ context.Context, in *pb.ContinueRequest) (*pb.DeployReply, error)
  • func (s *Service) Delete(_ context.Context, in *pb.DeployMetaRequest) (*pb.EmptyReply, error)
  • func (s *Service) Get(_ context.Context, in *pb.DeployMetaRequest) (*pb.DeployReply, error)
  • func (s *Service) Gets(_ context.Context, in *pb.DeploysRequest) (*pb.DeploysReply, error)
  • func (s *Service) ListAndWatch(in *pb.DeploysRequest, stream pb.DeployFlow_ListAndWatchServer) error
  • func (s *Service) Next(_ context.Context, in *pb.NextRequest) (*pb.DeployReply, error)
  • func (s *Service) Pause(in *pb.DeployMetaRequest, stream pb.DeployFlow_PauseServer) error
  • func (s *Service) Resume(in *pb.DeployMetaRequest, stream pb.DeployFlow_ResumeServer) error
  • func (s *Service) Watch(in *pb.WatchRequest, stream pb.DeployFlow_WatchServer) error
  • func (s *Service) WatchFixedInterval(in *pb.WatchRequest, stream pb.DeployFlow_WatchServer) error
• type StreamSender

Types

type ConditionFunc

type ConditionFunc func(d *tritonappsv1alpha1.DeployFlow) (bool, error)

type ConditionFuncs

type ConditionFuncs []ConditionFunc

type Service

type Service struct {
	pb.UnimplementedDeployFlowServer
}

func (*Service) Cancel

func (s *Service) Cancel(in *pb.DeployMetaRequest, stream pb.DeployFlow_CancelServer) error

func (*Service) Continue

func (s *Service) Continue(_ context.Context, in *pb.ContinueRequest) (*pb.DeployReply, error)

func (*Service) Delete

func (s *Service) Delete(_ context.Context, in *pb.DeployMetaRequest) (*pb.EmptyReply, error)

func (*Service) Get

func (s *Service) Get(_ context.Context, in *pb.DeployMetaRequest) (*pb.DeployReply, error)

func (*Service) Gets

func (s *Service) Gets(_ context.Context, in *pb.DeploysRequest) (*pb.DeploysReply, error)

func (*Service) ListAndWatch

func (s *Service) ListAndWatch(in *pb.DeploysRequest, stream pb.DeployFlow_ListAndWatchServer) error

func (*Service) Next

func (s *Service) Next(_ context.Context, in *pb.NextRequest) (*pb.DeployReply, error)

func (*Service) Pause

func (s *Service) Pause(in *pb.DeployMetaRequest, stream pb.DeployFlow_PauseServer) error

func (*Service) Resume

func (s *Service) Resume(in *pb.DeployMetaRequest, stream pb.DeployFlow_ResumeServer) error

func (*Service) Watch

func (s *Service) Watch(in *pb.WatchRequest, stream pb.DeployFlow_WatchServer) error

func (*Service) WatchFixedInterval

func (s *Service) WatchFixedInterval(in *pb.WatchRequest, stream pb.DeployFlow_WatchServer) error

type StreamSender

type StreamSender interface {
	Send(*pb.DeployReply) error
	Context() context.Context
}