Documentation ¶
Index ¶
- Variables
- func ClusterServiceClientType() reflect.Type
- func ClusterServiceHandlerType() reflect.Type
- func ClusterServiceServerType() reflect.Type
- func RegisterClusterServiceHandler(r http.Router, srv ClusterServiceHandler, opts ...http.HandleOption)
- func RegisterClusterServiceImp(regester transport.Register, srv ClusterServiceServer, ...)
- func RegisterClusterServiceServer(s grpc1.ServiceRegistrar, srv ClusterServiceServer, opts ...grpc1.HandleOption)
- func ServiceNames(svr ...string) []string
- func Types() []reflect.Type
- type ClusterHookRequest
- func (*ClusterHookRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterHookRequest) GetAction() string
- func (x *ClusterHookRequest) GetApplicationID() string
- func (x *ClusterHookRequest) GetContent() *structpb.Value
- func (x *ClusterHookRequest) GetEnv() string
- func (x *ClusterHookRequest) GetEvent() string
- func (x *ClusterHookRequest) GetOrgID() string
- func (x *ClusterHookRequest) GetProjectID() string
- func (x *ClusterHookRequest) GetTimeStamp() string
- func (m *ClusterHookRequest) MarshalJSON() ([]byte, error)
- func (*ClusterHookRequest) ProtoMessage()
- func (x *ClusterHookRequest) ProtoReflect() protoreflect.Message
- func (x *ClusterHookRequest) Reset()
- func (x *ClusterHookRequest) String() string
- func (m *ClusterHookRequest) UnmarshalJSON(b []byte) error
- func (m *ClusterHookRequest) UnmarshalURLValues(prefix string, values url.Values) error
- func (this *ClusterHookRequest) Validate() error
- type ClusterHookResponse
- func (*ClusterHookResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ClusterHookResponse) MarshalJSON() ([]byte, error)
- func (*ClusterHookResponse) ProtoMessage()
- func (x *ClusterHookResponse) ProtoReflect() protoreflect.Message
- func (x *ClusterHookResponse) Reset()
- func (x *ClusterHookResponse) String() string
- func (m *ClusterHookResponse) UnmarshalJSON(b []byte) error
- func (m *ClusterHookResponse) UnmarshalURLValues(prefix string, values url.Values) error
- func (this *ClusterHookResponse) Validate() error
- type ClusterServiceClient
- type ClusterServiceHandler
- type ClusterServiceServer
- type UnimplementedClusterServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_cluster_proto protoreflect.FileDescriptor
Functions ¶
func ClusterServiceClientType ¶
ClusterServiceClientType .
func ClusterServiceHandlerType ¶
ClusterServiceHandlerType .
func ClusterServiceServerType ¶
ClusterServiceServerType .
func RegisterClusterServiceHandler ¶
func RegisterClusterServiceHandler(r http.Router, srv ClusterServiceHandler, opts ...http.HandleOption)
RegisterClusterServiceHandler register ClusterServiceHandler to http.Router.
func RegisterClusterServiceImp ¶
func RegisterClusterServiceImp(regester transport.Register, srv ClusterServiceServer, opts ...transport.ServiceOption)
RegisterClusterServiceImp cluster.proto
func RegisterClusterServiceServer ¶
func RegisterClusterServiceServer(s grpc1.ServiceRegistrar, srv ClusterServiceServer, opts ...grpc1.HandleOption)
Types ¶
type ClusterHookRequest ¶
type ClusterHookRequest struct { Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` OrgID string `protobuf:"bytes,3,opt,name=orgID,proto3" json:"orgID,omitempty"` ProjectID string `protobuf:"bytes,4,opt,name=projectID,proto3" json:"projectID,omitempty"` ApplicationID string `protobuf:"bytes,5,opt,name=applicationID,proto3" json:"applicationID,omitempty"` Env string `protobuf:"bytes,6,opt,name=env,proto3" json:"env,omitempty"` TimeStamp string `protobuf:"bytes,7,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"` Content *structpb.Value `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ClusterHookRequest) Descriptor
deprecated
func (*ClusterHookRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClusterHookRequest.ProtoReflect.Descriptor instead.
func (*ClusterHookRequest) GetAction ¶
func (x *ClusterHookRequest) GetAction() string
func (*ClusterHookRequest) GetApplicationID ¶
func (x *ClusterHookRequest) GetApplicationID() string
func (*ClusterHookRequest) GetContent ¶
func (x *ClusterHookRequest) GetContent() *structpb.Value
func (*ClusterHookRequest) GetEnv ¶
func (x *ClusterHookRequest) GetEnv() string
func (*ClusterHookRequest) GetEvent ¶
func (x *ClusterHookRequest) GetEvent() string
func (*ClusterHookRequest) GetOrgID ¶
func (x *ClusterHookRequest) GetOrgID() string
func (*ClusterHookRequest) GetProjectID ¶
func (x *ClusterHookRequest) GetProjectID() string
func (*ClusterHookRequest) GetTimeStamp ¶
func (x *ClusterHookRequest) GetTimeStamp() string
func (*ClusterHookRequest) MarshalJSON ¶
func (m *ClusterHookRequest) MarshalJSON() ([]byte, error)
ClusterHookRequest implement json.Marshaler.
func (*ClusterHookRequest) ProtoMessage ¶
func (*ClusterHookRequest) ProtoMessage()
func (*ClusterHookRequest) ProtoReflect ¶
func (x *ClusterHookRequest) ProtoReflect() protoreflect.Message
func (*ClusterHookRequest) Reset ¶
func (x *ClusterHookRequest) Reset()
func (*ClusterHookRequest) String ¶
func (x *ClusterHookRequest) String() string
func (*ClusterHookRequest) UnmarshalJSON ¶
func (m *ClusterHookRequest) UnmarshalJSON(b []byte) error
ClusterHookRequest implement json.Marshaler.
func (*ClusterHookRequest) UnmarshalURLValues ¶
func (m *ClusterHookRequest) UnmarshalURLValues(prefix string, values url.Values) error
ClusterHookRequest implement urlenc.URLValuesUnmarshaler.
func (*ClusterHookRequest) Validate ¶
func (this *ClusterHookRequest) Validate() error
type ClusterHookResponse ¶
type ClusterHookResponse struct {
// contains filtered or unexported fields
}
func (*ClusterHookResponse) Descriptor
deprecated
func (*ClusterHookResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClusterHookResponse.ProtoReflect.Descriptor instead.
func (*ClusterHookResponse) MarshalJSON ¶
func (m *ClusterHookResponse) MarshalJSON() ([]byte, error)
ClusterHookResponse implement json.Marshaler.
func (*ClusterHookResponse) ProtoMessage ¶
func (*ClusterHookResponse) ProtoMessage()
func (*ClusterHookResponse) ProtoReflect ¶
func (x *ClusterHookResponse) ProtoReflect() protoreflect.Message
func (*ClusterHookResponse) Reset ¶
func (x *ClusterHookResponse) Reset()
func (*ClusterHookResponse) String ¶
func (x *ClusterHookResponse) String() string
func (*ClusterHookResponse) UnmarshalJSON ¶
func (m *ClusterHookResponse) UnmarshalJSON(b []byte) error
ClusterHookResponse implement json.Marshaler.
func (*ClusterHookResponse) UnmarshalURLValues ¶
func (m *ClusterHookResponse) UnmarshalURLValues(prefix string, values url.Values) error
ClusterHookResponse implement urlenc.URLValuesUnmarshaler.
func (*ClusterHookResponse) Validate ¶
func (this *ClusterHookResponse) Validate() error
type ClusterServiceClient ¶
type ClusterServiceClient interface {
ClusterHook(ctx context.Context, in *ClusterHookRequest, opts ...grpc.CallOption) (*ClusterHookResponse, error)
}
ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient ¶
func NewClusterServiceClient(cc grpc1.ClientConnInterface) ClusterServiceClient
type ClusterServiceHandler ¶
type ClusterServiceHandler interface { // POST /api/pipeline-clusters/actions/hook ClusterHook(context.Context, *ClusterHookRequest) (*ClusterHookResponse, error) }
ClusterServiceHandler is the server API for ClusterService service.
type ClusterServiceServer ¶
type ClusterServiceServer interface {
ClusterHook(context.Context, *ClusterHookRequest) (*ClusterHookResponse, error)
}
ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility
type UnimplementedClusterServiceServer ¶
type UnimplementedClusterServiceServer struct { }
UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.
func (*UnimplementedClusterServiceServer) ClusterHook ¶
func (*UnimplementedClusterServiceServer) ClusterHook(context.Context, *ClusterHookRequest) (*ClusterHookResponse, error)