Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
- type AgentConfig
- func (*AgentConfig) Descriptor() ([]byte, []int)deprecated
- func (x *AgentConfig) GetCertFile() string
- func (x *AgentConfig) GetClientCaFile() string
- func (x *AgentConfig) GetHost() string
- func (x *AgentConfig) GetKeyFile() string
- func (x *AgentConfig) GetLogLevel() string
- func (x *AgentConfig) GetPort() string
- func (x *AgentConfig) GetServerCaFile() string
- func (*AgentConfig) ProtoMessage()
- func (x *AgentConfig) ProtoReflect() protoreflect.Message
- func (x *AgentConfig) Reset()
- func (x *AgentConfig) String() string
- type AgentEvent
- func (*AgentEvent) Descriptor() ([]byte, []int)deprecated
- func (x *AgentEvent) GetComputationId() string
- func (x *AgentEvent) GetDetails() []byte
- func (x *AgentEvent) GetEventType() string
- func (x *AgentEvent) GetOriginator() string
- func (x *AgentEvent) GetStatus() string
- func (x *AgentEvent) GetTimestamp() *timestamppb.Timestamp
- func (*AgentEvent) ProtoMessage()
- func (x *AgentEvent) ProtoReflect() protoreflect.Message
- func (x *AgentEvent) Reset()
- func (x *AgentEvent) String() string
- type AgentLog
- func (*AgentLog) Descriptor() ([]byte, []int)deprecated
- func (x *AgentLog) GetComputationId() string
- func (x *AgentLog) GetLevel() string
- func (x *AgentLog) GetMessage() string
- func (x *AgentLog) GetTimestamp() *timestamppb.Timestamp
- func (*AgentLog) ProtoMessage()
- func (x *AgentLog) ProtoReflect() protoreflect.Message
- func (x *AgentLog) Reset()
- func (x *AgentLog) String() string
- type Algorithm
- func (*Algorithm) Descriptor() ([]byte, []int)deprecated
- func (x *Algorithm) GetHash() []byte
- func (x *Algorithm) GetId() string
- func (x *Algorithm) GetProvider() string
- func (*Algorithm) ProtoMessage()
- func (x *Algorithm) ProtoReflect() protoreflect.Message
- func (x *Algorithm) Reset()
- func (x *Algorithm) String() string
- type ClientStreamMessage
- func (*ClientStreamMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ClientStreamMessage) GetAgentEvent() *AgentEvent
- func (x *ClientStreamMessage) GetAgentLog() *AgentLog
- func (m *ClientStreamMessage) GetMessage() isClientStreamMessage_Message
- func (x *ClientStreamMessage) GetRunRes() *RunResponse
- func (x *ClientStreamMessage) GetWhoami() *WhoAmI
- func (*ClientStreamMessage) ProtoMessage()
- func (x *ClientStreamMessage) ProtoReflect() protoreflect.Message
- func (x *ClientStreamMessage) Reset()
- func (x *ClientStreamMessage) String() string
- type ClientStreamMessage_AgentEvent
- type ClientStreamMessage_AgentLog
- type ClientStreamMessage_RunRes
- type ClientStreamMessage_Whoami
- type ComputationRunReq
- func (*ComputationRunReq) Descriptor() ([]byte, []int)deprecated
- func (x *ComputationRunReq) GetAgentConfig() *AgentConfig
- func (x *ComputationRunReq) GetAlgorithms() []*Algorithm
- func (x *ComputationRunReq) GetDatasets() []*Dataset
- func (x *ComputationRunReq) GetDescription() string
- func (x *ComputationRunReq) GetId() string
- func (x *ComputationRunReq) GetName() string
- func (x *ComputationRunReq) GetResultConsumers() []string
- func (*ComputationRunReq) ProtoMessage()
- func (x *ComputationRunReq) ProtoReflect() protoreflect.Message
- func (x *ComputationRunReq) Reset()
- func (x *ComputationRunReq) String() string
- type Dataset
- func (*Dataset) Descriptor() ([]byte, []int)deprecated
- func (x *Dataset) GetHash() []byte
- func (x *Dataset) GetId() string
- func (x *Dataset) GetProvider() string
- func (*Dataset) ProtoMessage()
- func (x *Dataset) ProtoReflect() protoreflect.Message
- func (x *Dataset) Reset()
- func (x *Dataset) String() string
- type ManagerServiceClient
- type ManagerServiceServer
- type ManagerService_ProcessClient
- type ManagerService_ProcessServer
- type RunResponse
- func (*RunResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunResponse) GetAgentPort() string
- func (x *RunResponse) GetComputationId() string
- func (*RunResponse) ProtoMessage()
- func (x *RunResponse) ProtoReflect() protoreflect.Message
- func (x *RunResponse) Reset()
- func (x *RunResponse) String() string
- type UnimplementedManagerServiceServer
- type UnsafeManagerServiceServer
- type WhoAmI
Constants ¶
const (
ManagerService_Process_FullMethodName = "/manager.ManagerService/Process"
)
Variables ¶
var File_manager_manager_proto protoreflect.FileDescriptor
var ManagerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "manager.ManagerService", HandlerType: (*ManagerServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Process", Handler: _ManagerService_Process_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "manager/manager.proto", }
ManagerService_ServiceDesc is the grpc.ServiceDesc for ManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServiceServer ¶
func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
Types ¶
type AgentConfig ¶
type AgentConfig struct { Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` CertFile string `protobuf:"bytes,3,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"` KeyFile string `protobuf:"bytes,4,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"` ClientCaFile string `protobuf:"bytes,5,opt,name=client_ca_file,json=clientCaFile,proto3" json:"client_ca_file,omitempty"` ServerCaFile string `protobuf:"bytes,6,opt,name=server_ca_file,json=serverCaFile,proto3" json:"server_ca_file,omitempty"` LogLevel string `protobuf:"bytes,7,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"` // contains filtered or unexported fields }
func (*AgentConfig) Descriptor
deprecated
func (*AgentConfig) Descriptor() ([]byte, []int)
Deprecated: Use AgentConfig.ProtoReflect.Descriptor instead.
func (*AgentConfig) GetCertFile ¶
func (x *AgentConfig) GetCertFile() string
func (*AgentConfig) GetClientCaFile ¶
func (x *AgentConfig) GetClientCaFile() string
func (*AgentConfig) GetHost ¶
func (x *AgentConfig) GetHost() string
func (*AgentConfig) GetKeyFile ¶
func (x *AgentConfig) GetKeyFile() string
func (*AgentConfig) GetLogLevel ¶
func (x *AgentConfig) GetLogLevel() string
func (*AgentConfig) GetPort ¶
func (x *AgentConfig) GetPort() string
func (*AgentConfig) GetServerCaFile ¶
func (x *AgentConfig) GetServerCaFile() string
func (*AgentConfig) ProtoMessage ¶
func (*AgentConfig) ProtoMessage()
func (*AgentConfig) ProtoReflect ¶
func (x *AgentConfig) ProtoReflect() protoreflect.Message
func (*AgentConfig) Reset ¶
func (x *AgentConfig) Reset()
func (*AgentConfig) String ¶
func (x *AgentConfig) String() string
type AgentEvent ¶
type AgentEvent struct { EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ComputationId string `protobuf:"bytes,3,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"` Details []byte `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"` Originator string `protobuf:"bytes,5,opt,name=originator,proto3" json:"originator,omitempty"` Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*AgentEvent) Descriptor
deprecated
func (*AgentEvent) Descriptor() ([]byte, []int)
Deprecated: Use AgentEvent.ProtoReflect.Descriptor instead.
func (*AgentEvent) GetComputationId ¶
func (x *AgentEvent) GetComputationId() string
func (*AgentEvent) GetDetails ¶
func (x *AgentEvent) GetDetails() []byte
func (*AgentEvent) GetEventType ¶
func (x *AgentEvent) GetEventType() string
func (*AgentEvent) GetOriginator ¶
func (x *AgentEvent) GetOriginator() string
func (*AgentEvent) GetStatus ¶
func (x *AgentEvent) GetStatus() string
func (*AgentEvent) GetTimestamp ¶
func (x *AgentEvent) GetTimestamp() *timestamppb.Timestamp
func (*AgentEvent) ProtoMessage ¶
func (*AgentEvent) ProtoMessage()
func (*AgentEvent) ProtoReflect ¶
func (x *AgentEvent) ProtoReflect() protoreflect.Message
func (*AgentEvent) Reset ¶
func (x *AgentEvent) Reset()
func (*AgentEvent) String ¶
func (x *AgentEvent) String() string
type AgentLog ¶
type AgentLog struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` ComputationId string `protobuf:"bytes,2,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"` Level string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*AgentLog) Descriptor
deprecated
func (*AgentLog) GetComputationId ¶
func (*AgentLog) GetMessage ¶
func (*AgentLog) GetTimestamp ¶
func (x *AgentLog) GetTimestamp() *timestamppb.Timestamp
func (*AgentLog) ProtoMessage ¶
func (*AgentLog) ProtoMessage()
func (*AgentLog) ProtoReflect ¶
func (x *AgentLog) ProtoReflect() protoreflect.Message
type Algorithm ¶
type Algorithm struct { Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*Algorithm) Descriptor
deprecated
func (*Algorithm) GetProvider ¶
func (*Algorithm) ProtoMessage ¶
func (*Algorithm) ProtoMessage()
func (*Algorithm) ProtoReflect ¶
func (x *Algorithm) ProtoReflect() protoreflect.Message
type ClientStreamMessage ¶
type ClientStreamMessage struct { // Types that are assignable to Message: // // *ClientStreamMessage_Whoami // *ClientStreamMessage_AgentLog // *ClientStreamMessage_AgentEvent // *ClientStreamMessage_RunRes Message isClientStreamMessage_Message `protobuf_oneof:"message"` // contains filtered or unexported fields }
func (*ClientStreamMessage) Descriptor
deprecated
func (*ClientStreamMessage) Descriptor() ([]byte, []int)
Deprecated: Use ClientStreamMessage.ProtoReflect.Descriptor instead.
func (*ClientStreamMessage) GetAgentEvent ¶
func (x *ClientStreamMessage) GetAgentEvent() *AgentEvent
func (*ClientStreamMessage) GetAgentLog ¶
func (x *ClientStreamMessage) GetAgentLog() *AgentLog
func (*ClientStreamMessage) GetMessage ¶
func (m *ClientStreamMessage) GetMessage() isClientStreamMessage_Message
func (*ClientStreamMessage) GetRunRes ¶
func (x *ClientStreamMessage) GetRunRes() *RunResponse
func (*ClientStreamMessage) GetWhoami ¶
func (x *ClientStreamMessage) GetWhoami() *WhoAmI
func (*ClientStreamMessage) ProtoMessage ¶
func (*ClientStreamMessage) ProtoMessage()
func (*ClientStreamMessage) ProtoReflect ¶
func (x *ClientStreamMessage) ProtoReflect() protoreflect.Message
func (*ClientStreamMessage) Reset ¶
func (x *ClientStreamMessage) Reset()
func (*ClientStreamMessage) String ¶
func (x *ClientStreamMessage) String() string
type ClientStreamMessage_AgentEvent ¶
type ClientStreamMessage_AgentEvent struct {
AgentEvent *AgentEvent `protobuf:"bytes,3,opt,name=agent_event,json=agentEvent,proto3,oneof"`
}
type ClientStreamMessage_AgentLog ¶
type ClientStreamMessage_AgentLog struct {
AgentLog *AgentLog `protobuf:"bytes,2,opt,name=agent_log,json=agentLog,proto3,oneof"`
}
type ClientStreamMessage_RunRes ¶
type ClientStreamMessage_RunRes struct {
RunRes *RunResponse `protobuf:"bytes,4,opt,name=run_res,json=runRes,proto3,oneof"`
}
type ClientStreamMessage_Whoami ¶
type ClientStreamMessage_Whoami struct {
Whoami *WhoAmI `protobuf:"bytes,1,opt,name=whoami,proto3,oneof"`
}
type ComputationRunReq ¶
type ComputationRunReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Datasets []*Dataset `protobuf:"bytes,4,rep,name=datasets,proto3" json:"datasets,omitempty"` Algorithms []*Algorithm `protobuf:"bytes,5,rep,name=algorithms,proto3" json:"algorithms,omitempty"` ResultConsumers []string `protobuf:"bytes,6,rep,name=result_consumers,json=resultConsumers,proto3" json:"result_consumers,omitempty"` AgentConfig *AgentConfig `protobuf:"bytes,7,opt,name=agent_config,json=agentConfig,proto3" json:"agent_config,omitempty"` // contains filtered or unexported fields }
func (*ComputationRunReq) Descriptor
deprecated
func (*ComputationRunReq) Descriptor() ([]byte, []int)
Deprecated: Use ComputationRunReq.ProtoReflect.Descriptor instead.
func (*ComputationRunReq) GetAgentConfig ¶
func (x *ComputationRunReq) GetAgentConfig() *AgentConfig
func (*ComputationRunReq) GetAlgorithms ¶
func (x *ComputationRunReq) GetAlgorithms() []*Algorithm
func (*ComputationRunReq) GetDatasets ¶
func (x *ComputationRunReq) GetDatasets() []*Dataset
func (*ComputationRunReq) GetDescription ¶
func (x *ComputationRunReq) GetDescription() string
func (*ComputationRunReq) GetId ¶
func (x *ComputationRunReq) GetId() string
func (*ComputationRunReq) GetName ¶
func (x *ComputationRunReq) GetName() string
func (*ComputationRunReq) GetResultConsumers ¶
func (x *ComputationRunReq) GetResultConsumers() []string
func (*ComputationRunReq) ProtoMessage ¶
func (*ComputationRunReq) ProtoMessage()
func (*ComputationRunReq) ProtoReflect ¶
func (x *ComputationRunReq) ProtoReflect() protoreflect.Message
func (*ComputationRunReq) Reset ¶
func (x *ComputationRunReq) Reset()
func (*ComputationRunReq) String ¶
func (x *ComputationRunReq) String() string
type Dataset ¶
type Dataset struct { Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*Dataset) Descriptor
deprecated
func (*Dataset) GetProvider ¶
func (*Dataset) ProtoMessage ¶
func (*Dataset) ProtoMessage()
func (*Dataset) ProtoReflect ¶
func (x *Dataset) ProtoReflect() protoreflect.Message
type ManagerServiceClient ¶
type ManagerServiceClient interface {
Process(ctx context.Context, opts ...grpc.CallOption) (ManagerService_ProcessClient, error)
}
ManagerServiceClient is the client API for ManagerService 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 NewManagerServiceClient ¶
func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient
type ManagerServiceServer ¶
type ManagerServiceServer interface { Process(ManagerService_ProcessServer) error // contains filtered or unexported methods }
ManagerServiceServer is the server API for ManagerService service. All implementations must embed UnimplementedManagerServiceServer for forward compatibility
type ManagerService_ProcessClient ¶
type ManagerService_ProcessClient interface { Send(*ClientStreamMessage) error Recv() (*ComputationRunReq, error) grpc.ClientStream }
type ManagerService_ProcessServer ¶
type ManagerService_ProcessServer interface { Send(*ComputationRunReq) error Recv() (*ClientStreamMessage, error) grpc.ServerStream }
type RunResponse ¶
type RunResponse struct { AgentPort string `protobuf:"bytes,1,opt,name=agent_port,json=agentPort,proto3" json:"agent_port,omitempty"` ComputationId string `protobuf:"bytes,2,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"` // contains filtered or unexported fields }
func (*RunResponse) Descriptor
deprecated
func (*RunResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.
func (*RunResponse) GetAgentPort ¶
func (x *RunResponse) GetAgentPort() string
func (*RunResponse) GetComputationId ¶
func (x *RunResponse) GetComputationId() string
func (*RunResponse) ProtoMessage ¶
func (*RunResponse) ProtoMessage()
func (*RunResponse) ProtoReflect ¶
func (x *RunResponse) ProtoReflect() protoreflect.Message
func (*RunResponse) Reset ¶
func (x *RunResponse) Reset()
func (*RunResponse) String ¶
func (x *RunResponse) String() string
type UnimplementedManagerServiceServer ¶
type UnimplementedManagerServiceServer struct { }
UnimplementedManagerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedManagerServiceServer) Process ¶
func (UnimplementedManagerServiceServer) Process(ManagerService_ProcessServer) error
type UnsafeManagerServiceServer ¶
type UnsafeManagerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServiceServer will result in compilation errors.
type WhoAmI ¶
type WhoAmI struct {
// contains filtered or unexported fields
}
func (*WhoAmI) Descriptor
deprecated
func (*WhoAmI) ProtoMessage ¶
func (*WhoAmI) ProtoMessage()
func (*WhoAmI) ProtoReflect ¶
func (x *WhoAmI) ProtoReflect() protoreflect.Message