server

Documentation

Index

• Constants
• type ArgoRolloutsServer
  • func NewServer(o ServerOptions) *ArgoRolloutsServer
  • func (s *ArgoRolloutsServer) AbortRollout(ctx context.Context, q *rollout.AbortRolloutRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) GetNamespace(ctx context.Context, e *empty.Empty) (*rollout.NamespaceInfo, error)
  • func (s *ArgoRolloutsServer) GetRolloutInfo(c context.Context, q *rollout.RolloutInfoQuery) (*rollout.RolloutInfo, error)
  • func (s *ArgoRolloutsServer) ListReplicaSetsAndPods(ctx context.Context, namespace string) ([]*appsv1.ReplicaSet, []*corev1.Pod, error)
  • func (s *ArgoRolloutsServer) ListRolloutInfos(ctx context.Context, q *rollout.RolloutInfoListQuery) (*rollout.RolloutInfoList, error)
  • func (s *ArgoRolloutsServer) PromoteRollout(ctx context.Context, q *rollout.PromoteRolloutRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) RestartRollout(ctx context.Context, q *rollout.RestartRolloutRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) RetryRollout(ctx context.Context, q *rollout.RetryRolloutRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) RolloutToRolloutInfo(ro *v1alpha1.Rollout) (*rollout.RolloutInfo, error)
  • func (s *ArgoRolloutsServer) Run(ctx context.Context, port int, dashboard bool)
  • func (s *ArgoRolloutsServer) SetRolloutImage(ctx context.Context, q *rollout.SetImageRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) UndoRollout(ctx context.Context, q *rollout.UndoRolloutRequest) (*v1alpha1.Rollout, error)
  • func (s *ArgoRolloutsServer) Version(ctx context.Context, _ *empty.Empty) (*rollout.VersionInfo, error)
  • func (s *ArgoRolloutsServer) WatchRolloutInfo(q *rollout.RolloutInfoQuery, ws rollout.RolloutService_WatchRolloutInfoServer) error
  • func (s *ArgoRolloutsServer) WatchRolloutInfos(q *rollout.RolloutInfoListQuery, ...) error
• type ServerOptions

Constants

const (
	ContentType   = "Content-Type"
	ContentLength = "Content-Length"
)

const (
	// MaxGRPCMessageSize contains max grpc message size
	MaxGRPCMessageSize = 100 * 1024 * 1024
)

Types

type ArgoRolloutsServer

type ArgoRolloutsServer struct {
	Options ServerOptions
	// contains filtered or unexported fields
}

ArgoRolloutsServer holds information about rollouts server

func NewServer

func NewServer(o ServerOptions) *ArgoRolloutsServer

NewServer creates an ArgoRolloutsServer

func (*ArgoRolloutsServer) AbortRollout

func (s *ArgoRolloutsServer) AbortRollout(ctx context.Context, q *rollout.AbortRolloutRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) GetNamespace

func (s *ArgoRolloutsServer) GetNamespace(ctx context.Context, e *empty.Empty) (*rollout.NamespaceInfo, error)

func (*ArgoRolloutsServer) GetRolloutInfo

func (s *ArgoRolloutsServer) GetRolloutInfo(c context.Context, q *rollout.RolloutInfoQuery) (*rollout.RolloutInfo, error)

GetRolloutInfo returns a rollout

func (*ArgoRolloutsServer) ListReplicaSetsAndPods

func (s *ArgoRolloutsServer) ListReplicaSetsAndPods(ctx context.Context, namespace string) ([]*appsv1.ReplicaSet, []*corev1.Pod, error)

func (*ArgoRolloutsServer) ListRolloutInfos

func (s *ArgoRolloutsServer) ListRolloutInfos(ctx context.Context, q *rollout.RolloutInfoListQuery) (*rollout.RolloutInfoList, error)

ListRolloutInfos returns a list of all rollouts

func (*ArgoRolloutsServer) PromoteRollout

func (s *ArgoRolloutsServer) PromoteRollout(ctx context.Context, q *rollout.PromoteRolloutRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) RestartRollout

func (s *ArgoRolloutsServer) RestartRollout(ctx context.Context, q *rollout.RestartRolloutRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) RetryRollout

func (s *ArgoRolloutsServer) RetryRollout(ctx context.Context, q *rollout.RetryRolloutRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) RolloutToRolloutInfo

func (s *ArgoRolloutsServer) RolloutToRolloutInfo(ro *v1alpha1.Rollout) (*rollout.RolloutInfo, error)

func (*ArgoRolloutsServer) Run

func (s *ArgoRolloutsServer) Run(ctx context.Context, port int, dashboard bool)

Run starts the server

func (*ArgoRolloutsServer) SetRolloutImage

func (s *ArgoRolloutsServer) SetRolloutImage(ctx context.Context, q *rollout.SetImageRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) UndoRollout

func (s *ArgoRolloutsServer) UndoRollout(ctx context.Context, q *rollout.UndoRolloutRequest) (*v1alpha1.Rollout, error)

func (*ArgoRolloutsServer) Version

func (s *ArgoRolloutsServer) Version(ctx context.Context, _ *empty.Empty) (*rollout.VersionInfo, error)

func (*ArgoRolloutsServer) WatchRolloutInfo

func (s *ArgoRolloutsServer) WatchRolloutInfo(q *rollout.RolloutInfoQuery, ws rollout.RolloutService_WatchRolloutInfoServer) error

WatchRolloutInfo returns a rollout stream

func (*ArgoRolloutsServer) WatchRolloutInfos

func (s *ArgoRolloutsServer) WatchRolloutInfos(q *rollout.RolloutInfoListQuery, ws rollout.RolloutService_WatchRolloutInfosServer) error

WatchRolloutInfos returns a stream of all rollouts

type ServerOptions

type ServerOptions struct {
	KubeClientset     kubernetes.Interface
	RolloutsClientset rolloutclientset.Interface
	DynamicClientset  dynamic.Interface
	Namespace         string
	RootPath          string
}