cmd

Documentation

Index

• func RunServer()
• type Auth
  • func (p *Auth) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type GrpcProxy
  • func (p *GrpcProxy) GetCommitInfo(ctx context.Context, in *api.GetCommitInfoRequest) (*api.GetCommitInfoResponse, error)
  • func (p *GrpcProxy) GetEnvironmentConfig(ctx context.Context, in *api.GetEnvironmentConfigRequest) (*api.GetEnvironmentConfigResponse, error)
  • func (p *GrpcProxy) GetGitTags(ctx context.Context, in *api.GetGitTagsRequest) (*api.GetGitTagsResponse, error)
  • func (p *GrpcProxy) GetOverview(ctx context.Context, in *api.GetOverviewRequest) (*api.GetOverviewResponse, error)
  • func (p *GrpcProxy) GetProductSummary(ctx context.Context, in *api.GetProductSummaryRequest) (*api.GetProductSummaryResponse, error)
  • func (p *GrpcProxy) GetStatus(ctx context.Context, in *api.GetStatusRequest) (*api.GetStatusResponse, error)
  • func (p *GrpcProxy) ProcessBatch(ctx context.Context, in *api.BatchRequest) (*api.BatchResponse, error)
  • func (p *GrpcProxy) StreamOverview(in *api.GetOverviewRequest, stream api.OverviewService_StreamOverviewServer) error
  • func (p *GrpcProxy) StreamStatus(in *api.StreamStatusRequest, stream api.RolloutService_StreamStatusServer) error

Functions

func RunServer

func RunServer()

Types

type Auth

type Auth struct {
	HttpServer  http.Handler
	DefaultUser auth.User
	// KeyRing is as of now required because we do not have technical users yet. So we protect public endpoints by requiring a signature
	KeyRing openpgp.KeyRing
}

func (*Auth) ServeHTTP

func (p *Auth) ServeHTTP(w http.ResponseWriter, r *http.Request)

type GrpcProxy

type GrpcProxy struct {
	OverviewClient           api.OverviewServiceClient
	BatchClient              api.BatchServiceClient
	RolloutServiceClient     api.RolloutServiceClient
	GitClient                api.GitServiceClient
	EnvironmentServiceClient api.EnvironmentServiceClient
}

GrpcProxy passes through gRPC messages to another server. An alternative to the more generic methods proposed in https://github.com/grpc/grpc-go/issues/2297

func (*GrpcProxy) GetCommitInfo

func (p *GrpcProxy) GetCommitInfo(
	ctx context.Context,
	in *api.GetCommitInfoRequest) (*api.GetCommitInfoResponse, error)

func (*GrpcProxy) GetEnvironmentConfig

func (p *GrpcProxy) GetEnvironmentConfig(
	ctx context.Context,
	in *api.GetEnvironmentConfigRequest) (*api.GetEnvironmentConfigResponse, error)

func (*GrpcProxy) GetGitTags

func (p *GrpcProxy) GetGitTags(
	ctx context.Context,
	in *api.GetGitTagsRequest) (*api.GetGitTagsResponse, error)

func (*GrpcProxy) GetOverview

func (p *GrpcProxy) GetOverview(
	ctx context.Context,
	in *api.GetOverviewRequest) (*api.GetOverviewResponse, error)

func (*GrpcProxy) GetProductSummary

func (p *GrpcProxy) GetProductSummary(
	ctx context.Context,
	in *api.GetProductSummaryRequest) (*api.GetProductSummaryResponse, error)

func (*GrpcProxy) GetStatus

func (p *GrpcProxy) GetStatus(ctx context.Context, in *api.GetStatusRequest) (*api.GetStatusResponse, error)

func (*GrpcProxy) ProcessBatch

func (p *GrpcProxy) ProcessBatch(
	ctx context.Context,
	in *api.BatchRequest) (*api.BatchResponse, error)

func (*GrpcProxy) StreamOverview

func (p *GrpcProxy) StreamOverview(
	in *api.GetOverviewRequest,
	stream api.OverviewService_StreamOverviewServer) error

func (*GrpcProxy) StreamStatus

func (p *GrpcProxy) StreamStatus(in *api.StreamStatusRequest, stream api.RolloutService_StreamStatusServer) error