Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)
- func RegisterSupervisorServer(s grpc.ServiceRegistrar, srv SupervisorServer)
- type PluginClient
- type PluginEndpoint
- func (*PluginEndpoint) Descriptor() ([]byte, []int)deprecated
- func (x *PluginEndpoint) GetAccessToken() string
- func (x *PluginEndpoint) GetEndpoint() string
- func (x *PluginEndpoint) GetUpdatedVersion() string
- func (*PluginEndpoint) ProtoMessage()
- func (x *PluginEndpoint) ProtoReflect() protoreflect.Message
- func (x *PluginEndpoint) Reset()
- func (x *PluginEndpoint) String() string
- type PluginEndpointRequest
- func (*PluginEndpointRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PluginEndpointRequest) GetDomainId() string
- func (x *PluginEndpointRequest) GetLabels() *_struct.Struct
- func (x *PluginEndpointRequest) GetPluginId() string
- func (x *PluginEndpointRequest) GetUpgradeMode() PluginEndpointRequest_UpgradeMode
- func (x *PluginEndpointRequest) GetVersion() string
- func (*PluginEndpointRequest) ProtoMessage()
- func (x *PluginEndpointRequest) ProtoReflect() protoreflect.Message
- func (x *PluginEndpointRequest) Reset()
- func (x *PluginEndpointRequest) String() string
- type PluginEndpointRequest_UpgradeMode
- func (PluginEndpointRequest_UpgradeMode) Descriptor() protoreflect.EnumDescriptor
- func (x PluginEndpointRequest_UpgradeMode) Enum() *PluginEndpointRequest_UpgradeMode
- func (PluginEndpointRequest_UpgradeMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginEndpointRequest_UpgradeMode) Number() protoreflect.EnumNumber
- func (x PluginEndpointRequest_UpgradeMode) String() string
- func (PluginEndpointRequest_UpgradeMode) Type() protoreflect.EnumType
- type PluginFailureRequest
- func (*PluginFailureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PluginFailureRequest) GetDomainId() string
- func (x *PluginFailureRequest) GetPluginId() string
- func (x *PluginFailureRequest) GetSupervisorId() string
- func (x *PluginFailureRequest) GetVersion() string
- func (*PluginFailureRequest) ProtoMessage()
- func (x *PluginFailureRequest) ProtoReflect() protoreflect.Message
- func (x *PluginFailureRequest) Reset()
- func (x *PluginFailureRequest) String() string
- type PluginInfo
- func (*PluginInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PluginInfo) GetDomainId() string
- func (x *PluginInfo) GetEndpoint() string
- func (x *PluginInfo) GetEndpoints() []string
- func (x *PluginInfo) GetManaged() bool
- func (x *PluginInfo) GetPluginId() string
- func (x *PluginInfo) GetState() PluginInfo_State
- func (x *PluginInfo) GetSupervisorId() string
- func (x *PluginInfo) GetSupervisorName() string
- func (x *PluginInfo) GetVersion() string
- func (*PluginInfo) ProtoMessage()
- func (x *PluginInfo) ProtoReflect() protoreflect.Message
- func (x *PluginInfo) Reset()
- func (x *PluginInfo) String() string
- type PluginInfo_State
- func (PluginInfo_State) Descriptor() protoreflect.EnumDescriptor
- func (x PluginInfo_State) Enum() *PluginInfo_State
- func (PluginInfo_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginInfo_State) Number() protoreflect.EnumNumber
- func (x PluginInfo_State) String() string
- func (PluginInfo_State) Type() protoreflect.EnumType
- type PluginMetadata
- type PluginMetadataRequest
- func (*PluginMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PluginMetadataRequest) GetOptions() *_struct.Struct
- func (x *PluginMetadataRequest) GetPluginId() string
- func (x *PluginMetadataRequest) GetUpgradeMode() PluginMetadataRequest_UpgradeMode
- func (x *PluginMetadataRequest) GetVersion() string
- func (*PluginMetadataRequest) ProtoMessage()
- func (x *PluginMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *PluginMetadataRequest) Reset()
- func (x *PluginMetadataRequest) String() string
- type PluginMetadataRequest_UpgradeMode
- func (PluginMetadataRequest_UpgradeMode) Descriptor() protoreflect.EnumDescriptor
- func (x PluginMetadataRequest_UpgradeMode) Enum() *PluginMetadataRequest_UpgradeMode
- func (PluginMetadataRequest_UpgradeMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginMetadataRequest_UpgradeMode) Number() protoreflect.EnumNumber
- func (x PluginMetadataRequest_UpgradeMode) String() string
- func (PluginMetadataRequest_UpgradeMode) Type() protoreflect.EnumType
- type PluginQuery
- func (*PluginQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PluginQuery) GetDomainId() string
- func (x *PluginQuery) GetEndpoint() string
- func (x *PluginQuery) GetHostname() string
- func (x *PluginQuery) GetPluginId() string
- func (x *PluginQuery) GetQuery() *v2.Query
- func (x *PluginQuery) GetState() PluginQuery_State
- func (x *PluginQuery) GetSupervisorId() string
- func (x *PluginQuery) GetVersion() string
- func (*PluginQuery) ProtoMessage()
- func (x *PluginQuery) ProtoReflect() protoreflect.Message
- func (x *PluginQuery) Reset()
- func (x *PluginQuery) String() string
- type PluginQuery_State
- func (PluginQuery_State) Descriptor() protoreflect.EnumDescriptor
- func (x PluginQuery_State) Enum() *PluginQuery_State
- func (PluginQuery_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginQuery_State) Number() protoreflect.EnumNumber
- func (x PluginQuery_State) String() string
- func (PluginQuery_State) Type() protoreflect.EnumType
- type PluginServer
- type PluginsInfo
- func (*PluginsInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PluginsInfo) GetResults() []*PluginInfo
- func (x *PluginsInfo) GetTotalCount() int32
- func (*PluginsInfo) ProtoMessage()
- func (x *PluginsInfo) ProtoReflect() protoreflect.Message
- func (x *PluginsInfo) Reset()
- func (x *PluginsInfo) String() string
- type PublishSupervisorRequest
- func (*PublishSupervisorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishSupervisorRequest) GetDomainId() string
- func (x *PublishSupervisorRequest) GetHostname() string
- func (x *PublishSupervisorRequest) GetIsPublic() bool
- func (x *PublishSupervisorRequest) GetLabels() *_struct.ListValue
- func (x *PublishSupervisorRequest) GetName() string
- func (x *PublishSupervisorRequest) GetPluginInfo() []*PluginInfo
- func (x *PublishSupervisorRequest) GetSecretKey() string
- func (x *PublishSupervisorRequest) GetTags() *_struct.Struct
- func (*PublishSupervisorRequest) ProtoMessage()
- func (x *PublishSupervisorRequest) ProtoReflect() protoreflect.Message
- func (x *PublishSupervisorRequest) Reset()
- func (x *PublishSupervisorRequest) String() string
- type RecoverPluginRequest
- func (*RecoverPluginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RecoverPluginRequest) GetDomainId() string
- func (x *RecoverPluginRequest) GetPluginId() string
- func (x *RecoverPluginRequest) GetSupervisorId() string
- func (x *RecoverPluginRequest) GetVersion() string
- func (*RecoverPluginRequest) ProtoMessage()
- func (x *RecoverPluginRequest) ProtoReflect() protoreflect.Message
- func (x *RecoverPluginRequest) Reset()
- func (x *RecoverPluginRequest) String() string
- type RegisterSupervisorRequest
- func (*RegisterSupervisorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSupervisorRequest) GetDomainId() string
- func (x *RegisterSupervisorRequest) GetIsPublic() bool
- func (x *RegisterSupervisorRequest) GetLabels() *_struct.Struct
- func (x *RegisterSupervisorRequest) GetName() string
- func (x *RegisterSupervisorRequest) GetPriority() int32
- func (x *RegisterSupervisorRequest) GetSupervisorId() string
- func (x *RegisterSupervisorRequest) GetTags() *_struct.Struct
- func (*RegisterSupervisorRequest) ProtoMessage()
- func (x *RegisterSupervisorRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterSupervisorRequest) Reset()
- func (x *RegisterSupervisorRequest) String() string
- type SupervisorClient
- type SupervisorInfo
- func (*SupervisorInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SupervisorInfo) GetCreatedAt() string
- func (x *SupervisorInfo) GetDomainId() string
- func (x *SupervisorInfo) GetHostname() string
- func (x *SupervisorInfo) GetIsPublic() bool
- func (x *SupervisorInfo) GetLabels() *_struct.Struct
- func (x *SupervisorInfo) GetName() string
- func (x *SupervisorInfo) GetState() SupervisorInfo_State
- func (x *SupervisorInfo) GetSupervisorId() string
- func (x *SupervisorInfo) GetTags() *_struct.Struct
- func (x *SupervisorInfo) GetUpdatedAt() string
- func (*SupervisorInfo) ProtoMessage()
- func (x *SupervisorInfo) ProtoReflect() protoreflect.Message
- func (x *SupervisorInfo) Reset()
- func (x *SupervisorInfo) String() string
- type SupervisorInfo_State
- func (SupervisorInfo_State) Descriptor() protoreflect.EnumDescriptor
- func (x SupervisorInfo_State) Enum() *SupervisorInfo_State
- func (SupervisorInfo_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x SupervisorInfo_State) Number() protoreflect.EnumNumber
- func (x SupervisorInfo_State) String() string
- func (SupervisorInfo_State) Type() protoreflect.EnumType
- type SupervisorQuery
- func (*SupervisorQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SupervisorQuery) GetDomainId() string
- func (x *SupervisorQuery) GetIsPublic() bool
- func (x *SupervisorQuery) GetName() string
- func (x *SupervisorQuery) GetQuery() *v2.Query
- func (x *SupervisorQuery) GetSupervisorId() string
- func (*SupervisorQuery) ProtoMessage()
- func (x *SupervisorQuery) ProtoReflect() protoreflect.Message
- func (x *SupervisorQuery) Reset()
- func (x *SupervisorQuery) String() string
- type SupervisorRequest
- func (*SupervisorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SupervisorRequest) GetDomainId() string
- func (x *SupervisorRequest) GetSupervisorId() string
- func (*SupervisorRequest) ProtoMessage()
- func (x *SupervisorRequest) ProtoReflect() protoreflect.Message
- func (x *SupervisorRequest) Reset()
- func (x *SupervisorRequest) String() string
- type SupervisorServer
- type SupervisorStatQuery
- func (*SupervisorStatQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SupervisorStatQuery) GetDomainId() string
- func (x *SupervisorStatQuery) GetQuery() *v2.StatisticsQuery
- func (*SupervisorStatQuery) ProtoMessage()
- func (x *SupervisorStatQuery) ProtoReflect() protoreflect.Message
- func (x *SupervisorStatQuery) Reset()
- func (x *SupervisorStatQuery) String() string
- type SupervisorsInfo
- func (*SupervisorsInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SupervisorsInfo) GetResults() []*SupervisorInfo
- func (x *SupervisorsInfo) GetTotalCount() int32
- func (*SupervisorsInfo) ProtoMessage()
- func (x *SupervisorsInfo) ProtoReflect() protoreflect.Message
- func (x *SupervisorsInfo) Reset()
- func (x *SupervisorsInfo) String() string
- type UnimplementedPluginServer
- func (UnimplementedPluginServer) GetPluginEndpoint(context.Context, *PluginEndpointRequest) (*PluginEndpoint, error)
- func (UnimplementedPluginServer) GetPluginMetadata(context.Context, *PluginMetadataRequest) (*PluginMetadata, error)
- func (UnimplementedPluginServer) NotifyFailure(context.Context, *PluginFailureRequest) (*empty.Empty, error)
- type UnimplementedSupervisorServer
- func (UnimplementedSupervisorServer) Deregister(context.Context, *SupervisorRequest) (*empty.Empty, error)
- func (UnimplementedSupervisorServer) Disable(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
- func (UnimplementedSupervisorServer) Enable(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
- func (UnimplementedSupervisorServer) Get(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
- func (UnimplementedSupervisorServer) List(context.Context, *SupervisorQuery) (*SupervisorsInfo, error)
- func (UnimplementedSupervisorServer) ListPlugins(context.Context, *PluginQuery) (*PluginsInfo, error)
- func (UnimplementedSupervisorServer) Publish(context.Context, *PublishSupervisorRequest) (*SupervisorInfo, error)
- func (UnimplementedSupervisorServer) RecoverPlugin(context.Context, *RecoverPluginRequest) (*PluginInfo, error)
- func (UnimplementedSupervisorServer) Register(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error)
- func (UnimplementedSupervisorServer) Stat(context.Context, *SupervisorStatQuery) (*_struct.Struct, error)
- func (UnimplementedSupervisorServer) Update(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error)
- type UnsafePluginServer
- type UnsafeSupervisorServer
Constants ¶
const ( Plugin_GetPluginEndpoint_FullMethodName = "/spaceone.api.plugin.v1.Plugin/get_plugin_endpoint" Plugin_GetPluginMetadata_FullMethodName = "/spaceone.api.plugin.v1.Plugin/get_plugin_metadata" Plugin_NotifyFailure_FullMethodName = "/spaceone.api.plugin.v1.Plugin/notify_failure" )
const ( Supervisor_Publish_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/publish" Supervisor_Register_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/register" Supervisor_Update_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/update" Supervisor_Deregister_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/deregister" Supervisor_Enable_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/enable" Supervisor_Disable_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/disable" Supervisor_RecoverPlugin_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/recover_plugin" Supervisor_Get_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/get" Supervisor_List_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/list" Supervisor_Stat_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/stat" Supervisor_ListPlugins_FullMethodName = "/spaceone.api.plugin.v1.Supervisor/list_plugins" )
Variables ¶
var ( PluginEndpointRequest_UpgradeMode_name = map[int32]string{ 0: "MANUAL", 1: "AUTO", } PluginEndpointRequest_UpgradeMode_value = map[string]int32{ "MANUAL": 0, "AUTO": 1, } )
Enum value maps for PluginEndpointRequest_UpgradeMode.
var ( PluginMetadataRequest_UpgradeMode_name = map[int32]string{ 0: "MANUAL", 1: "AUTO", } PluginMetadataRequest_UpgradeMode_value = map[string]int32{ "MANUAL": 0, "AUTO": 1, } )
Enum value maps for PluginMetadataRequest_UpgradeMode.
var ( SupervisorInfo_State_name = map[int32]string{ 0: "NONE", 1: "ENABLED", 2: "DISABLED", 3: "PENDING", 4: "DISCONNECTED", } SupervisorInfo_State_value = map[string]int32{ "NONE": 0, "ENABLED": 1, "DISABLED": 2, "PENDING": 3, "DISCONNECTED": 4, } )
Enum value maps for SupervisorInfo_State.
var ( PluginQuery_State_name = map[int32]string{ 0: "NONE", 1: "PROVISIONING", 2: "ACTIVE", 3: "RE_PROVISIONING", 4: "ERROR", } PluginQuery_State_value = map[string]int32{ "NONE": 0, "PROVISIONING": 1, "ACTIVE": 2, "RE_PROVISIONING": 3, "ERROR": 4, } )
Enum value maps for PluginQuery_State.
var ( PluginInfo_State_name = map[int32]string{ 0: "NONE", 1: "PROVISIONING", 2: "ACTIVE", 3: "RE_PROVISIONING", 4: "ERROR", } PluginInfo_State_value = map[string]int32{ "NONE": 0, "PROVISIONING": 1, "ACTIVE": 2, "RE_PROVISIONING": 3, "ERROR": 4, } )
Enum value maps for PluginInfo_State.
var File_spaceone_api_plugin_v1_plugin_proto protoreflect.FileDescriptor
var File_spaceone_api_plugin_v1_supervisor_proto protoreflect.FileDescriptor
var Plugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "spaceone.api.plugin.v1.Plugin", HandlerType: (*PluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "get_plugin_endpoint", Handler: _Plugin_GetPluginEndpoint_Handler, }, { MethodName: "get_plugin_metadata", Handler: _Plugin_GetPluginMetadata_Handler, }, { MethodName: "notify_failure", Handler: _Plugin_NotifyFailure_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "spaceone/api/plugin/v1/plugin.proto", }
Plugin_ServiceDesc is the grpc.ServiceDesc for Plugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Supervisor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "spaceone.api.plugin.v1.Supervisor", HandlerType: (*SupervisorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "publish", Handler: _Supervisor_Publish_Handler, }, { MethodName: "register", Handler: _Supervisor_Register_Handler, }, { MethodName: "update", Handler: _Supervisor_Update_Handler, }, { MethodName: "deregister", Handler: _Supervisor_Deregister_Handler, }, { MethodName: "enable", Handler: _Supervisor_Enable_Handler, }, { MethodName: "disable", Handler: _Supervisor_Disable_Handler, }, { MethodName: "recover_plugin", Handler: _Supervisor_RecoverPlugin_Handler, }, { MethodName: "get", Handler: _Supervisor_Get_Handler, }, { MethodName: "list", Handler: _Supervisor_List_Handler, }, { MethodName: "stat", Handler: _Supervisor_Stat_Handler, }, { MethodName: "list_plugins", Handler: _Supervisor_ListPlugins_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "spaceone/api/plugin/v1/supervisor.proto", }
Supervisor_ServiceDesc is the grpc.ServiceDesc for Supervisor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPluginServer ¶
func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)
func RegisterSupervisorServer ¶
func RegisterSupervisorServer(s grpc.ServiceRegistrar, srv SupervisorServer)
Types ¶
type PluginClient ¶
type PluginClient interface { // Gets the `endpoint` of a specific plugin instance. A Plugin returns only a single `endpoint` by determining `labels` and `priority`. If the requested plugin instance is already deployed, the `endpoint` is returned. If not, the `endpoint` is returned after deploying the plugin instance. GetPluginEndpoint(ctx context.Context, in *PluginEndpointRequest, opts ...grpc.CallOption) (*PluginEndpoint, error) GetPluginMetadata(ctx context.Context, in *PluginMetadataRequest, opts ...grpc.CallOption) (*PluginMetadata, error) NotifyFailure(ctx context.Context, in *PluginFailureRequest, opts ...grpc.CallOption) (*empty.Empty, error) }
PluginClient is the client API for Plugin 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 NewPluginClient ¶
func NewPluginClient(cc grpc.ClientConnInterface) PluginClient
type PluginEndpoint ¶
type PluginEndpoint struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` AccessToken string `protobuf:"bytes,2,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` // +optional UpdatedVersion string `protobuf:"bytes,3,opt,name=updated_version,json=updatedVersion,proto3" json:"updated_version,omitempty"` // contains filtered or unexported fields }
{ "endpoint": "grpc://endpoint-url:50051" }
func (*PluginEndpoint) Descriptor
deprecated
func (*PluginEndpoint) Descriptor() ([]byte, []int)
Deprecated: Use PluginEndpoint.ProtoReflect.Descriptor instead.
func (*PluginEndpoint) GetAccessToken ¶
func (x *PluginEndpoint) GetAccessToken() string
func (*PluginEndpoint) GetEndpoint ¶
func (x *PluginEndpoint) GetEndpoint() string
func (*PluginEndpoint) GetUpdatedVersion ¶
func (x *PluginEndpoint) GetUpdatedVersion() string
func (*PluginEndpoint) ProtoMessage ¶
func (*PluginEndpoint) ProtoMessage()
func (*PluginEndpoint) ProtoReflect ¶
func (x *PluginEndpoint) ProtoReflect() protoreflect.Message
func (*PluginEndpoint) Reset ¶
func (x *PluginEndpoint) Reset()
func (*PluginEndpoint) String ¶
func (x *PluginEndpoint) String() string
type PluginEndpointRequest ¶
type PluginEndpointRequest struct { PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` // +optional Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // +optional UpgradeMode PluginEndpointRequest_UpgradeMode `` /* 157-byte string literal not displayed */ // +optional Labels *_struct.Struct `protobuf:"bytes,4,opt,name=labels,proto3" json:"labels,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "plugin_id": "plugin-aws-sns-mon-webhook", "version": "1.2.2" }
func (*PluginEndpointRequest) Descriptor
deprecated
func (*PluginEndpointRequest) Descriptor() ([]byte, []int)
Deprecated: Use PluginEndpointRequest.ProtoReflect.Descriptor instead.
func (*PluginEndpointRequest) GetDomainId ¶
func (x *PluginEndpointRequest) GetDomainId() string
func (*PluginEndpointRequest) GetLabels ¶
func (x *PluginEndpointRequest) GetLabels() *_struct.Struct
func (*PluginEndpointRequest) GetPluginId ¶
func (x *PluginEndpointRequest) GetPluginId() string
func (*PluginEndpointRequest) GetUpgradeMode ¶
func (x *PluginEndpointRequest) GetUpgradeMode() PluginEndpointRequest_UpgradeMode
func (*PluginEndpointRequest) GetVersion ¶
func (x *PluginEndpointRequest) GetVersion() string
func (*PluginEndpointRequest) ProtoMessage ¶
func (*PluginEndpointRequest) ProtoMessage()
func (*PluginEndpointRequest) ProtoReflect ¶
func (x *PluginEndpointRequest) ProtoReflect() protoreflect.Message
func (*PluginEndpointRequest) Reset ¶
func (x *PluginEndpointRequest) Reset()
func (*PluginEndpointRequest) String ¶
func (x *PluginEndpointRequest) String() string
type PluginEndpointRequest_UpgradeMode ¶
type PluginEndpointRequest_UpgradeMode int32
const ( PluginEndpointRequest_MANUAL PluginEndpointRequest_UpgradeMode = 0 PluginEndpointRequest_AUTO PluginEndpointRequest_UpgradeMode = 1 )
func (PluginEndpointRequest_UpgradeMode) Descriptor ¶
func (PluginEndpointRequest_UpgradeMode) Descriptor() protoreflect.EnumDescriptor
func (PluginEndpointRequest_UpgradeMode) Enum ¶
func (x PluginEndpointRequest_UpgradeMode) Enum() *PluginEndpointRequest_UpgradeMode
func (PluginEndpointRequest_UpgradeMode) EnumDescriptor
deprecated
func (PluginEndpointRequest_UpgradeMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginEndpointRequest_UpgradeMode.Descriptor instead.
func (PluginEndpointRequest_UpgradeMode) Number ¶
func (x PluginEndpointRequest_UpgradeMode) Number() protoreflect.EnumNumber
func (PluginEndpointRequest_UpgradeMode) String ¶
func (x PluginEndpointRequest_UpgradeMode) String() string
func (PluginEndpointRequest_UpgradeMode) Type ¶
func (PluginEndpointRequest_UpgradeMode) Type() protoreflect.EnumType
type PluginFailureRequest ¶
type PluginFailureRequest struct { SupervisorId string `protobuf:"bytes,1,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` PluginId string `protobuf:"bytes,22,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` // contains filtered or unexported fields }
func (*PluginFailureRequest) Descriptor
deprecated
func (*PluginFailureRequest) Descriptor() ([]byte, []int)
Deprecated: Use PluginFailureRequest.ProtoReflect.Descriptor instead.
func (*PluginFailureRequest) GetDomainId ¶
func (x *PluginFailureRequest) GetDomainId() string
func (*PluginFailureRequest) GetPluginId ¶
func (x *PluginFailureRequest) GetPluginId() string
func (*PluginFailureRequest) GetSupervisorId ¶
func (x *PluginFailureRequest) GetSupervisorId() string
func (*PluginFailureRequest) GetVersion ¶
func (x *PluginFailureRequest) GetVersion() string
func (*PluginFailureRequest) ProtoMessage ¶
func (*PluginFailureRequest) ProtoMessage()
func (*PluginFailureRequest) ProtoReflect ¶
func (x *PluginFailureRequest) ProtoReflect() protoreflect.Message
func (*PluginFailureRequest) Reset ¶
func (x *PluginFailureRequest) Reset()
func (*PluginFailureRequest) String ¶
func (x *PluginFailureRequest) String() string
type PluginInfo ¶
type PluginInfo struct { PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` State PluginInfo_State `protobuf:"varint,3,opt,name=state,proto3,enum=spaceone.api.plugin.v1.PluginInfo_State" json:"state,omitempty"` Endpoint string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Managed bool `protobuf:"varint,7,opt,name=managed,proto3" json:"managed,omitempty"` Endpoints []string `protobuf:"bytes,8,rep,name=endpoints,proto3" json:"endpoints,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` SupervisorId string `protobuf:"bytes,22,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` SupervisorName string `protobuf:"bytes,23,opt,name=supervisor_name,json=supervisorName,proto3" json:"supervisor_name,omitempty"` // contains filtered or unexported fields }
func (*PluginInfo) Descriptor
deprecated
func (*PluginInfo) Descriptor() ([]byte, []int)
Deprecated: Use PluginInfo.ProtoReflect.Descriptor instead.
func (*PluginInfo) GetDomainId ¶
func (x *PluginInfo) GetDomainId() string
func (*PluginInfo) GetEndpoint ¶
func (x *PluginInfo) GetEndpoint() string
func (*PluginInfo) GetEndpoints ¶
func (x *PluginInfo) GetEndpoints() []string
func (*PluginInfo) GetManaged ¶
func (x *PluginInfo) GetManaged() bool
func (*PluginInfo) GetPluginId ¶
func (x *PluginInfo) GetPluginId() string
func (*PluginInfo) GetState ¶
func (x *PluginInfo) GetState() PluginInfo_State
func (*PluginInfo) GetSupervisorId ¶
func (x *PluginInfo) GetSupervisorId() string
func (*PluginInfo) GetSupervisorName ¶
func (x *PluginInfo) GetSupervisorName() string
func (*PluginInfo) GetVersion ¶
func (x *PluginInfo) GetVersion() string
func (*PluginInfo) ProtoMessage ¶
func (*PluginInfo) ProtoMessage()
func (*PluginInfo) ProtoReflect ¶
func (x *PluginInfo) ProtoReflect() protoreflect.Message
func (*PluginInfo) Reset ¶
func (x *PluginInfo) Reset()
func (*PluginInfo) String ¶
func (x *PluginInfo) String() string
type PluginInfo_State ¶
type PluginInfo_State int32
const ( PluginInfo_NONE PluginInfo_State = 0 PluginInfo_PROVISIONING PluginInfo_State = 1 PluginInfo_ACTIVE PluginInfo_State = 2 PluginInfo_RE_PROVISIONING PluginInfo_State = 3 PluginInfo_ERROR PluginInfo_State = 4 )
func (PluginInfo_State) Descriptor ¶
func (PluginInfo_State) Descriptor() protoreflect.EnumDescriptor
func (PluginInfo_State) Enum ¶
func (x PluginInfo_State) Enum() *PluginInfo_State
func (PluginInfo_State) EnumDescriptor
deprecated
func (PluginInfo_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginInfo_State.Descriptor instead.
func (PluginInfo_State) Number ¶
func (x PluginInfo_State) Number() protoreflect.EnumNumber
func (PluginInfo_State) String ¶
func (x PluginInfo_State) String() string
func (PluginInfo_State) Type ¶
func (PluginInfo_State) Type() protoreflect.EnumType
type PluginMetadata ¶
type PluginMetadata struct { Metadata *_struct.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*PluginMetadata) Descriptor
deprecated
func (*PluginMetadata) Descriptor() ([]byte, []int)
Deprecated: Use PluginMetadata.ProtoReflect.Descriptor instead.
func (*PluginMetadata) GetMetadata ¶
func (x *PluginMetadata) GetMetadata() *_struct.Struct
func (*PluginMetadata) ProtoMessage ¶
func (*PluginMetadata) ProtoMessage()
func (*PluginMetadata) ProtoReflect ¶
func (x *PluginMetadata) ProtoReflect() protoreflect.Message
func (*PluginMetadata) Reset ¶
func (x *PluginMetadata) Reset()
func (*PluginMetadata) String ¶
func (x *PluginMetadata) String() string
type PluginMetadataRequest ¶
type PluginMetadataRequest struct { PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` // +optional Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // +optional UpgradeMode PluginMetadataRequest_UpgradeMode `` /* 157-byte string literal not displayed */ // +optional Options *_struct.Struct `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*PluginMetadataRequest) Descriptor
deprecated
func (*PluginMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use PluginMetadataRequest.ProtoReflect.Descriptor instead.
func (*PluginMetadataRequest) GetOptions ¶
func (x *PluginMetadataRequest) GetOptions() *_struct.Struct
func (*PluginMetadataRequest) GetPluginId ¶
func (x *PluginMetadataRequest) GetPluginId() string
func (*PluginMetadataRequest) GetUpgradeMode ¶
func (x *PluginMetadataRequest) GetUpgradeMode() PluginMetadataRequest_UpgradeMode
func (*PluginMetadataRequest) GetVersion ¶
func (x *PluginMetadataRequest) GetVersion() string
func (*PluginMetadataRequest) ProtoMessage ¶
func (*PluginMetadataRequest) ProtoMessage()
func (*PluginMetadataRequest) ProtoReflect ¶
func (x *PluginMetadataRequest) ProtoReflect() protoreflect.Message
func (*PluginMetadataRequest) Reset ¶
func (x *PluginMetadataRequest) Reset()
func (*PluginMetadataRequest) String ¶
func (x *PluginMetadataRequest) String() string
type PluginMetadataRequest_UpgradeMode ¶
type PluginMetadataRequest_UpgradeMode int32
const ( PluginMetadataRequest_MANUAL PluginMetadataRequest_UpgradeMode = 0 PluginMetadataRequest_AUTO PluginMetadataRequest_UpgradeMode = 1 )
func (PluginMetadataRequest_UpgradeMode) Descriptor ¶
func (PluginMetadataRequest_UpgradeMode) Descriptor() protoreflect.EnumDescriptor
func (PluginMetadataRequest_UpgradeMode) Enum ¶
func (x PluginMetadataRequest_UpgradeMode) Enum() *PluginMetadataRequest_UpgradeMode
func (PluginMetadataRequest_UpgradeMode) EnumDescriptor
deprecated
func (PluginMetadataRequest_UpgradeMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginMetadataRequest_UpgradeMode.Descriptor instead.
func (PluginMetadataRequest_UpgradeMode) Number ¶
func (x PluginMetadataRequest_UpgradeMode) Number() protoreflect.EnumNumber
func (PluginMetadataRequest_UpgradeMode) String ¶
func (x PluginMetadataRequest_UpgradeMode) String() string
func (PluginMetadataRequest_UpgradeMode) Type ¶
func (PluginMetadataRequest_UpgradeMode) Type() protoreflect.EnumType
type PluginQuery ¶
type PluginQuery struct { // +optional Query *v2.Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // +optional SupervisorId string `protobuf:"bytes,2,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` // +optional Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"` // +optional PluginId string `protobuf:"bytes,4,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` // +optional Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` // +optional State PluginQuery_State `protobuf:"varint,6,opt,name=state,proto3,enum=spaceone.api.plugin.v1.PluginQuery_State" json:"state,omitempty"` // +optional Endpoint string `protobuf:"bytes,7,opt,name=endpoint,proto3" json:"endpoint,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "query": {} }
func (*PluginQuery) Descriptor
deprecated
func (*PluginQuery) Descriptor() ([]byte, []int)
Deprecated: Use PluginQuery.ProtoReflect.Descriptor instead.
func (*PluginQuery) GetDomainId ¶
func (x *PluginQuery) GetDomainId() string
func (*PluginQuery) GetEndpoint ¶
func (x *PluginQuery) GetEndpoint() string
func (*PluginQuery) GetHostname ¶
func (x *PluginQuery) GetHostname() string
func (*PluginQuery) GetPluginId ¶
func (x *PluginQuery) GetPluginId() string
func (*PluginQuery) GetQuery ¶
func (x *PluginQuery) GetQuery() *v2.Query
func (*PluginQuery) GetState ¶
func (x *PluginQuery) GetState() PluginQuery_State
func (*PluginQuery) GetSupervisorId ¶
func (x *PluginQuery) GetSupervisorId() string
func (*PluginQuery) GetVersion ¶
func (x *PluginQuery) GetVersion() string
func (*PluginQuery) ProtoMessage ¶
func (*PluginQuery) ProtoMessage()
func (*PluginQuery) ProtoReflect ¶
func (x *PluginQuery) ProtoReflect() protoreflect.Message
func (*PluginQuery) Reset ¶
func (x *PluginQuery) Reset()
func (*PluginQuery) String ¶
func (x *PluginQuery) String() string
type PluginQuery_State ¶
type PluginQuery_State int32
const ( PluginQuery_NONE PluginQuery_State = 0 PluginQuery_PROVISIONING PluginQuery_State = 1 PluginQuery_ACTIVE PluginQuery_State = 2 PluginQuery_RE_PROVISIONING PluginQuery_State = 3 PluginQuery_ERROR PluginQuery_State = 4 )
func (PluginQuery_State) Descriptor ¶
func (PluginQuery_State) Descriptor() protoreflect.EnumDescriptor
func (PluginQuery_State) Enum ¶
func (x PluginQuery_State) Enum() *PluginQuery_State
func (PluginQuery_State) EnumDescriptor
deprecated
func (PluginQuery_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginQuery_State.Descriptor instead.
func (PluginQuery_State) Number ¶
func (x PluginQuery_State) Number() protoreflect.EnumNumber
func (PluginQuery_State) String ¶
func (x PluginQuery_State) String() string
func (PluginQuery_State) Type ¶
func (PluginQuery_State) Type() protoreflect.EnumType
type PluginServer ¶
type PluginServer interface { // Gets the `endpoint` of a specific plugin instance. A Plugin returns only a single `endpoint` by determining `labels` and `priority`. If the requested plugin instance is already deployed, the `endpoint` is returned. If not, the `endpoint` is returned after deploying the plugin instance. GetPluginEndpoint(context.Context, *PluginEndpointRequest) (*PluginEndpoint, error) GetPluginMetadata(context.Context, *PluginMetadataRequest) (*PluginMetadata, error) NotifyFailure(context.Context, *PluginFailureRequest) (*empty.Empty, error) // contains filtered or unexported methods }
PluginServer is the server API for Plugin service. All implementations must embed UnimplementedPluginServer for forward compatibility
type PluginsInfo ¶
type PluginsInfo struct { Results []*PluginInfo `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // contains filtered or unexported fields }
{ "results": [ { "plugin_id": "plugin-openstack-inven-collector", "version": "0.4.1.20220609.122832", "state": "ACTIVE", "endpoint": "grpc://plugin-openstack-inven-collector-vbnnsoszfjsneiqz.dev-supervisor.svc.cluster.local:50051", "supervisor_id": "supervisor-3a091f899539", "supervisor_name": "root", "managed": true, "endpoints": [ "grpc://172.16.16.234:50051" ] }, { "plugin_id": "plugin-zabbix-mon-webhook", "version": "1.0", "state": "ACTIVE", "endpoint": "grpc://plugin-zabbix-mon-webhook-dgqqfqsqidieeuk.dev-supervisor.svc.cluster.local:50051", "supervisor_id": "supervisor-3a091f899539", "supervisor_name": "root", "managed": true, "endpoints": [ "grpc://172.16.16.130:50051" ] } ], "total_count": 2 }
func (*PluginsInfo) Descriptor
deprecated
func (*PluginsInfo) Descriptor() ([]byte, []int)
Deprecated: Use PluginsInfo.ProtoReflect.Descriptor instead.
func (*PluginsInfo) GetResults ¶
func (x *PluginsInfo) GetResults() []*PluginInfo
func (*PluginsInfo) GetTotalCount ¶
func (x *PluginsInfo) GetTotalCount() int32
func (*PluginsInfo) ProtoMessage ¶
func (*PluginsInfo) ProtoMessage()
func (*PluginsInfo) ProtoReflect ¶
func (x *PluginsInfo) ProtoReflect() protoreflect.Message
func (*PluginsInfo) Reset ¶
func (x *PluginsInfo) Reset()
func (*PluginsInfo) String ¶
func (x *PluginsInfo) String() string
type PublishSupervisorRequest ¶
type PublishSupervisorRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"` // +optional SecretKey string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"` // +optional PluginInfo []*PluginInfo `protobuf:"bytes,4,rep,name=plugin_info,json=pluginInfo,proto3" json:"plugin_info,omitempty"` // +optional IsPublic bool `protobuf:"varint,5,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"` // +optional Labels *_struct.ListValue `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"` // +optional Tags *_struct.Struct `protobuf:"bytes,7,opt,name=tags,proto3" json:"tags,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "name": "test", "hostname": "dev-test2", "secret_key": "xxxxx", "tags": { "a": "b" } }
func (*PublishSupervisorRequest) Descriptor
deprecated
func (*PublishSupervisorRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishSupervisorRequest.ProtoReflect.Descriptor instead.
func (*PublishSupervisorRequest) GetDomainId ¶
func (x *PublishSupervisorRequest) GetDomainId() string
func (*PublishSupervisorRequest) GetHostname ¶
func (x *PublishSupervisorRequest) GetHostname() string
func (*PublishSupervisorRequest) GetIsPublic ¶
func (x *PublishSupervisorRequest) GetIsPublic() bool
func (*PublishSupervisorRequest) GetLabels ¶
func (x *PublishSupervisorRequest) GetLabels() *_struct.ListValue
func (*PublishSupervisorRequest) GetName ¶
func (x *PublishSupervisorRequest) GetName() string
func (*PublishSupervisorRequest) GetPluginInfo ¶
func (x *PublishSupervisorRequest) GetPluginInfo() []*PluginInfo
func (*PublishSupervisorRequest) GetSecretKey ¶
func (x *PublishSupervisorRequest) GetSecretKey() string
func (*PublishSupervisorRequest) GetTags ¶
func (x *PublishSupervisorRequest) GetTags() *_struct.Struct
func (*PublishSupervisorRequest) ProtoMessage ¶
func (*PublishSupervisorRequest) ProtoMessage()
func (*PublishSupervisorRequest) ProtoReflect ¶
func (x *PublishSupervisorRequest) ProtoReflect() protoreflect.Message
func (*PublishSupervisorRequest) Reset ¶
func (x *PublishSupervisorRequest) Reset()
func (*PublishSupervisorRequest) String ¶
func (x *PublishSupervisorRequest) String() string
type RecoverPluginRequest ¶
type RecoverPluginRequest struct { SupervisorId string `protobuf:"bytes,1,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` PluginId string `protobuf:"bytes,22,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"` // contains filtered or unexported fields }
{ "supervisor_id": "supervisor-a4c287cba676", "plugin_id": "plugin-api-direct-mon-webhook", "version": "1.1.0" }
func (*RecoverPluginRequest) Descriptor
deprecated
func (*RecoverPluginRequest) Descriptor() ([]byte, []int)
Deprecated: Use RecoverPluginRequest.ProtoReflect.Descriptor instead.
func (*RecoverPluginRequest) GetDomainId ¶
func (x *RecoverPluginRequest) GetDomainId() string
func (*RecoverPluginRequest) GetPluginId ¶
func (x *RecoverPluginRequest) GetPluginId() string
func (*RecoverPluginRequest) GetSupervisorId ¶
func (x *RecoverPluginRequest) GetSupervisorId() string
func (*RecoverPluginRequest) GetVersion ¶
func (x *RecoverPluginRequest) GetVersion() string
func (*RecoverPluginRequest) ProtoMessage ¶
func (*RecoverPluginRequest) ProtoMessage()
func (*RecoverPluginRequest) ProtoReflect ¶
func (x *RecoverPluginRequest) ProtoReflect() protoreflect.Message
func (*RecoverPluginRequest) Reset ¶
func (x *RecoverPluginRequest) Reset()
func (*RecoverPluginRequest) String ¶
func (x *RecoverPluginRequest) String() string
type RegisterSupervisorRequest ¶
type RegisterSupervisorRequest struct { SupervisorId string `protobuf:"bytes,1,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` // +optional Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // +optional IsPublic bool `protobuf:"varint,3,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"` // +optional Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"` // +optional Labels *_struct.Struct `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"` // +optional Tags *_struct.Struct `protobuf:"bytes,6,opt,name=tags,proto3" json:"tags,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "supervisor_id": "supervisor-525982f2ae9a", "is_public": true, "priority": 10, "labels": { "a": "b" }, "tags": { "c": "d" }, "domain_id": "domain-1c5a6b8181ad" }
func (*RegisterSupervisorRequest) Descriptor
deprecated
func (*RegisterSupervisorRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSupervisorRequest.ProtoReflect.Descriptor instead.
func (*RegisterSupervisorRequest) GetDomainId ¶
func (x *RegisterSupervisorRequest) GetDomainId() string
func (*RegisterSupervisorRequest) GetIsPublic ¶
func (x *RegisterSupervisorRequest) GetIsPublic() bool
func (*RegisterSupervisorRequest) GetLabels ¶
func (x *RegisterSupervisorRequest) GetLabels() *_struct.Struct
func (*RegisterSupervisorRequest) GetName ¶
func (x *RegisterSupervisorRequest) GetName() string
func (*RegisterSupervisorRequest) GetPriority ¶
func (x *RegisterSupervisorRequest) GetPriority() int32
func (*RegisterSupervisorRequest) GetSupervisorId ¶
func (x *RegisterSupervisorRequest) GetSupervisorId() string
func (*RegisterSupervisorRequest) GetTags ¶
func (x *RegisterSupervisorRequest) GetTags() *_struct.Struct
func (*RegisterSupervisorRequest) ProtoMessage ¶
func (*RegisterSupervisorRequest) ProtoMessage()
func (*RegisterSupervisorRequest) ProtoReflect ¶
func (x *RegisterSupervisorRequest) ProtoReflect() protoreflect.Message
func (*RegisterSupervisorRequest) Reset ¶
func (x *RegisterSupervisorRequest) Reset()
func (*RegisterSupervisorRequest) String ¶
func (x *RegisterSupervisorRequest) String() string
type SupervisorClient ¶
type SupervisorClient interface { // Creates a new Supervisor. Only Users with the `MANAGED` permission can set the Supervisor `public`. The Supervisor manages the lifecycle of plugin instances by the Supervisor's state. When a Supervisor is created, the state of the resource is `PENDING`. If the state remains the same for 5 minutes, the state is changed to `DISCONNECTED`. Publish(ctx context.Context, in *PublishSupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Registers a specific Supervisor. You must specify the `supervisor_id` of the Supervisor to register. The `state` of the Supervisor changes from `PENDING` to `ENABLED`. Register(ctx context.Context, in *RegisterSupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Updates a specific Supervisor. You can make changes in Supervisor settings, including `labels`, `tags`, and the `bool` type parameter `is_public`. Update(ctx context.Context, in *RegisterSupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Deregisters and deletes a specific Supervisor. You must specify the `supervisor_id` of the Supervisor to deregister. Deregister(ctx context.Context, in *SupervisorRequest, opts ...grpc.CallOption) (*empty.Empty, error) // Enables a specific Supervisor. By changing the `state` parameter to `ENABLED`, the Supervisor can deploy or delete the `pod` of the plugin instance. Enable(ctx context.Context, in *SupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Disables a specific Supervisor. By changing the `state` parameter to `DISABLED`, the Supervisor cannot deploy or delete the `pod` of the plugin instance. Disable(ctx context.Context, in *SupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Recovers a specific plugin instance in a specific Supervisor. Changes the `state` of the Supervisor to `RE-PROVISIONING`. RecoverPlugin(ctx context.Context, in *RecoverPluginRequest, opts ...grpc.CallOption) (*PluginInfo, error) Get(ctx context.Context, in *SupervisorRequest, opts ...grpc.CallOption) (*SupervisorInfo, error) // Gets a list of all Supervisors. You can use a query to get a filtered list of Supervisors. List(ctx context.Context, in *SupervisorQuery, opts ...grpc.CallOption) (*SupervisorsInfo, error) Stat(ctx context.Context, in *SupervisorStatQuery, opts ...grpc.CallOption) (*_struct.Struct, error) // Gets a list of all plugin instances regardless of Supervisors. Prints detailed information about the plugin instances, including `version`, `state`, and the relevant Supervisor. ListPlugins(ctx context.Context, in *PluginQuery, opts ...grpc.CallOption) (*PluginsInfo, error) }
SupervisorClient is the client API for Supervisor 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 NewSupervisorClient ¶
func NewSupervisorClient(cc grpc.ClientConnInterface) SupervisorClient
type SupervisorInfo ¶
type SupervisorInfo struct { SupervisorId string `protobuf:"bytes,1,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"` State SupervisorInfo_State `protobuf:"varint,4,opt,name=state,proto3,enum=spaceone.api.plugin.v1.SupervisorInfo_State" json:"state,omitempty"` IsPublic bool `protobuf:"varint,5,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"` Labels *_struct.Struct `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"` Tags *_struct.Struct `protobuf:"bytes,7,opt,name=tags,proto3" json:"tags,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` CreatedAt string `protobuf:"bytes,31,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt string `protobuf:"bytes,32,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // contains filtered or unexported fields }
{ "supervisor_id": "supervisor-525982f2ae9a", "name": "test", "hostname": "dev-test2", "state": "ENABLED", "domain_id": "domain-1c5a6b8181ad", "tags": { "a": "b" }, "labels": {}, "created_at": "2022-01-15T05:42:02.999Z" }
func (*SupervisorInfo) Descriptor
deprecated
func (*SupervisorInfo) Descriptor() ([]byte, []int)
Deprecated: Use SupervisorInfo.ProtoReflect.Descriptor instead.
func (*SupervisorInfo) GetCreatedAt ¶
func (x *SupervisorInfo) GetCreatedAt() string
func (*SupervisorInfo) GetDomainId ¶
func (x *SupervisorInfo) GetDomainId() string
func (*SupervisorInfo) GetHostname ¶
func (x *SupervisorInfo) GetHostname() string
func (*SupervisorInfo) GetIsPublic ¶
func (x *SupervisorInfo) GetIsPublic() bool
func (*SupervisorInfo) GetLabels ¶
func (x *SupervisorInfo) GetLabels() *_struct.Struct
func (*SupervisorInfo) GetName ¶
func (x *SupervisorInfo) GetName() string
func (*SupervisorInfo) GetState ¶
func (x *SupervisorInfo) GetState() SupervisorInfo_State
func (*SupervisorInfo) GetSupervisorId ¶
func (x *SupervisorInfo) GetSupervisorId() string
func (*SupervisorInfo) GetTags ¶
func (x *SupervisorInfo) GetTags() *_struct.Struct
func (*SupervisorInfo) GetUpdatedAt ¶
func (x *SupervisorInfo) GetUpdatedAt() string
func (*SupervisorInfo) ProtoMessage ¶
func (*SupervisorInfo) ProtoMessage()
func (*SupervisorInfo) ProtoReflect ¶
func (x *SupervisorInfo) ProtoReflect() protoreflect.Message
func (*SupervisorInfo) Reset ¶
func (x *SupervisorInfo) Reset()
func (*SupervisorInfo) String ¶
func (x *SupervisorInfo) String() string
type SupervisorInfo_State ¶
type SupervisorInfo_State int32
const ( SupervisorInfo_NONE SupervisorInfo_State = 0 SupervisorInfo_ENABLED SupervisorInfo_State = 1 SupervisorInfo_DISABLED SupervisorInfo_State = 2 SupervisorInfo_PENDING SupervisorInfo_State = 3 SupervisorInfo_DISCONNECTED SupervisorInfo_State = 4 )
func (SupervisorInfo_State) Descriptor ¶
func (SupervisorInfo_State) Descriptor() protoreflect.EnumDescriptor
func (SupervisorInfo_State) Enum ¶
func (x SupervisorInfo_State) Enum() *SupervisorInfo_State
func (SupervisorInfo_State) EnumDescriptor
deprecated
func (SupervisorInfo_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use SupervisorInfo_State.Descriptor instead.
func (SupervisorInfo_State) Number ¶
func (x SupervisorInfo_State) Number() protoreflect.EnumNumber
func (SupervisorInfo_State) String ¶
func (x SupervisorInfo_State) String() string
func (SupervisorInfo_State) Type ¶
func (SupervisorInfo_State) Type() protoreflect.EnumType
type SupervisorQuery ¶
type SupervisorQuery struct { // +optional Query *v2.Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // +optional SupervisorId string `protobuf:"bytes,2,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` // +optional Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // +optional IsPublic bool `protobuf:"varint,4,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "query": {} }
func (*SupervisorQuery) Descriptor
deprecated
func (*SupervisorQuery) Descriptor() ([]byte, []int)
Deprecated: Use SupervisorQuery.ProtoReflect.Descriptor instead.
func (*SupervisorQuery) GetDomainId ¶
func (x *SupervisorQuery) GetDomainId() string
func (*SupervisorQuery) GetIsPublic ¶
func (x *SupervisorQuery) GetIsPublic() bool
func (*SupervisorQuery) GetName ¶
func (x *SupervisorQuery) GetName() string
func (*SupervisorQuery) GetQuery ¶
func (x *SupervisorQuery) GetQuery() *v2.Query
func (*SupervisorQuery) GetSupervisorId ¶
func (x *SupervisorQuery) GetSupervisorId() string
func (*SupervisorQuery) ProtoMessage ¶
func (*SupervisorQuery) ProtoMessage()
func (*SupervisorQuery) ProtoReflect ¶
func (x *SupervisorQuery) ProtoReflect() protoreflect.Message
func (*SupervisorQuery) Reset ¶
func (x *SupervisorQuery) Reset()
func (*SupervisorQuery) String ¶
func (x *SupervisorQuery) String() string
type SupervisorRequest ¶
type SupervisorRequest struct { SupervisorId string `protobuf:"bytes,1,opt,name=supervisor_id,json=supervisorId,proto3" json:"supervisor_id,omitempty"` DomainId string `protobuf:"bytes,21,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
{ "supervisor_id": "supervisor-d73011256d55" }
func (*SupervisorRequest) Descriptor
deprecated
func (*SupervisorRequest) Descriptor() ([]byte, []int)
Deprecated: Use SupervisorRequest.ProtoReflect.Descriptor instead.
func (*SupervisorRequest) GetDomainId ¶
func (x *SupervisorRequest) GetDomainId() string
func (*SupervisorRequest) GetSupervisorId ¶
func (x *SupervisorRequest) GetSupervisorId() string
func (*SupervisorRequest) ProtoMessage ¶
func (*SupervisorRequest) ProtoMessage()
func (*SupervisorRequest) ProtoReflect ¶
func (x *SupervisorRequest) ProtoReflect() protoreflect.Message
func (*SupervisorRequest) Reset ¶
func (x *SupervisorRequest) Reset()
func (*SupervisorRequest) String ¶
func (x *SupervisorRequest) String() string
type SupervisorServer ¶
type SupervisorServer interface { // Creates a new Supervisor. Only Users with the `MANAGED` permission can set the Supervisor `public`. The Supervisor manages the lifecycle of plugin instances by the Supervisor's state. When a Supervisor is created, the state of the resource is `PENDING`. If the state remains the same for 5 minutes, the state is changed to `DISCONNECTED`. Publish(context.Context, *PublishSupervisorRequest) (*SupervisorInfo, error) // Registers a specific Supervisor. You must specify the `supervisor_id` of the Supervisor to register. The `state` of the Supervisor changes from `PENDING` to `ENABLED`. Register(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error) // Updates a specific Supervisor. You can make changes in Supervisor settings, including `labels`, `tags`, and the `bool` type parameter `is_public`. Update(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error) // Deregisters and deletes a specific Supervisor. You must specify the `supervisor_id` of the Supervisor to deregister. Deregister(context.Context, *SupervisorRequest) (*empty.Empty, error) // Enables a specific Supervisor. By changing the `state` parameter to `ENABLED`, the Supervisor can deploy or delete the `pod` of the plugin instance. Enable(context.Context, *SupervisorRequest) (*SupervisorInfo, error) // Disables a specific Supervisor. By changing the `state` parameter to `DISABLED`, the Supervisor cannot deploy or delete the `pod` of the plugin instance. Disable(context.Context, *SupervisorRequest) (*SupervisorInfo, error) // Recovers a specific plugin instance in a specific Supervisor. Changes the `state` of the Supervisor to `RE-PROVISIONING`. RecoverPlugin(context.Context, *RecoverPluginRequest) (*PluginInfo, error) Get(context.Context, *SupervisorRequest) (*SupervisorInfo, error) // Gets a list of all Supervisors. You can use a query to get a filtered list of Supervisors. List(context.Context, *SupervisorQuery) (*SupervisorsInfo, error) Stat(context.Context, *SupervisorStatQuery) (*_struct.Struct, error) // Gets a list of all plugin instances regardless of Supervisors. Prints detailed information about the plugin instances, including `version`, `state`, and the relevant Supervisor. ListPlugins(context.Context, *PluginQuery) (*PluginsInfo, error) // contains filtered or unexported methods }
SupervisorServer is the server API for Supervisor service. All implementations must embed UnimplementedSupervisorServer for forward compatibility
type SupervisorStatQuery ¶
type SupervisorStatQuery struct { Query *v2.StatisticsQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` DomainId string `protobuf:"bytes,2,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` // contains filtered or unexported fields }
func (*SupervisorStatQuery) Descriptor
deprecated
func (*SupervisorStatQuery) Descriptor() ([]byte, []int)
Deprecated: Use SupervisorStatQuery.ProtoReflect.Descriptor instead.
func (*SupervisorStatQuery) GetDomainId ¶
func (x *SupervisorStatQuery) GetDomainId() string
func (*SupervisorStatQuery) GetQuery ¶
func (x *SupervisorStatQuery) GetQuery() *v2.StatisticsQuery
func (*SupervisorStatQuery) ProtoMessage ¶
func (*SupervisorStatQuery) ProtoMessage()
func (*SupervisorStatQuery) ProtoReflect ¶
func (x *SupervisorStatQuery) ProtoReflect() protoreflect.Message
func (*SupervisorStatQuery) Reset ¶
func (x *SupervisorStatQuery) Reset()
func (*SupervisorStatQuery) String ¶
func (x *SupervisorStatQuery) String() string
type SupervisorsInfo ¶
type SupervisorsInfo struct { Results []*SupervisorInfo `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // contains filtered or unexported fields }
{ "results": [ { "supervisor_id": "supervisor-3a091f899539", "name": "root", "hostname": "dev-supervisor.svc.cluster.local", "state": "ENABLED", "is_public": true, "domain_id": "domain-1c5a6b8181ad", "labels": {}, "created_at": "2020-05-12T00:24:48.250Z" }, { "supervisor_id": "supervisor-a4c287cba676", "name": "test", "hostname": "dev-test", "state": "ENABLED", "domain_id": "domain-1c5a6b8181ad", "tags": { "a": "b" }, "labels": {}, "created_at": "2022-06-15T05:39:15.886Z" } ], "total_count": 2 }
func (*SupervisorsInfo) Descriptor
deprecated
func (*SupervisorsInfo) Descriptor() ([]byte, []int)
Deprecated: Use SupervisorsInfo.ProtoReflect.Descriptor instead.
func (*SupervisorsInfo) GetResults ¶
func (x *SupervisorsInfo) GetResults() []*SupervisorInfo
func (*SupervisorsInfo) GetTotalCount ¶
func (x *SupervisorsInfo) GetTotalCount() int32
func (*SupervisorsInfo) ProtoMessage ¶
func (*SupervisorsInfo) ProtoMessage()
func (*SupervisorsInfo) ProtoReflect ¶
func (x *SupervisorsInfo) ProtoReflect() protoreflect.Message
func (*SupervisorsInfo) Reset ¶
func (x *SupervisorsInfo) Reset()
func (*SupervisorsInfo) String ¶
func (x *SupervisorsInfo) String() string
type UnimplementedPluginServer ¶
type UnimplementedPluginServer struct { }
UnimplementedPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedPluginServer) GetPluginEndpoint ¶
func (UnimplementedPluginServer) GetPluginEndpoint(context.Context, *PluginEndpointRequest) (*PluginEndpoint, error)
func (UnimplementedPluginServer) GetPluginMetadata ¶
func (UnimplementedPluginServer) GetPluginMetadata(context.Context, *PluginMetadataRequest) (*PluginMetadata, error)
func (UnimplementedPluginServer) NotifyFailure ¶
func (UnimplementedPluginServer) NotifyFailure(context.Context, *PluginFailureRequest) (*empty.Empty, error)
type UnimplementedSupervisorServer ¶
type UnimplementedSupervisorServer struct { }
UnimplementedSupervisorServer must be embedded to have forward compatible implementations.
func (UnimplementedSupervisorServer) Deregister ¶
func (UnimplementedSupervisorServer) Deregister(context.Context, *SupervisorRequest) (*empty.Empty, error)
func (UnimplementedSupervisorServer) Disable ¶
func (UnimplementedSupervisorServer) Disable(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
func (UnimplementedSupervisorServer) Enable ¶
func (UnimplementedSupervisorServer) Enable(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
func (UnimplementedSupervisorServer) Get ¶
func (UnimplementedSupervisorServer) Get(context.Context, *SupervisorRequest) (*SupervisorInfo, error)
func (UnimplementedSupervisorServer) List ¶
func (UnimplementedSupervisorServer) List(context.Context, *SupervisorQuery) (*SupervisorsInfo, error)
func (UnimplementedSupervisorServer) ListPlugins ¶
func (UnimplementedSupervisorServer) ListPlugins(context.Context, *PluginQuery) (*PluginsInfo, error)
func (UnimplementedSupervisorServer) Publish ¶
func (UnimplementedSupervisorServer) Publish(context.Context, *PublishSupervisorRequest) (*SupervisorInfo, error)
func (UnimplementedSupervisorServer) RecoverPlugin ¶
func (UnimplementedSupervisorServer) RecoverPlugin(context.Context, *RecoverPluginRequest) (*PluginInfo, error)
func (UnimplementedSupervisorServer) Register ¶
func (UnimplementedSupervisorServer) Register(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error)
func (UnimplementedSupervisorServer) Stat ¶
func (UnimplementedSupervisorServer) Stat(context.Context, *SupervisorStatQuery) (*_struct.Struct, error)
func (UnimplementedSupervisorServer) Update ¶
func (UnimplementedSupervisorServer) Update(context.Context, *RegisterSupervisorRequest) (*SupervisorInfo, error)
type UnsafePluginServer ¶
type UnsafePluginServer interface {
// contains filtered or unexported methods
}
UnsafePluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServer will result in compilation errors.
type UnsafeSupervisorServer ¶
type UnsafeSupervisorServer interface {
// contains filtered or unexported methods
}
UnsafeSupervisorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SupervisorServer will result in compilation errors.