pb

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cluster_proto protoreflect.FileDescriptor

Functions

func ClusterServiceClientType 

func ClusterServiceClientType() reflect.Type

ClusterServiceClientType .

func ClusterServiceHandlerType 

func ClusterServiceHandlerType() reflect.Type

ClusterServiceHandlerType .

func ClusterServiceServerType 

func ClusterServiceServerType() reflect.Type

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)

func ServiceNames 

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func Types 

func Types() []reflect.Type

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)

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.