platform

package
v0.48.9 Latest Latest
Warning

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

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

Documentation

Overview

Package planner provides a piped component that decides the deployment pipeline of a deployment. The planner bases on the changes from git commits then builds the deployment manifests to know the behavior of the deployment. From that behavior the planner can decides which pipeline should be applied.

Index

Constants

This section is empty.

Variables

View Source 
var ExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.plugin.platformapi.v1alpha1.ExecutorService",
	HandlerType: (*ExecutorServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteStage",
			Handler:       _ExecutorService_ExecuteStage_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/plugin/api/v1alpha1/platform/api.proto",
}

ExecutorService_ServiceDesc is the grpc.ServiceDesc for ExecutorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_plugin_api_v1alpha1_platform_api_proto protoreflect.FileDescriptor
View Source 
var PlannerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.plugin.platformapi.v1alpha1.PlannerService",
	HandlerType: (*PlannerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DetermineStrategy",
			Handler:    _PlannerService_DetermineStrategy_Handler,
		},
		{
			MethodName: "QuickSyncPlan",
			Handler:    _PlannerService_QuickSyncPlan_Handler,
		},
		{
			MethodName: "PipelineSyncPlan",
			Handler:    _PlannerService_PipelineSyncPlan_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/plugin/api/v1alpha1/platform/api.proto",
}

PlannerService_ServiceDesc is the grpc.ServiceDesc for PlannerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterExecutorServiceServer 

func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)

func RegisterPlannerServiceServer 

func RegisterPlannerServiceServer(s grpc.ServiceRegistrar, srv PlannerServiceServer)

Types

type DetermineStrategyRequest added in v0.48.0 

