Documentation
¶
Overview ¶
Package v1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterRegistrationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterRegistrationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RegistrationServiceClient) error
- func RegisterRegistrationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterRegistrationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RegistrationServiceServer) error
- func RegisterRegistrationServiceServer(s grpc.ServiceRegistrar, srv RegistrationServiceServer)
- type GetServiceStatusRequest
- func (x *GetServiceStatusRequest) GetNamespace() string
- func (x *GetServiceStatusRequest) GetServiceName() string
- func (*GetServiceStatusRequest) ProtoMessage()
- func (x *GetServiceStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetServiceStatusRequest) Reset()
- func (x *GetServiceStatusRequest) SetNamespace(v string)
- func (x *GetServiceStatusRequest) SetServiceName(v string)
- func (x *GetServiceStatusRequest) String() string
- type GetServiceStatusRequest_builder
- type GetServiceStatusResponse
- func (x *GetServiceStatusResponse) GetMetrics() map[string]int64
- func (x *GetServiceStatusResponse) GetTools() []*v1.ToolDefinition
- func (*GetServiceStatusResponse) ProtoMessage()
- func (x *GetServiceStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetServiceStatusResponse) Reset()
- func (x *GetServiceStatusResponse) SetMetrics(v map[string]int64)
- func (x *GetServiceStatusResponse) SetTools(v []*v1.ToolDefinition)
- func (x *GetServiceStatusResponse) String() string
- type GetServiceStatusResponse_builder
- type InitiateOAuth2FlowRequest
- func (x *InitiateOAuth2FlowRequest) GetNamespace() string
- func (x *InitiateOAuth2FlowRequest) GetServiceId() string
- func (*InitiateOAuth2FlowRequest) ProtoMessage()
- func (x *InitiateOAuth2FlowRequest) ProtoReflect() protoreflect.Message
- func (x *InitiateOAuth2FlowRequest) Reset()
- func (x *InitiateOAuth2FlowRequest) SetNamespace(v string)
- func (x *InitiateOAuth2FlowRequest) SetServiceId(v string)
- func (x *InitiateOAuth2FlowRequest) String() string
- type InitiateOAuth2FlowRequest_builder
- type InitiateOAuth2FlowResponse
- func (x *InitiateOAuth2FlowResponse) GetAuthorizationUrl() string
- func (x *InitiateOAuth2FlowResponse) GetState() string
- func (*InitiateOAuth2FlowResponse) ProtoMessage()
- func (x *InitiateOAuth2FlowResponse) ProtoReflect() protoreflect.Message
- func (x *InitiateOAuth2FlowResponse) Reset()
- func (x *InitiateOAuth2FlowResponse) SetAuthorizationUrl(v string)
- func (x *InitiateOAuth2FlowResponse) SetState(v string)
- func (x *InitiateOAuth2FlowResponse) String() string
- type InitiateOAuth2FlowResponse_builder
- type ListServicesRequest
- type ListServicesRequest_builder
- type ListServicesResponse
- func (x *ListServicesResponse) GetServices() []*v1.UpstreamServiceConfig
- func (*ListServicesResponse) ProtoMessage()
- func (x *ListServicesResponse) ProtoReflect() protoreflect.Message
- func (x *ListServicesResponse) Reset()
- func (x *ListServicesResponse) SetServices(v []*v1.UpstreamServiceConfig)
- func (x *ListServicesResponse) String() string
- type ListServicesResponse_builder
- type RegisterServiceRequest
- func (x *RegisterServiceRequest) ClearConfig()
- func (x *RegisterServiceRequest) GetConfig() *v1.UpstreamServiceConfig
- func (x *RegisterServiceRequest) HasConfig() bool
- func (*RegisterServiceRequest) ProtoMessage()
- func (x *RegisterServiceRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterServiceRequest) Reset()
- func (x *RegisterServiceRequest) SetConfig(v *v1.UpstreamServiceConfig)
- func (x *RegisterServiceRequest) String() string
- type RegisterServiceRequest_builder
- type RegisterServiceResponse
- func (x *RegisterServiceResponse) GetDiscoveredResources() []*v1.ResourceDefinition
- func (x *RegisterServiceResponse) GetDiscoveredTools() []*v1.ToolDefinition
- func (x *RegisterServiceResponse) GetMessage() string
- func (x *RegisterServiceResponse) GetServiceKey() string
- func (*RegisterServiceResponse) ProtoMessage()
- func (x *RegisterServiceResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterServiceResponse) Reset()
- func (x *RegisterServiceResponse) SetDiscoveredResources(v []*v1.ResourceDefinition)
- func (x *RegisterServiceResponse) SetDiscoveredTools(v []*v1.ToolDefinition)
- func (x *RegisterServiceResponse) SetMessage(v string)
- func (x *RegisterServiceResponse) SetServiceKey(v string)
- func (x *RegisterServiceResponse) String() string
- type RegisterServiceResponse_builder
- type RegisterToolsRequest
- func (x *RegisterToolsRequest) GetNamespace() string
- func (x *RegisterToolsRequest) GetServiceName() string
- func (x *RegisterToolsRequest) GetTools() []*v1.ToolDefinition
- func (*RegisterToolsRequest) ProtoMessage()
- func (x *RegisterToolsRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterToolsRequest) Reset()
- func (x *RegisterToolsRequest) SetNamespace(v string)
- func (x *RegisterToolsRequest) SetServiceName(v string)
- func (x *RegisterToolsRequest) SetTools(v []*v1.ToolDefinition)
- func (x *RegisterToolsRequest) String() string
- type RegisterToolsRequest_builder
- type RegisterToolsResponse
- func (x *RegisterToolsResponse) GetMessage() string
- func (x *RegisterToolsResponse) GetToolsRegistered() int32
- func (*RegisterToolsResponse) ProtoMessage()
- func (x *RegisterToolsResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterToolsResponse) Reset()
- func (x *RegisterToolsResponse) SetMessage(v string)
- func (x *RegisterToolsResponse) SetToolsRegistered(v int32)
- func (x *RegisterToolsResponse) String() string
- type RegisterToolsResponse_builder
- type RegistrationServiceClient
- type RegistrationServiceServer
- type UnimplementedRegistrationServiceServer
- func (UnimplementedRegistrationServiceServer) GetServiceStatus(context.Context, *GetServiceStatusRequest) (*GetServiceStatusResponse, error)
- func (UnimplementedRegistrationServiceServer) InitiateOAuth2Flow(context.Context, *InitiateOAuth2FlowRequest) (*InitiateOAuth2FlowResponse, error)
- func (UnimplementedRegistrationServiceServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
- func (UnimplementedRegistrationServiceServer) RegisterService(context.Context, *RegisterServiceRequest) (*RegisterServiceResponse, error)
- func (UnimplementedRegistrationServiceServer) RegisterTools(context.Context, *RegisterToolsRequest) (*RegisterToolsResponse, error)
- func (UnimplementedRegistrationServiceServer) UnregisterService(context.Context, *UnregisterServiceRequest) (*UnregisterServiceResponse, error)
- type UnregisterServiceRequest
- func (x *UnregisterServiceRequest) GetNamespace() string
- func (x *UnregisterServiceRequest) GetServiceName() string
- func (*UnregisterServiceRequest) ProtoMessage()
- func (x *UnregisterServiceRequest) ProtoReflect() protoreflect.Message
- func (x *UnregisterServiceRequest) Reset()
- func (x *UnregisterServiceRequest) SetNamespace(v string)
- func (x *UnregisterServiceRequest) SetServiceName(v string)
- func (x *UnregisterServiceRequest) String() string
- type UnregisterServiceRequest_builder
- type UnregisterServiceResponse
- func (x *UnregisterServiceResponse) GetMessage() string
- func (*UnregisterServiceResponse) ProtoMessage()
- func (x *UnregisterServiceResponse) ProtoReflect() protoreflect.Message
- func (x *UnregisterServiceResponse) Reset()
- func (x *UnregisterServiceResponse) SetMessage(v string)
- func (x *UnregisterServiceResponse) String() string
- type UnregisterServiceResponse_builder
- type UnsafeRegistrationServiceServer
Constants ¶
const ( RegistrationService_RegisterService_FullMethodName = "/mcpany.api.v1.RegistrationService/RegisterService" RegistrationService_UnregisterService_FullMethodName = "/mcpany.api.v1.RegistrationService/UnregisterService" RegistrationService_InitiateOAuth2Flow_FullMethodName = "/mcpany.api.v1.RegistrationService/InitiateOAuth2Flow" RegistrationService_RegisterTools_FullMethodName = "/mcpany.api.v1.RegistrationService/RegisterTools" RegistrationService_GetServiceStatus_FullMethodName = "/mcpany.api.v1.RegistrationService/GetServiceStatus" RegistrationService_ListServices_FullMethodName = "/mcpany.api.v1.RegistrationService/ListServices" )
Variables ¶
var File_proto_api_v1_registration_proto protoreflect.FileDescriptor
var RegistrationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mcpany.api.v1.RegistrationService", HandlerType: (*RegistrationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterService", Handler: _RegistrationService_RegisterService_Handler, }, { MethodName: "UnregisterService", Handler: _RegistrationService_UnregisterService_Handler, }, { MethodName: "InitiateOAuth2Flow", Handler: _RegistrationService_InitiateOAuth2Flow_Handler, }, { MethodName: "RegisterTools", Handler: _RegistrationService_RegisterTools_Handler, }, { MethodName: "GetServiceStatus", Handler: _RegistrationService_GetServiceStatus_Handler, }, { MethodName: "ListServices", Handler: _RegistrationService_ListServices_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/api/v1/registration.proto", }
RegistrationService_ServiceDesc is the grpc.ServiceDesc for RegistrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRegistrationServiceHandler ¶
func RegisterRegistrationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterRegistrationServiceHandler registers the http handlers for service RegistrationService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterRegistrationServiceHandlerClient ¶
func RegisterRegistrationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RegistrationServiceClient) error
RegisterRegistrationServiceHandlerClient registers the http handlers for service RegistrationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RegistrationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RegistrationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RegistrationServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterRegistrationServiceHandlerFromEndpoint ¶
func RegisterRegistrationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterRegistrationServiceHandlerFromEndpoint is same as RegisterRegistrationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterRegistrationServiceHandlerServer ¶
func RegisterRegistrationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RegistrationServiceServer) error
RegisterRegistrationServiceHandlerServer registers the http handlers for service RegistrationService to "mux". UnaryRPC :call RegistrationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRegistrationServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
func RegisterRegistrationServiceServer ¶
func RegisterRegistrationServiceServer(s grpc.ServiceRegistrar, srv RegistrationServiceServer)
Types ¶
type GetServiceStatusRequest ¶
type GetServiceStatusRequest struct {
ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName" json:"service_name,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*GetServiceStatusRequest) GetNamespace ¶
func (x *GetServiceStatusRequest) GetNamespace() string
func (*GetServiceStatusRequest) GetServiceName ¶
func (x *GetServiceStatusRequest) GetServiceName() string
func (*GetServiceStatusRequest) ProtoMessage ¶
func (*GetServiceStatusRequest) ProtoMessage()
func (*GetServiceStatusRequest) ProtoReflect ¶
func (x *GetServiceStatusRequest) ProtoReflect() protoreflect.Message
func (*GetServiceStatusRequest) Reset ¶
func (x *GetServiceStatusRequest) Reset()
func (*GetServiceStatusRequest) SetNamespace ¶
func (x *GetServiceStatusRequest) SetNamespace(v string)
func (*GetServiceStatusRequest) SetServiceName ¶
func (x *GetServiceStatusRequest) SetServiceName(v string)
func (*GetServiceStatusRequest) String ¶
func (x *GetServiceStatusRequest) String() string
type GetServiceStatusRequest_builder ¶
type GetServiceStatusRequest_builder struct {
ServiceName string
Namespace string
// contains filtered or unexported fields
}
func (GetServiceStatusRequest_builder) Build ¶
func (b0 GetServiceStatusRequest_builder) Build() *GetServiceStatusRequest
type GetServiceStatusResponse ¶
type GetServiceStatusResponse struct {
Tools []*v1.ToolDefinition `protobuf:"bytes,1,rep,name=tools" json:"tools,omitempty"`
Metrics map[string]int64 `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetServiceStatusResponse) GetMetrics ¶
func (x *GetServiceStatusResponse) GetMetrics() map[string]int64
func (*GetServiceStatusResponse) GetTools ¶
func (x *GetServiceStatusResponse) GetTools() []*v1.ToolDefinition
func (*GetServiceStatusResponse) ProtoMessage ¶
func (*GetServiceStatusResponse) ProtoMessage()
func (*GetServiceStatusResponse) ProtoReflect ¶
func (x *GetServiceStatusResponse) ProtoReflect() protoreflect.Message
func (*GetServiceStatusResponse) Reset ¶
func (x *GetServiceStatusResponse) Reset()
func (*GetServiceStatusResponse) SetMetrics ¶
func (x *GetServiceStatusResponse) SetMetrics(v map[string]int64)
func (*GetServiceStatusResponse) SetTools ¶
func (x *GetServiceStatusResponse) SetTools(v []*v1.ToolDefinition)
func (*GetServiceStatusResponse) String ¶
func (x *GetServiceStatusResponse) String() string
type GetServiceStatusResponse_builder ¶
type GetServiceStatusResponse_builder struct {
Tools []*v1.ToolDefinition
Metrics map[string]int64
// contains filtered or unexported fields
}
func (GetServiceStatusResponse_builder) Build ¶
func (b0 GetServiceStatusResponse_builder) Build() *GetServiceStatusResponse
type InitiateOAuth2FlowRequest ¶
type InitiateOAuth2FlowRequest struct {
ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*InitiateOAuth2FlowRequest) GetNamespace ¶
func (x *InitiateOAuth2FlowRequest) GetNamespace() string
func (*InitiateOAuth2FlowRequest) GetServiceId ¶
func (x *InitiateOAuth2FlowRequest) GetServiceId() string
func (*InitiateOAuth2FlowRequest) ProtoMessage ¶
func (*InitiateOAuth2FlowRequest) ProtoMessage()
func (*InitiateOAuth2FlowRequest) ProtoReflect ¶
func (x *InitiateOAuth2FlowRequest) ProtoReflect() protoreflect.Message
func (*InitiateOAuth2FlowRequest) Reset ¶
func (x *InitiateOAuth2FlowRequest) Reset()
func (*InitiateOAuth2FlowRequest) SetNamespace ¶
func (x *InitiateOAuth2FlowRequest) SetNamespace(v string)
func (*InitiateOAuth2FlowRequest) SetServiceId ¶
func (x *InitiateOAuth2FlowRequest) SetServiceId(v string)
func (*InitiateOAuth2FlowRequest) String ¶
func (x *InitiateOAuth2FlowRequest) String() string
type InitiateOAuth2FlowRequest_builder ¶
type InitiateOAuth2FlowRequest_builder struct {
ServiceId string
Namespace string
// contains filtered or unexported fields
}
func (InitiateOAuth2FlowRequest_builder) Build ¶
func (b0 InitiateOAuth2FlowRequest_builder) Build() *InitiateOAuth2FlowRequest
type InitiateOAuth2FlowResponse ¶
type InitiateOAuth2FlowResponse struct {
AuthorizationUrl string `protobuf:"bytes,1,opt,name=authorization_url,json=authorizationUrl" json:"authorization_url,omitempty"`
State string `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*InitiateOAuth2FlowResponse) GetAuthorizationUrl ¶
func (x *InitiateOAuth2FlowResponse) GetAuthorizationUrl() string
func (*InitiateOAuth2FlowResponse) GetState ¶
func (x *InitiateOAuth2FlowResponse) GetState() string
func (*InitiateOAuth2FlowResponse) ProtoMessage ¶
func (*InitiateOAuth2FlowResponse) ProtoMessage()
func (*InitiateOAuth2FlowResponse) ProtoReflect ¶
func (x *InitiateOAuth2FlowResponse) ProtoReflect() protoreflect.Message
func (*InitiateOAuth2FlowResponse) Reset ¶
func (x *InitiateOAuth2FlowResponse) Reset()
func (*InitiateOAuth2FlowResponse) SetAuthorizationUrl ¶
func (x *InitiateOAuth2FlowResponse) SetAuthorizationUrl(v string)
func (*InitiateOAuth2FlowResponse) SetState ¶
func (x *InitiateOAuth2FlowResponse) SetState(v string)
func (*InitiateOAuth2FlowResponse) String ¶
func (x *InitiateOAuth2FlowResponse) String() string
type InitiateOAuth2FlowResponse_builder ¶
type InitiateOAuth2FlowResponse_builder struct {
AuthorizationUrl string
State string
// contains filtered or unexported fields
}
func (InitiateOAuth2FlowResponse_builder) Build ¶
func (b0 InitiateOAuth2FlowResponse_builder) Build() *InitiateOAuth2FlowResponse
type ListServicesRequest ¶
type ListServicesRequest struct {
// contains filtered or unexported fields
}
func (*ListServicesRequest) ProtoMessage ¶
func (*ListServicesRequest) ProtoMessage()
func (*ListServicesRequest) ProtoReflect ¶
func (x *ListServicesRequest) ProtoReflect() protoreflect.Message
func (*ListServicesRequest) Reset ¶
func (x *ListServicesRequest) Reset()
func (*ListServicesRequest) String ¶
func (x *ListServicesRequest) String() string
type ListServicesRequest_builder ¶
type ListServicesRequest_builder struct {
// contains filtered or unexported fields
}
func (ListServicesRequest_builder) Build ¶
func (b0 ListServicesRequest_builder) Build() *ListServicesRequest
type ListServicesResponse ¶
type ListServicesResponse struct {
Services []*v1.UpstreamServiceConfig `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`
// contains filtered or unexported fields
}
func (*ListServicesResponse) GetServices ¶
func (x *ListServicesResponse) GetServices() []*v1.UpstreamServiceConfig
func (*ListServicesResponse) ProtoMessage ¶
func (*ListServicesResponse) ProtoMessage()
func (*ListServicesResponse) ProtoReflect ¶
func (x *ListServicesResponse) ProtoReflect() protoreflect.Message
func (*ListServicesResponse) Reset ¶
func (x *ListServicesResponse) Reset()
func (*ListServicesResponse) SetServices ¶
func (x *ListServicesResponse) SetServices(v []*v1.UpstreamServiceConfig)
func (*ListServicesResponse) String ¶
func (x *ListServicesResponse) String() string
type ListServicesResponse_builder ¶
type ListServicesResponse_builder struct {
Services []*v1.UpstreamServiceConfig
// contains filtered or unexported fields
}
func (ListServicesResponse_builder) Build ¶
func (b0 ListServicesResponse_builder) Build() *ListServicesResponse
type RegisterServiceRequest ¶
type RegisterServiceRequest struct {
Config *v1.UpstreamServiceConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterServiceRequest) ClearConfig ¶
func (x *RegisterServiceRequest) ClearConfig()
func (*RegisterServiceRequest) GetConfig ¶
func (x *RegisterServiceRequest) GetConfig() *v1.UpstreamServiceConfig
func (*RegisterServiceRequest) HasConfig ¶
func (x *RegisterServiceRequest) HasConfig() bool
func (*RegisterServiceRequest) ProtoMessage ¶
func (*RegisterServiceRequest) ProtoMessage()
func (*RegisterServiceRequest) ProtoReflect ¶
func (x *RegisterServiceRequest) ProtoReflect() protoreflect.Message
func (*RegisterServiceRequest) Reset ¶
func (x *RegisterServiceRequest) Reset()
func (*RegisterServiceRequest) SetConfig ¶
func (x *RegisterServiceRequest) SetConfig(v *v1.UpstreamServiceConfig)
func (*RegisterServiceRequest) String ¶
func (x *RegisterServiceRequest) String() string
type RegisterServiceRequest_builder ¶
type RegisterServiceRequest_builder struct {
Config *v1.UpstreamServiceConfig
// contains filtered or unexported fields
}
func (RegisterServiceRequest_builder) Build ¶
func (b0 RegisterServiceRequest_builder) Build() *RegisterServiceRequest
type RegisterServiceResponse ¶
type RegisterServiceResponse struct {
Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"` // e.g., "Service registered successfully"
DiscoveredTools []*v1.ToolDefinition `protobuf:"bytes,2,rep,name=discovered_tools,json=discoveredTools" json:"discovered_tools,omitempty"`
ServiceKey string `protobuf:"bytes,3,opt,name=service_key,json=serviceKey" json:"service_key,omitempty"` // The generated key for the service
DiscoveredResources []*v1.ResourceDefinition `protobuf:"bytes,4,rep,name=discovered_resources,json=discoveredResources" json:"discovered_resources,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterServiceResponse) GetDiscoveredResources ¶
func (x *RegisterServiceResponse) GetDiscoveredResources() []*v1.ResourceDefinition
func (*RegisterServiceResponse) GetDiscoveredTools ¶
func (x *RegisterServiceResponse) GetDiscoveredTools() []*v1.ToolDefinition
func (*RegisterServiceResponse) GetMessage ¶
func (x *RegisterServiceResponse) GetMessage() string
func (*RegisterServiceResponse) GetServiceKey ¶
func (x *RegisterServiceResponse) GetServiceKey() string
func (*RegisterServiceResponse) ProtoMessage ¶
func (*RegisterServiceResponse) ProtoMessage()
func (*RegisterServiceResponse) ProtoReflect ¶
func (x *RegisterServiceResponse) ProtoReflect() protoreflect.Message
func (*RegisterServiceResponse) Reset ¶
func (x *RegisterServiceResponse) Reset()
func (*RegisterServiceResponse) SetDiscoveredResources ¶
func (x *RegisterServiceResponse) SetDiscoveredResources(v []*v1.ResourceDefinition)
func (*RegisterServiceResponse) SetDiscoveredTools ¶
func (x *RegisterServiceResponse) SetDiscoveredTools(v []*v1.ToolDefinition)
func (*RegisterServiceResponse) SetMessage ¶
func (x *RegisterServiceResponse) SetMessage(v string)
func (*RegisterServiceResponse) SetServiceKey ¶
func (x *RegisterServiceResponse) SetServiceKey(v string)
func (*RegisterServiceResponse) String ¶
func (x *RegisterServiceResponse) String() string
type RegisterServiceResponse_builder ¶
type RegisterServiceResponse_builder struct {
Message string
DiscoveredTools []*v1.ToolDefinition
ServiceKey string
DiscoveredResources []*v1.ResourceDefinition
// contains filtered or unexported fields
}
func (RegisterServiceResponse_builder) Build ¶
func (b0 RegisterServiceResponse_builder) Build() *RegisterServiceResponse
type RegisterToolsRequest ¶
type RegisterToolsRequest struct {
ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName" json:"service_name,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
Tools []*v1.ToolDefinition `protobuf:"bytes,3,rep,name=tools" json:"tools,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterToolsRequest) GetNamespace ¶
func (x *RegisterToolsRequest) GetNamespace() string
func (*RegisterToolsRequest) GetServiceName ¶
func (x *RegisterToolsRequest) GetServiceName() string
func (*RegisterToolsRequest) GetTools ¶
func (x *RegisterToolsRequest) GetTools() []*v1.ToolDefinition
func (*RegisterToolsRequest) ProtoMessage ¶
func (*RegisterToolsRequest) ProtoMessage()
func (*RegisterToolsRequest) ProtoReflect ¶
func (x *RegisterToolsRequest) ProtoReflect() protoreflect.Message
func (*RegisterToolsRequest) Reset ¶
func (x *RegisterToolsRequest) Reset()
func (*RegisterToolsRequest) SetNamespace ¶
func (x *RegisterToolsRequest) SetNamespace(v string)
func (*RegisterToolsRequest) SetServiceName ¶
func (x *RegisterToolsRequest) SetServiceName(v string)
func (*RegisterToolsRequest) SetTools ¶
func (x *RegisterToolsRequest) SetTools(v []*v1.ToolDefinition)
func (*RegisterToolsRequest) String ¶
func (x *RegisterToolsRequest) String() string
type RegisterToolsRequest_builder ¶
type RegisterToolsRequest_builder struct {
ServiceName string
Namespace string
Tools []*v1.ToolDefinition
// contains filtered or unexported fields
}
func (RegisterToolsRequest_builder) Build ¶
func (b0 RegisterToolsRequest_builder) Build() *RegisterToolsRequest
type RegisterToolsResponse ¶
type RegisterToolsResponse struct {
Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
ToolsRegistered int32 `protobuf:"varint,2,opt,name=tools_registered,json=toolsRegistered" json:"tools_registered,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterToolsResponse) GetMessage ¶
func (x *RegisterToolsResponse) GetMessage() string
func (*RegisterToolsResponse) GetToolsRegistered ¶
func (x *RegisterToolsResponse) GetToolsRegistered() int32
func (*RegisterToolsResponse) ProtoMessage ¶
func (*RegisterToolsResponse) ProtoMessage()
func (*RegisterToolsResponse) ProtoReflect ¶
func (x *RegisterToolsResponse) ProtoReflect() protoreflect.Message
func (*RegisterToolsResponse) Reset ¶
func (x *RegisterToolsResponse) Reset()
func (*RegisterToolsResponse) SetMessage ¶
func (x *RegisterToolsResponse) SetMessage(v string)
func (*RegisterToolsResponse) SetToolsRegistered ¶
func (x *RegisterToolsResponse) SetToolsRegistered(v int32)
func (*RegisterToolsResponse) String ¶
func (x *RegisterToolsResponse) String() string
type RegisterToolsResponse_builder ¶
type RegisterToolsResponse_builder struct {
Message string
ToolsRegistered int32
// contains filtered or unexported fields
}
func (RegisterToolsResponse_builder) Build ¶
func (b0 RegisterToolsResponse_builder) Build() *RegisterToolsResponse
type RegistrationServiceClient ¶
type RegistrationServiceClient interface {
RegisterService(ctx context.Context, in *RegisterServiceRequest, opts ...grpc.CallOption) (*RegisterServiceResponse, error)
UnregisterService(ctx context.Context, in *UnregisterServiceRequest, opts ...grpc.CallOption) (*UnregisterServiceResponse, error)
InitiateOAuth2Flow(ctx context.Context, in *InitiateOAuth2FlowRequest, opts ...grpc.CallOption) (*InitiateOAuth2FlowResponse, error)
RegisterTools(ctx context.Context, in *RegisterToolsRequest, opts ...grpc.CallOption) (*RegisterToolsResponse, error)
GetServiceStatus(ctx context.Context, in *GetServiceStatusRequest, opts ...grpc.CallOption) (*GetServiceStatusResponse, error)
ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
}
RegistrationServiceClient is the client API for RegistrationService 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 NewRegistrationServiceClient ¶
func NewRegistrationServiceClient(cc grpc.ClientConnInterface) RegistrationServiceClient
type RegistrationServiceServer ¶
type RegistrationServiceServer interface {
RegisterService(context.Context, *RegisterServiceRequest) (*RegisterServiceResponse, error)
UnregisterService(context.Context, *UnregisterServiceRequest) (*UnregisterServiceResponse, error)
InitiateOAuth2Flow(context.Context, *InitiateOAuth2FlowRequest) (*InitiateOAuth2FlowResponse, error)
RegisterTools(context.Context, *RegisterToolsRequest) (*RegisterToolsResponse, error)
GetServiceStatus(context.Context, *GetServiceStatusRequest) (*GetServiceStatusResponse, error)
ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
// contains filtered or unexported methods
}
RegistrationServiceServer is the server API for RegistrationService service. All implementations must embed UnimplementedRegistrationServiceServer for forward compatibility.
type UnimplementedRegistrationServiceServer ¶
type UnimplementedRegistrationServiceServer struct{}
UnimplementedRegistrationServiceServer 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 (UnimplementedRegistrationServiceServer) GetServiceStatus ¶
func (UnimplementedRegistrationServiceServer) GetServiceStatus(context.Context, *GetServiceStatusRequest) (*GetServiceStatusResponse, error)
func (UnimplementedRegistrationServiceServer) InitiateOAuth2Flow ¶
func (UnimplementedRegistrationServiceServer) InitiateOAuth2Flow(context.Context, *InitiateOAuth2FlowRequest) (*InitiateOAuth2FlowResponse, error)
func (UnimplementedRegistrationServiceServer) ListServices ¶
func (UnimplementedRegistrationServiceServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
func (UnimplementedRegistrationServiceServer) RegisterService ¶
func (UnimplementedRegistrationServiceServer) RegisterService(context.Context, *RegisterServiceRequest) (*RegisterServiceResponse, error)
func (UnimplementedRegistrationServiceServer) RegisterTools ¶
func (UnimplementedRegistrationServiceServer) RegisterTools(context.Context, *RegisterToolsRequest) (*RegisterToolsResponse, error)
func (UnimplementedRegistrationServiceServer) UnregisterService ¶
func (UnimplementedRegistrationServiceServer) UnregisterService(context.Context, *UnregisterServiceRequest) (*UnregisterServiceResponse, error)
type UnregisterServiceRequest ¶
type UnregisterServiceRequest struct {
ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName" json:"service_name,omitempty"` // User-defined unique ID for the service to deregister
Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"` // Optional namespace for the service
// contains filtered or unexported fields
}
func (*UnregisterServiceRequest) GetNamespace ¶
func (x *UnregisterServiceRequest) GetNamespace() string
func (*UnregisterServiceRequest) GetServiceName ¶
func (x *UnregisterServiceRequest) GetServiceName() string
func (*UnregisterServiceRequest) ProtoMessage ¶
func (*UnregisterServiceRequest) ProtoMessage()
func (*UnregisterServiceRequest) ProtoReflect ¶
func (x *UnregisterServiceRequest) ProtoReflect() protoreflect.Message
func (*UnregisterServiceRequest) Reset ¶
func (x *UnregisterServiceRequest) Reset()
func (*UnregisterServiceRequest) SetNamespace ¶
func (x *UnregisterServiceRequest) SetNamespace(v string)
func (*UnregisterServiceRequest) SetServiceName ¶
func (x *UnregisterServiceRequest) SetServiceName(v string)
func (*UnregisterServiceRequest) String ¶
func (x *UnregisterServiceRequest) String() string
type UnregisterServiceRequest_builder ¶
type UnregisterServiceRequest_builder struct {
ServiceName string
Namespace string
// contains filtered or unexported fields
}
func (UnregisterServiceRequest_builder) Build ¶
func (b0 UnregisterServiceRequest_builder) Build() *UnregisterServiceRequest
type UnregisterServiceResponse ¶
type UnregisterServiceResponse struct {
Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"` // e.g., "Service unregistered successfully"
// contains filtered or unexported fields
}
func (*UnregisterServiceResponse) GetMessage ¶
func (x *UnregisterServiceResponse) GetMessage() string
func (*UnregisterServiceResponse) ProtoMessage ¶
func (*UnregisterServiceResponse) ProtoMessage()
func (*UnregisterServiceResponse) ProtoReflect ¶
func (x *UnregisterServiceResponse) ProtoReflect() protoreflect.Message
func (*UnregisterServiceResponse) Reset ¶
func (x *UnregisterServiceResponse) Reset()
func (*UnregisterServiceResponse) SetMessage ¶
func (x *UnregisterServiceResponse) SetMessage(v string)
func (*UnregisterServiceResponse) String ¶
func (x *UnregisterServiceResponse) String() string
type UnregisterServiceResponse_builder ¶
type UnregisterServiceResponse_builder struct {
Message string
// contains filtered or unexported fields
}
func (UnregisterServiceResponse_builder) Build ¶
func (b0 UnregisterServiceResponse_builder) Build() *UnregisterServiceResponse
type UnsafeRegistrationServiceServer ¶
type UnsafeRegistrationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRegistrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RegistrationServiceServer will result in compilation errors.