service

Documentation

Index

• Constants
• Variables
• func RegisterServiceInterfaceServer(s grpc.ServiceRegistrar, srv ServiceInterfaceServer)
• type ApplyServiceRequest
  • func (*ApplyServiceRequest) Descriptor() ([]byte, []int)
  • func (x *ApplyServiceRequest) GetCd() *biz.ContinuousDeployment
  • func (x *ApplyServiceRequest) GetService() *biz.Service
  • func (*ApplyServiceRequest) ProtoMessage()
  • func (x *ApplyServiceRequest) ProtoReflect() protoreflect.Message
  • func (x *ApplyServiceRequest) Reset()
  • func (x *ApplyServiceRequest) String() string
• type ServiceInterfaceClient
  • func NewServiceInterfaceClient(cc grpc.ClientConnInterface) ServiceInterfaceClient
• type ServiceInterfaceServer
• type UnimplementedServiceInterfaceServer
  • func (UnimplementedServiceInterfaceServer) ApplyService(context.Context, *ApplyServiceRequest) (*common.Msg, error)
  • func (UnimplementedServiceInterfaceServer) CleanWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)
  • func (UnimplementedServiceInterfaceServer) CommitWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)
  • func (UnimplementedServiceInterfaceServer) GetService(context.Context, *biz.Service) (*biz.Service, error)
  • func (UnimplementedServiceInterfaceServer) GetWorkflow(context.Context, *biz.Workflow) (*biz.Workflow, error)
• type UnsafeServiceInterfaceServer

Constants

const (
	ServiceInterface_ApplyService_FullMethodName   = "/clusterruntime.api.service.ServiceInterface/ApplyService"
	ServiceInterface_GetService_FullMethodName     = "/clusterruntime.api.service.ServiceInterface/GetService"
	ServiceInterface_CommitWorkflow_FullMethodName = "/clusterruntime.api.service.ServiceInterface/CommitWorkflow"
	ServiceInterface_GetWorkflow_FullMethodName    = "/clusterruntime.api.service.ServiceInterface/GetWorkflow"
	ServiceInterface_CleanWorkflow_FullMethodName  = "/clusterruntime.api.service.ServiceInterface/CleanWorkflow"
)

Variables

var File_internal_repository_clusterruntime_api_service_message_proto protoreflect.FileDescriptor

var File_internal_repository_clusterruntime_api_service_service_proto protoreflect.FileDescriptor

var ServiceInterface_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "clusterruntime.api.service.ServiceInterface",
	HandlerType: (*ServiceInterfaceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ApplyService",
			Handler:    _ServiceInterface_ApplyService_Handler,
		},
		{
			MethodName: "GetService",
			Handler:    _ServiceInterface_GetService_Handler,
		},
		{
			MethodName: "CommitWorkflow",
			Handler:    _ServiceInterface_CommitWorkflow_Handler,
		},
		{
			MethodName: "GetWorkflow",
			Handler:    _ServiceInterface_GetWorkflow_Handler,
		},
		{
			MethodName: "CleanWorkflow",
			Handler:    _ServiceInterface_CleanWorkflow_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/repository/clusterruntime/api/service/service.proto",
}

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

Functions

func RegisterServiceInterfaceServer

func RegisterServiceInterfaceServer(s grpc.ServiceRegistrar, srv ServiceInterfaceServer)

Types

type ApplyServiceRequest

type ApplyServiceRequest struct {
	Service *biz.Service              `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Cd      *biz.ContinuousDeployment `protobuf:"bytes,2,opt,name=cd,proto3" json:"cd,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyServiceRequest) Descriptor

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

Deprecated: Use ApplyServiceRequest.ProtoReflect.Descriptor instead.

func (*ApplyServiceRequest) GetCd

func (x *ApplyServiceRequest) GetCd() *biz.ContinuousDeployment

func (*ApplyServiceRequest) GetService

func (x *ApplyServiceRequest) GetService() *biz.Service

func (*ApplyServiceRequest) ProtoMessage

func (*ApplyServiceRequest) ProtoMessage()

func (*ApplyServiceRequest) ProtoReflect

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

func (*ApplyServiceRequest) Reset

func (x *ApplyServiceRequest) Reset()

func (*ApplyServiceRequest) String

func (x *ApplyServiceRequest) String() string

type ServiceInterfaceClient

type ServiceInterfaceClient interface {
	ApplyService(ctx context.Context, in *ApplyServiceRequest, opts ...grpc.CallOption) (*common.Msg, error)
	GetService(ctx context.Context, in *biz.Service, opts ...grpc.CallOption) (*biz.Service, error)
	CommitWorkflow(ctx context.Context, in *biz.Workflow, opts ...grpc.CallOption) (*common.Msg, error)
	GetWorkflow(ctx context.Context, in *biz.Workflow, opts ...grpc.CallOption) (*biz.Workflow, error)
	CleanWorkflow(ctx context.Context, in *biz.Workflow, opts ...grpc.CallOption) (*common.Msg, error)
}

ServiceInterfaceClient is the client API for ServiceInterface 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 NewServiceInterfaceClient

func NewServiceInterfaceClient(cc grpc.ClientConnInterface) ServiceInterfaceClient

type ServiceInterfaceServer

type ServiceInterfaceServer interface {
	ApplyService(context.Context, *ApplyServiceRequest) (*common.Msg, error)
	GetService(context.Context, *biz.Service) (*biz.Service, error)
	CommitWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)
	GetWorkflow(context.Context, *biz.Workflow) (*biz.Workflow, error)
	CleanWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)
	// contains filtered or unexported methods
}

ServiceInterfaceServer is the server API for ServiceInterface service. All implementations must embed UnimplementedServiceInterfaceServer for forward compatibility.

type UnimplementedServiceInterfaceServer

type UnimplementedServiceInterfaceServer struct{}

UnimplementedServiceInterfaceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedServiceInterfaceServer) ApplyService

func (UnimplementedServiceInterfaceServer) ApplyService(context.Context, *ApplyServiceRequest) (*common.Msg, error)

func (UnimplementedServiceInterfaceServer) CleanWorkflow

func (UnimplementedServiceInterfaceServer) CleanWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)

func (UnimplementedServiceInterfaceServer) CommitWorkflow

func (UnimplementedServiceInterfaceServer) CommitWorkflow(context.Context, *biz.Workflow) (*common.Msg, error)

func (UnimplementedServiceInterfaceServer) GetService

func (UnimplementedServiceInterfaceServer) GetService(context.Context, *biz.Service) (*biz.Service, error)

func (UnimplementedServiceInterfaceServer) GetWorkflow

func (UnimplementedServiceInterfaceServer) GetWorkflow(context.Context, *biz.Workflow) (*biz.Workflow, error)

type UnsafeServiceInterfaceServer

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

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