type DetermineStrategyRequest struct {
	Input *PlanPluginInput `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*DetermineStrategyRequest) Descriptor deprecated added in v0.48.0 

func (*DetermineStrategyRequest) Descriptor() ([]byte, []int)

Deprecated: Use DetermineStrategyRequest.ProtoReflect.Descriptor instead.

func (*DetermineStrategyRequest) GetInput added in v0.48.0 

func (x *DetermineStrategyRequest) GetInput() *PlanPluginInput

func (*DetermineStrategyRequest) ProtoMessage added in v0.48.0 

func (*DetermineStrategyRequest) ProtoMessage()

func (*DetermineStrategyRequest) ProtoReflect added in v0.48.0 

func (x *DetermineStrategyRequest) ProtoReflect() protoreflect.Message

func (*DetermineStrategyRequest) Reset added in v0.48.0 

func (x *DetermineStrategyRequest) Reset()

func (*DetermineStrategyRequest) String added in v0.48.0 

func (x *DetermineStrategyRequest) String() string

func (*DetermineStrategyRequest) Validate added in v0.48.0 

func (m *DetermineStrategyRequest) Validate() error

Validate checks the field values on DetermineStrategyRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DetermineStrategyRequest) ValidateAll added in v0.48.0 

func (m *DetermineStrategyRequest) ValidateAll() error

ValidateAll checks the field values on DetermineStrategyRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DetermineStrategyRequestMultiError, or nil if none found.

type DetermineStrategyRequestMultiError added in v0.48.0 

type DetermineStrategyRequestMultiError []error

DetermineStrategyRequestMultiError is an error wrapping multiple validation errors returned by DetermineStrategyRequest.ValidateAll() if the designated constraints aren't met.

func (DetermineStrategyRequestMultiError) AllErrors added in v0.48.0 

func (m DetermineStrategyRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DetermineStrategyRequestMultiError) Error added in v0.48.0 

func (m DetermineStrategyRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DetermineStrategyRequestValidationError added in v0.48.0 

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

DetermineStrategyRequestValidationError is the validation error returned by DetermineStrategyRequest.Validate if the designated constraints aren't met.

func (DetermineStrategyRequestValidationError) Cause added in v0.48.0 

func (e DetermineStrategyRequestValidationError) Cause() error

Cause function returns cause value.

func (DetermineStrategyRequestValidationError) Error added in v0.48.0 

func (e DetermineStrategyRequestValidationError) Error() string

Error satisfies the builtin error interface

func (DetermineStrategyRequestValidationError) ErrorName added in v0.48.0 

func (e DetermineStrategyRequestValidationError) ErrorName() string

ErrorName returns error name.

func (DetermineStrategyRequestValidationError) Field added in v0.48.0 

func (e DetermineStrategyRequestValidationError) Field() string

Field function returns field value.

func (DetermineStrategyRequestValidationError) Key added in v0.48.0 

func (e DetermineStrategyRequestValidationError) Key() bool

Key function returns key value.

func (DetermineStrategyRequestValidationError) Reason added in v0.48.0 

func (e DetermineStrategyRequestValidationError) Reason() string

Reason function returns reason value.

type DetermineStrategyResponse added in v0.48.0 

type DetermineStrategyResponse struct {

	// The determined sync strategy.
	SyncStrategy model.SyncStrategy `protobuf:"varint,1,opt,name=sync_strategy,json=syncStrategy,proto3,enum=model.SyncStrategy" json:"sync_strategy,omitempty"`
	// Text summary of the determined strategy.
	Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*DetermineStrategyResponse) Descriptor deprecated added in v0.48.0 

func (*DetermineStrategyResponse) Descriptor() ([]byte, []int)

Deprecated: Use DetermineStrategyResponse.ProtoReflect.Descriptor instead.

func (*DetermineStrategyResponse) GetSummary added in v0.48.0 

func (x *DetermineStrategyResponse) GetSummary() string

func (*DetermineStrategyResponse) GetSyncStrategy added in v0.48.0 

func (x *DetermineStrategyResponse) GetSyncStrategy() model.SyncStrategy

func (*DetermineStrategyResponse) ProtoMessage added in v0.48.0 

func (*DetermineStrategyResponse) ProtoMessage()

func (*DetermineStrategyResponse) ProtoReflect added in v0.48.0 

func (x *DetermineStrategyResponse) ProtoReflect() protoreflect.Message

func (*DetermineStrategyResponse) Reset added in v0.48.0 

func (x *DetermineStrategyResponse) Reset()

func (*DetermineStrategyResponse) String added in v0.48.0 

func (x *DetermineStrategyResponse) String() string

func (*DetermineStrategyResponse) Validate added in v0.48.0 

func (m *DetermineStrategyResponse) Validate() error

Validate checks the field values on DetermineStrategyResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DetermineStrategyResponse) ValidateAll added in v0.48.0 

func (m *DetermineStrategyResponse) ValidateAll() error

ValidateAll checks the field values on DetermineStrategyResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DetermineStrategyResponseMultiError, or nil if none found.

type DetermineStrategyResponseMultiError added in v0.48.0 

type DetermineStrategyResponseMultiError []error

DetermineStrategyResponseMultiError is an error wrapping multiple validation errors returned by DetermineStrategyResponse.ValidateAll() if the designated constraints aren't met.

func (DetermineStrategyResponseMultiError) AllErrors added in v0.48.0 

func (m DetermineStrategyResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DetermineStrategyResponseMultiError) Error added in v0.48.0 

func (m DetermineStrategyResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DetermineStrategyResponseValidationError added in v0.48.0 

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

DetermineStrategyResponseValidationError is the validation error returned by DetermineStrategyResponse.Validate if the designated constraints aren't met.

func (DetermineStrategyResponseValidationError) Cause added in v0.48.0 

func (e DetermineStrategyResponseValidationError) Cause() error

Cause function returns cause value.

func (DetermineStrategyResponseValidationError) Error added in v0.48.0 

func (e DetermineStrategyResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DetermineStrategyResponseValidationError) ErrorName added in v0.48.0 

func (e DetermineStrategyResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DetermineStrategyResponseValidationError) Field added in v0.48.0 

func (e DetermineStrategyResponseValidationError) Field() string

Field function returns field value.

func (DetermineStrategyResponseValidationError) Key added in v0.48.0 

func (e DetermineStrategyResponseValidationError) Key() bool

Key function returns key value.

func (DetermineStrategyResponseValidationError) Reason added in v0.48.0 

func (e DetermineStrategyResponseValidationError) Reason() string

Reason function returns reason value.

type ExecuteStageRequest 

type ExecuteStageRequest struct {
	Stage       *model.PipelineStage `protobuf:"bytes,1,opt,name=stage,proto3" json:"stage,omitempty"`
	StageConfig []byte               `protobuf:"bytes,2,opt,name=stage_config,json=stageConfig,proto3" json:"stage_config,omitempty"`
	PipedConfig []byte               `protobuf:"bytes,3,opt,name=piped_config,json=pipedConfig,proto3" json:"piped_config,omitempty"`
	Deployment  *model.Deployment    `protobuf:"bytes,4,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStageRequest) Descriptor deprecated 

func (*ExecuteStageRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteStageRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStageRequest) GetDeployment 

func (x *ExecuteStageRequest) GetDeployment() *model.Deployment

func (*ExecuteStageRequest) GetPipedConfig 

func (x *ExecuteStageRequest) GetPipedConfig() []byte

func (*ExecuteStageRequest) GetStage 

func (x *ExecuteStageRequest) GetStage() *model.PipelineStage

func (*ExecuteStageRequest) GetStageConfig 

func (x *ExecuteStageRequest) GetStageConfig() []byte

func (*ExecuteStageRequest) ProtoMessage 

func (*ExecuteStageRequest) ProtoMessage()

func (*ExecuteStageRequest) ProtoReflect 

func (x *ExecuteStageRequest) ProtoReflect() protoreflect.Message

func (*ExecuteStageRequest) Reset 

func (x *ExecuteStageRequest) Reset()

func (*ExecuteStageRequest) String 

func (x *ExecuteStageRequest) String() string

func (*ExecuteStageRequest) Validate 

func (m *ExecuteStageRequest) Validate() error

Validate checks the field values on ExecuteStageRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecuteStageRequest) ValidateAll 

