Versions in this module Expand all Collapse all v1 v1.0.1 Jun 1, 2023 v1.0.0 Jan 7, 2022 Changes in this version + var ExecuteResponse_State_name = map[int32]string + var ExecuteResponse_State_value = map[string]int32 + var File_proto_dsrv_api_node_manager_plugin_manager_plugin_proto protoreflect.FileDescriptor + var ManagerPlugin_ServiceDesc = grpc.ServiceDesc + func RegisterManagerPluginServer(s grpc.ServiceRegistrar, srv ManagerPluginServer) + type CollectorVerifyInfo struct + Options *structpb.Struct + func (*CollectorVerifyInfo) Descriptor() ([]byte, []int) + func (*CollectorVerifyInfo) ProtoMessage() + func (x *CollectorVerifyInfo) GetOptions() *structpb.Struct + func (x *CollectorVerifyInfo) ProtoReflect() protoreflect.Message + func (x *CollectorVerifyInfo) Reset() + func (x *CollectorVerifyInfo) String() string + type ExecuteRequest struct + ExecuteInfo *structpb.Struct + Options *structpb.Struct + func (*ExecuteRequest) Descriptor() ([]byte, []int) + func (*ExecuteRequest) ProtoMessage() + func (x *ExecuteRequest) GetExecuteInfo() *structpb.Struct + func (x *ExecuteRequest) GetOptions() *structpb.Struct + func (x *ExecuteRequest) ProtoReflect() protoreflect.Message + func (x *ExecuteRequest) Reset() + func (x *ExecuteRequest) String() string + type ExecuteResponse struct + Message string + ResourceType string + State ExecuteResponse_State + func (*ExecuteResponse) Descriptor() ([]byte, []int) + func (*ExecuteResponse) ProtoMessage() + func (x *ExecuteResponse) GetMessage() string + func (x *ExecuteResponse) GetResourceType() string + func (x *ExecuteResponse) GetState() ExecuteResponse_State + func (x *ExecuteResponse) ProtoReflect() protoreflect.Message + func (x *ExecuteResponse) Reset() + func (x *ExecuteResponse) String() string + type ExecuteResponse_State int32 + const ExecuteResponse_FAILURE + const ExecuteResponse_INPROGRESS + const ExecuteResponse_NONE + const ExecuteResponse_PENDING + const ExecuteResponse_SUCCESS + const ExecuteResponse_TIMEOUT + func (ExecuteResponse_State) Descriptor() protoreflect.EnumDescriptor + func (ExecuteResponse_State) EnumDescriptor() ([]byte, []int) + func (ExecuteResponse_State) Type() protoreflect.EnumType + func (x ExecuteResponse_State) Enum() *ExecuteResponse_State + func (x ExecuteResponse_State) Number() protoreflect.EnumNumber + func (x ExecuteResponse_State) String() string + type ManagerPluginClient interface + Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) + Init func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PluginInfo, error) + Verify func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*VerifyInfo, error) + func NewManagerPluginClient(cc grpc.ClientConnInterface) ManagerPluginClient + type ManagerPluginServer interface + Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + Init func(context.Context, *emptypb.Empty) (*PluginInfo, error) + Verify func(context.Context, *emptypb.Empty) (*VerifyInfo, error) + type PluginInfo struct + Metadata *structpb.Struct + func (*PluginInfo) Descriptor() ([]byte, []int) + func (*PluginInfo) ProtoMessage() + func (x *PluginInfo) GetMetadata() *structpb.Struct + func (x *PluginInfo) ProtoReflect() protoreflect.Message + func (x *PluginInfo) Reset() + func (x *PluginInfo) String() string + type UnimplementedManagerPluginServer struct + func (UnimplementedManagerPluginServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + func (UnimplementedManagerPluginServer) Init(context.Context, *emptypb.Empty) (*PluginInfo, error) + func (UnimplementedManagerPluginServer) Verify(context.Context, *emptypb.Empty) (*VerifyInfo, error) + type UnsafeManagerPluginServer interface + type VerifyInfo struct + VerifyMsg string + func (*VerifyInfo) Descriptor() ([]byte, []int) + func (*VerifyInfo) ProtoMessage() + func (x *VerifyInfo) GetVerifyMsg() string + func (x *VerifyInfo) ProtoReflect() protoreflect.Message + func (x *VerifyInfo) Reset() + func (x *VerifyInfo) String() string