func (m *ExecuteStageRequest) ValidateAll() error

ValidateAll checks the field values on ExecuteStageRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecuteStageRequestMultiError, or nil if none found.

type ExecuteStageRequestMultiError 

type ExecuteStageRequestMultiError []error

ExecuteStageRequestMultiError is an error wrapping multiple validation errors returned by ExecuteStageRequest.ValidateAll() if the designated constraints aren't met.

func (ExecuteStageRequestMultiError) AllErrors 

func (m ExecuteStageRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecuteStageRequestMultiError) Error 

func (m ExecuteStageRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecuteStageRequestValidationError 

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

ExecuteStageRequestValidationError is the validation error returned by ExecuteStageRequest.Validate if the designated constraints aren't met.

func (ExecuteStageRequestValidationError) Cause 

func (e ExecuteStageRequestValidationError) Cause() error

Cause function returns cause value.

func (ExecuteStageRequestValidationError) Error 

func (e ExecuteStageRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ExecuteStageRequestValidationError) ErrorName 

func (e ExecuteStageRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExecuteStageRequestValidationError) Field 

func (e ExecuteStageRequestValidationError) Field() string

Field function returns field value.

func (ExecuteStageRequestValidationError) Key 

func (e ExecuteStageRequestValidationError) Key() bool

Key function returns key value.

func (ExecuteStageRequestValidationError) Reason 

func (e ExecuteStageRequestValidationError) Reason() string

Reason function returns reason value.

type ExecuteStageResponse 

type ExecuteStageResponse struct {
	Status model.StageStatus `protobuf:"varint,1,opt,name=status,proto3,enum=model.StageStatus" json:"status,omitempty"`
	Log    string            `protobuf:"bytes,2,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStageResponse) Descriptor deprecated 

func (*ExecuteStageResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteStageResponse.ProtoReflect.Descriptor instead.

func (*ExecuteStageResponse) GetLog 

func (x *ExecuteStageResponse) GetLog() string

func (*ExecuteStageResponse) GetStatus 

func (x *ExecuteStageResponse) GetStatus() model.StageStatus

func (*ExecuteStageResponse) ProtoMessage 

func (*ExecuteStageResponse) ProtoMessage()

func (*ExecuteStageResponse) ProtoReflect 

func (x *ExecuteStageResponse) ProtoReflect() protoreflect.Message

func (*ExecuteStageResponse) Reset 

func (x *ExecuteStageResponse) Reset()

func (*ExecuteStageResponse) String 

func (x *ExecuteStageResponse) String() string

func (*ExecuteStageResponse) Validate 

func (m *ExecuteStageResponse) Validate() error

Validate checks the field values on ExecuteStageResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecuteStageResponse) ValidateAll 

func (m *ExecuteStageResponse) ValidateAll() error

ValidateAll checks the field values on ExecuteStageResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecuteStageResponseMultiError, or nil if none found.

type ExecuteStageResponseMultiError 

type ExecuteStageResponseMultiError []error

ExecuteStageResponseMultiError is an error wrapping multiple validation errors returned by ExecuteStageResponse.ValidateAll() if the designated constraints aren't met.

func (ExecuteStageResponseMultiError) AllErrors 

func (m ExecuteStageResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecuteStageResponseMultiError) Error 

func (m ExecuteStageResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExecuteStageResponseValidationError 

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

ExecuteStageResponseValidationError is the validation error returned by ExecuteStageResponse.Validate if the designated constraints aren't met.

func (ExecuteStageResponseValidationError) Cause 

func (e ExecuteStageResponseValidationError) Cause() error

Cause function returns cause value.

func (ExecuteStageResponseValidationError) Error 

func (e ExecuteStageResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ExecuteStageResponseValidationError) ErrorName 

func (e ExecuteStageResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ExecuteStageResponseValidationError) Field 

func (e ExecuteStageResponseValidationError) Field() string

Field function returns field value.

func (ExecuteStageResponseValidationError) Key 

func (e ExecuteStageResponseValidationError) Key() bool

Key function returns key value.

func (ExecuteStageResponseValidationError) Reason 

func (e ExecuteStageResponseValidationError) Reason() string

Reason function returns reason value.

type ExecutorServiceClient 

type ExecutorServiceClient interface {
	// Execute executes the given stage of the deployment plan.
	ExecuteStage(ctx context.Context, in *ExecuteStageRequest, opts ...grpc.CallOption) (ExecutorService_ExecuteStageClient, error)
}

ExecutorServiceClient is the client API for ExecutorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorServiceClient 

func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient

type ExecutorServiceServer 

type ExecutorServiceServer interface {
	// Execute executes the given stage of the deployment plan.
	ExecuteStage(*ExecuteStageRequest, ExecutorService_ExecuteStageServer) error
	// contains filtered or unexported methods
}

ExecutorServiceServer is the server API for ExecutorService service. All implementations must embed UnimplementedExecutorServiceServer for forward compatibility

type ExecutorService_ExecuteStageClient 

type ExecutorService_ExecuteStageClient interface {
	Recv() (*ExecuteStageResponse, error)
	grpc.ClientStream
}

type ExecutorService_ExecuteStageServer 

type ExecutorService_ExecuteStageServer interface {
	Send(*ExecuteStageResponse) error
	grpc.ServerStream
}

type PipelineSyncPlanRequest added in v0.48.0 

type PipelineSyncPlanRequest struct {
	Input *PlanPluginInput `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineSyncPlanRequest) Descriptor deprecated added in v0.48.0 

func (*PipelineSyncPlanRequest) Descriptor() ([]byte, []int)

Deprecated: Use PipelineSyncPlanRequest.ProtoReflect.Descriptor instead.

func (*PipelineSyncPlanRequest) GetInput added in v0.48.0 

func (x *PipelineSyncPlanRequest) GetInput() *PlanPluginInput

func (*PipelineSyncPlanRequest) ProtoMessage added in v0.48.0 

func (*PipelineSyncPlanRequest) ProtoMessage()

func (*PipelineSyncPlanRequest) ProtoReflect added in v0.48.0 

func (x *PipelineSyncPlanRequest) ProtoReflect() protoreflect.Message

func (*PipelineSyncPlanRequest) Reset added in v0.48.0 

func (x *PipelineSyncPlanRequest) Reset()

func (*PipelineSyncPlanRequest) String added in v0.48.0 

func (x *PipelineSyncPlanRequest) String() string

func (*PipelineSyncPlanRequest) Validate added in v0.48.0 

func (m *PipelineSyncPlanRequest) Validate() error

Validate checks the field values on PipelineSyncPlanRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PipelineSyncPlanRequest) ValidateAll added in v0.48.0 

func (m *PipelineSyncPlanRequest) ValidateAll() error

ValidateAll checks the field values on PipelineSyncPlanRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineSyncPlanRequestMultiError, or nil if none found.

type PipelineSyncPlanRequestMultiError added in v0.48.0 

type PipelineSyncPlanRequestMultiError []error

PipelineSyncPlanRequestMultiError is an error wrapping multiple validation errors returned by PipelineSyncPlanRequest.ValidateAll() if the designated constraints aren't met.

func (PipelineSyncPlanRequestMultiError) AllErrors added in v0.48.0 

func (m PipelineSyncPlanRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PipelineSyncPlanRequestMultiError) Error added in v0.48.0 

func (m PipelineSyncPlanRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PipelineSyncPlanRequestValidationError added in v0.48.0 

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

PipelineSyncPlanRequestValidationError is the validation error returned by PipelineSyncPlanRequest.Validate if the designated constraints aren't met.

func (PipelineSyncPlanRequestValidationError) Cause added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) Cause() error

Cause function returns cause value.

func (PipelineSyncPlanRequestValidationError) Error added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PipelineSyncPlanRequestValidationError) ErrorName added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PipelineSyncPlanRequestValidationError) Field added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) Field() string

Field function returns field value.

func (PipelineSyncPlanRequestValidationError) Key added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) Key() bool

Key function returns key value.

func (PipelineSyncPlanRequestValidationError) Reason added in v0.48.0 

func (e PipelineSyncPlanRequestValidationError) Reason() string

Reason function returns reason value.

type PipelineSyncPlanResponse added in v0.48.0 

type PipelineSyncPlanResponse struct {

	// Stages of deployment pipeline under pipeline sync strategy.
	Stages []*model.PipelineStage `protobuf:"bytes,1,rep,name=stages,proto3" json:"stages,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineSyncPlanResponse) Descriptor deprecated added in v0.48.0 

func (*PipelineSyncPlanResponse) Descriptor() ([]byte, []int)

Deprecated: Use PipelineSyncPlanResponse.ProtoReflect.Descriptor instead.

func (*PipelineSyncPlanResponse) GetStages added in v0.48.0 

func (x *PipelineSyncPlanResponse) GetStages() []*model.PipelineStage

func (*PipelineSyncPlanResponse) ProtoMessage added in v0.48.0 

func (*PipelineSyncPlanResponse) ProtoMessage()

func (*PipelineSyncPlanResponse) ProtoReflect added in v0.48.0 

func (x *PipelineSyncPlanResponse) ProtoReflect() protoreflect.Message

func (*PipelineSyncPlanResponse) Reset added in v0.48.0 

func (x *PipelineSyncPlanResponse) Reset()

func (*PipelineSyncPlanResponse) String added in v0.48.0 

func (x *PipelineSyncPlanResponse) String() string

func (*PipelineSyncPlanResponse) Validate added in v0.48.0 

func (m *PipelineSyncPlanResponse) Validate() error

Validate checks the field values on PipelineSyncPlanResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PipelineSyncPlanResponse) ValidateAll added in v0.48.0 

func (m *PipelineSyncPlanResponse) ValidateAll() error

ValidateAll checks the field values on PipelineSyncPlanResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineSyncPlanResponseMultiError, or nil if none found.

type PipelineSyncPlanResponseMultiError added in v0.48.0 

type PipelineSyncPlanResponseMultiError []error

PipelineSyncPlanResponseMultiError is an error wrapping multiple validation errors returned by PipelineSyncPlanResponse.ValidateAll() if the designated constraints aren't met.

func (PipelineSyncPlanResponseMultiError) AllErrors added in v0.48.0 

func (m PipelineSyncPlanResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PipelineSyncPlanResponseMultiError) Error added in v0.48.0 

func (m PipelineSyncPlanResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PipelineSyncPlanResponseValidationError added in v0.48.0 

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

PipelineSyncPlanResponseValidationError is the validation error returned by PipelineSyncPlanResponse.Validate if the designated constraints aren't met.

func (PipelineSyncPlanResponseValidationError) Cause added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) Cause() error

Cause function returns cause value.

func (PipelineSyncPlanResponseValidationError) Error added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) Error() string

Error satisfies the builtin error interface

func (PipelineSyncPlanResponseValidationError) ErrorName added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) ErrorName() string

ErrorName returns error name.

func (PipelineSyncPlanResponseValidationError) Field added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) Field() string

Field function returns field value.

func (PipelineSyncPlanResponseValidationError) Key added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) Key() bool

Key function returns key value.

func (PipelineSyncPlanResponseValidationError) Reason added in v0.48.0 

func (e PipelineSyncPlanResponseValidationError) Reason() string

Reason function returns reason value.

type PlanPluginInput added in v0.48.0 

type PlanPluginInput struct {

	// The deployment to build a plan for.
	Deployment *model.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// The remote URL of the deployment source, where plugin can find the deployments sources (manifests).
	SourceRemoteUrl string `protobuf:"bytes,2,opt,name=source_remote_url,json=sourceRemoteUrl,proto3" json:"source_remote_url,omitempty"`
	// Last successful commit hash and config file name.
	// Use to build deployment source object for last successful deployment.
	LastSuccessfulCommitHash     string `` /* 137-byte string literal not displayed */
	LastSuccessfulConfigFileName string `` /* 151-byte string literal not displayed */
	// The configuration of plugin that handles the deployment.
	PluginConfig []byte `protobuf:"bytes,5,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanPluginInput) Descriptor deprecated added in v0.48.0 

func (*PlanPluginInput) Descriptor() ([]byte, []int)

Deprecated: Use PlanPluginInput.ProtoReflect.Descriptor instead.

func (*PlanPluginInput) GetDeployment added in v0.48.0 

func (x *PlanPluginInput) GetDeployment() *model.Deployment

func (*PlanPluginInput) GetLastSuccessfulCommitHash added in v0.48.0 

func (x *PlanPluginInput) GetLastSuccessfulCommitHash() string

func (*PlanPluginInput) GetLastSuccessfulConfigFileName added in v0.48.0 

func (x *PlanPluginInput) GetLastSuccessfulConfigFileName() string

func (*PlanPluginInput) GetPluginConfig added in v0.48.0 

func (x *PlanPluginInput) GetPluginConfig() []byte

func (*PlanPluginInput) GetSourceRemoteUrl added in v0.48.0 

func (x *PlanPluginInput) GetSourceRemoteUrl() string

func (*PlanPluginInput) ProtoMessage added in v0.48.0 

func (*PlanPluginInput) ProtoMessage()

func (*PlanPluginInput) ProtoReflect added in v0.48.0 

func (x *PlanPluginInput) ProtoReflect() protoreflect.Message

func (*PlanPluginInput) Reset added in v0.48.0 

func (x *PlanPluginInput) Reset()

func (*PlanPluginInput) String added in v0.48.0 

func (x *PlanPluginInput) String() string

func (*PlanPluginInput) Validate added in v0.48.0 

func (m *PlanPluginInput) Validate() error

Validate checks the field values on PlanPluginInput with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PlanPluginInput) ValidateAll added in v0.48.0 

func (m *PlanPluginInput) ValidateAll() error

ValidateAll checks the field values on PlanPluginInput with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PlanPluginInputMultiError, or nil if none found.

type PlanPluginInputMultiError added in v0.48.0 

type PlanPluginInputMultiError []error

PlanPluginInputMultiError is an error wrapping multiple validation errors returned by PlanPluginInput.ValidateAll() if the designated constraints aren't met.

func (PlanPluginInputMultiError) AllErrors added in v0.48.0 

func (m PlanPluginInputMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PlanPluginInputMultiError) Error added in v0.48.0 

func (m PlanPluginInputMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PlanPluginInputValidationError added in v0.48.0 

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

PlanPluginInputValidationError is the validation error returned by PlanPluginInput.Validate if the designated constraints aren't met.

func (PlanPluginInputValidationError) Cause added in v0.48.0 

func (e PlanPluginInputValidationError) Cause() error

Cause function returns cause value.

func (PlanPluginInputValidationError) Error added in v0.48.0 

func (e PlanPluginInputValidationError) Error() string

Error satisfies the builtin error interface

func (PlanPluginInputValidationError) ErrorName added in v0.48.0 

func (e PlanPluginInputValidationError) ErrorName() string

ErrorName returns error name.

func (PlanPluginInputValidationError) Field added in v0.48.0 

func (e PlanPluginInputValidationError) Field() string

Field function returns field value.

func (PlanPluginInputValidationError) Key added in v0.48.0 

func (e PlanPluginInputValidationError) Key() bool

Key function returns key value.

func (PlanPluginInputValidationError) Reason added in v0.48.0 

func (e PlanPluginInputValidationError) Reason() string

Reason function returns reason value.

type PlannerServiceClient 

type PlannerServiceClient interface {
	// DetermineStrategy determines which strategy should be used for the given deployment.
	DetermineStrategy(ctx context.Context, in *DetermineStrategyRequest, opts ...grpc.CallOption) (*DetermineStrategyResponse, error)
	// QuickSyncPlan builds plan for the given deployment using quick sync strategy.
	QuickSyncPlan(ctx context.Context, in *QuickSyncPlanRequest, opts ...grpc.CallOption) (*QuickSyncPlanResponse, error)
	// PipelineSyncPlan builds plan for the given deployment using pipeline sync strategy.
	PipelineSyncPlan(ctx context.Context, in *PipelineSyncPlanRequest, opts ...grpc.CallOption) (*PipelineSyncPlanResponse, error)
}

PlannerServiceClient is the client API for PlannerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPlannerServiceClient 

func NewPlannerServiceClient(cc grpc.ClientConnInterface) PlannerServiceClient

type PlannerServiceServer 

type PlannerServiceServer interface {
	// DetermineStrategy determines which strategy should be used for the given deployment.
	DetermineStrategy(context.Context, *DetermineStrategyRequest) (*DetermineStrategyResponse, error)
	// QuickSyncPlan builds plan for the given deployment using quick sync strategy.
	QuickSyncPlan(context.Context, *QuickSyncPlanRequest) (*QuickSyncPlanResponse, error)
	// PipelineSyncPlan builds plan for the given deployment using pipeline sync strategy.
	PipelineSyncPlan(context.Context, *PipelineSyncPlanRequest) (*PipelineSyncPlanResponse, error)
	// contains filtered or unexported methods
}

PlannerServiceServer is the server API for PlannerService service. All implementations must embed UnimplementedPlannerServiceServer for forward compatibility

type PlatformPluginClient 

type PlatformPluginClient interface {
	PlannerServiceClient
	ExecutorServiceClient
	Close() error
}

func NewClient 

func NewClient(ctx context.Context, address string, opts ...rpcclient.DialOption) (PlatformPluginClient, error)

type QuickSyncPlanRequest added in v0.48.0 

type QuickSyncPlanRequest struct {
	Input *PlanPluginInput `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*QuickSyncPlanRequest) Descriptor deprecated added in v0.48.0 

func (*QuickSyncPlanRequest) Descriptor() ([]byte, []int)

Deprecated: Use QuickSyncPlanRequest.ProtoReflect.Descriptor instead.

func (*QuickSyncPlanRequest) GetInput added in v0.48.0 

func (x *QuickSyncPlanRequest) GetInput() *PlanPluginInput

func (*QuickSyncPlanRequest) ProtoMessage added in v0.48.0 

func (*QuickSyncPlanRequest) ProtoMessage()

func (*QuickSyncPlanRequest) ProtoReflect added in v0.48.0 

func (x *QuickSyncPlanRequest) ProtoReflect() protoreflect.Message

func (*QuickSyncPlanRequest) Reset added in v0.48.0 

func (x *QuickSyncPlanRequest) Reset()

func (*QuickSyncPlanRequest) String added in v0.48.0 

func (x *QuickSyncPlanRequest) String() string

func (*QuickSyncPlanRequest) Validate added in v0.48.0 

func (m *QuickSyncPlanRequest) Validate() error

Validate checks the field values on QuickSyncPlanRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QuickSyncPlanRequest) ValidateAll added in v0.48.0 

func (m *QuickSyncPlanRequest) ValidateAll() error

ValidateAll checks the field values on QuickSyncPlanRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QuickSyncPlanRequestMultiError, or nil if none found.

type QuickSyncPlanRequestMultiError added in v0.48.0 

type QuickSyncPlanRequestMultiError []error

QuickSyncPlanRequestMultiError is an error wrapping multiple validation errors returned by QuickSyncPlanRequest.ValidateAll() if the designated constraints aren't met.

func (QuickSyncPlanRequestMultiError) AllErrors added in v0.48.0 

func (m QuickSyncPlanRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QuickSyncPlanRequestMultiError) Error added in v0.48.0 

func (m QuickSyncPlanRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type QuickSyncPlanRequestValidationError added in v0.48.0 

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

QuickSyncPlanRequestValidationError is the validation error returned by QuickSyncPlanRequest.Validate if the designated constraints aren't met.

func (QuickSyncPlanRequestValidationError) Cause added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) Cause() error

Cause function returns cause value.

func (QuickSyncPlanRequestValidationError) Error added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) Error() string

Error satisfies the builtin error interface

func (QuickSyncPlanRequestValidationError) ErrorName added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) ErrorName() string

ErrorName returns error name.

func (QuickSyncPlanRequestValidationError) Field added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) Field() string

Field function returns field value.

func (QuickSyncPlanRequestValidationError) Key added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) Key() bool

Key function returns key value.

func (QuickSyncPlanRequestValidationError) Reason added in v0.48.0 

func (e QuickSyncPlanRequestValidationError) Reason() string

Reason function returns reason value.

type QuickSyncPlanResponse added in v0.48.0 

type QuickSyncPlanResponse struct {

	// Stages of deployment pipeline under quick sync strategy.
	Stages []*model.PipelineStage `protobuf:"bytes,1,rep,name=stages,proto3" json:"stages,omitempty"`
	// contains filtered or unexported fields
}

func (*QuickSyncPlanResponse) Descriptor deprecated added in v0.48.0 

func (*QuickSyncPlanResponse) Descriptor() ([]byte, []int)

Deprecated: Use QuickSyncPlanResponse.ProtoReflect.Descriptor instead.

func (*QuickSyncPlanResponse) GetStages added in v0.48.0 

func (x *QuickSyncPlanResponse) GetStages() []*model.PipelineStage

func (*QuickSyncPlanResponse) ProtoMessage added in v0.48.0 

func (*QuickSyncPlanResponse) ProtoMessage()

func (*QuickSyncPlanResponse) ProtoReflect added in v0.48.0 

func (x *QuickSyncPlanResponse) ProtoReflect() protoreflect.Message

func (*QuickSyncPlanResponse) Reset added in v0.48.0 

func (x *QuickSyncPlanResponse) Reset()

func (*QuickSyncPlanResponse) String added in v0.48.0 

func (x *QuickSyncPlanResponse) String() string

func (*QuickSyncPlanResponse) Validate added in v0.48.0 

func (m *QuickSyncPlanResponse) Validate() error

Validate checks the field values on QuickSyncPlanResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*QuickSyncPlanResponse) ValidateAll added in v0.48.0 

func (m *QuickSyncPlanResponse) ValidateAll() error

ValidateAll checks the field values on QuickSyncPlanResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in QuickSyncPlanResponseMultiError, or nil if none found.

type QuickSyncPlanResponseMultiError added in v0.48.0 

type QuickSyncPlanResponseMultiError []error

QuickSyncPlanResponseMultiError is an error wrapping multiple validation errors returned by QuickSyncPlanResponse.ValidateAll() if the designated constraints aren't met.

func (QuickSyncPlanResponseMultiError) AllErrors added in v0.48.0 

func (m QuickSyncPlanResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (QuickSyncPlanResponseMultiError) Error added in v0.48.0 

func (m QuickSyncPlanResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type QuickSyncPlanResponseValidationError added in v0.48.0 

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

QuickSyncPlanResponseValidationError is the validation error returned by QuickSyncPlanResponse.Validate if the designated constraints aren't met.

func (QuickSyncPlanResponseValidationError) Cause added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) Cause() error

Cause function returns cause value.

func (QuickSyncPlanResponseValidationError) Error added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) Error() string

Error satisfies the builtin error interface

func (QuickSyncPlanResponseValidationError) ErrorName added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) ErrorName() string

ErrorName returns error name.

func (QuickSyncPlanResponseValidationError) Field added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) Field() string

Field function returns field value.

func (QuickSyncPlanResponseValidationError) Key added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) Key() bool

Key function returns key value.

func (QuickSyncPlanResponseValidationError) Reason added in v0.48.0 

func (e QuickSyncPlanResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedExecutorServiceServer 

type UnimplementedExecutorServiceServer struct {
}

UnimplementedExecutorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServiceServer) ExecuteStage 

func (UnimplementedExecutorServiceServer) ExecuteStage(*ExecuteStageRequest, ExecutorService_ExecuteStageServer) error

type UnimplementedPlannerServiceServer 

type UnimplementedPlannerServiceServer struct {
}

UnimplementedPlannerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPlannerServiceServer) DetermineStrategy added in v0.48.0 

func (UnimplementedPlannerServiceServer) DetermineStrategy(context.Context, *DetermineStrategyRequest) (*DetermineStrategyResponse, error)

func (UnimplementedPlannerServiceServer) PipelineSyncPlan added in v0.48.0 

func (UnimplementedPlannerServiceServer) PipelineSyncPlan(context.Context, *PipelineSyncPlanRequest) (*PipelineSyncPlanResponse, error)

func (UnimplementedPlannerServiceServer) QuickSyncPlan added in v0.48.0 

func (UnimplementedPlannerServiceServer) QuickSyncPlan(context.Context, *QuickSyncPlanRequest) (*QuickSyncPlanResponse, error)

type UnsafeExecutorServiceServer 

type UnsafeExecutorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServiceServer will result in compilation errors.

type UnsafePlannerServiceServer 

type UnsafePlannerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafePlannerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PlannerServiceServer will result in compilation errors.

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.