manager

package

Go to main page

Versions in this module

v0

v0.4.0

Dec 6, 2024

Changes in this version

+ type ManagerState uint8

+ const StopComputationRun

+ const VmProvision

+ const VmRunning

+ func (i ManagerState) String() string

+ type ManagerStatus uint8

+ const Disconnected

+ const Failed

+ const Starting

+ const Stopped

+ const Warning

+ func (i ManagerStatus) String() string

v0.3.1

Aug 26, 2024

v0.3.0

Aug 23, 2024

Changes in this version

+ type BackendInfo struct

+ Id string

+ Info []byte

+ func (*BackendInfo) Descriptor() ([]byte, []int)

+ func (*BackendInfo) ProtoMessage()

+ func (x *BackendInfo) GetId() string

+ func (x *BackendInfo) GetInfo() []byte

+ func (x *BackendInfo) ProtoReflect() protoreflect.Message

+ func (x *BackendInfo) Reset()

+ func (x *BackendInfo) String() string

+ type BackendInfoReq struct

+ Id string

+ func (*BackendInfoReq) Descriptor() ([]byte, []int)

+ func (*BackendInfoReq) ProtoMessage()

+ func (x *BackendInfoReq) GetId() string

+ func (x *BackendInfoReq) ProtoReflect() protoreflect.Message

+ func (x *BackendInfoReq) Reset()

+ func (x *BackendInfoReq) String() string

type ClientStreamMessage

+ func (x *ClientStreamMessage) GetBackendInfo() *BackendInfo

+ func (x *ClientStreamMessage) GetStopComputationRes() *StopComputationResponse

+ type ClientStreamMessage_BackendInfo struct

+ BackendInfo *BackendInfo

+ type ClientStreamMessage_StopComputationRes struct

+ StopComputationRes *StopComputationResponse

type Dataset

+ Filename string

+ func (x *Dataset) GetFilename() string

+ type RunReqChunks struct

+ Data []byte

+ func (*RunReqChunks) Descriptor() ([]byte, []int)

+ func (*RunReqChunks) ProtoMessage()

+ func (x *RunReqChunks) GetData() []byte

+ func (x *RunReqChunks) ProtoReflect() protoreflect.Message

+ func (x *RunReqChunks) Reset()

+ func (x *RunReqChunks) String() string

type ServerStreamMessage

+ func (x *ServerStreamMessage) GetBackendInfoReq() *BackendInfoReq

+ func (x *ServerStreamMessage) GetRunReqChunks() *RunReqChunks

+ type ServerStreamMessage_BackendInfoReq struct

+ BackendInfoReq *BackendInfoReq

+ type ServerStreamMessage_RunReqChunks struct

+ RunReqChunks *RunReqChunks

+ type StopComputationResponse struct

+ ComputationId string

+ Message string

+ func (*StopComputationResponse) Descriptor() ([]byte, []int)

+ func (*StopComputationResponse) ProtoMessage()

+ func (x *StopComputationResponse) GetComputationId() string

+ func (x *StopComputationResponse) GetMessage() string

+ func (x *StopComputationResponse) ProtoReflect() protoreflect.Message

+ func (x *StopComputationResponse) Reset()

+ func (x *StopComputationResponse) String() string

v0.2.0

Jul 31, 2024

Changes in this version

type Algorithm

+ UserKey []byte

+ func (x *Algorithm) GetUserKey() []byte

type Dataset

+ UserKey []byte

+ func (x *Dataset) GetUserKey() []byte

+ type ResultConsumer struct

+ UserKey []byte

+ func (*ResultConsumer) Descriptor() ([]byte, []int)

+ func (*ResultConsumer) ProtoMessage()

+ func (x *ResultConsumer) GetUserKey() []byte

+ func (x *ResultConsumer) ProtoReflect() protoreflect.Message

+ func (x *ResultConsumer) Reset()

+ func (x *ResultConsumer) String() string

+ type ServerStreamMessage struct

+ Message isServerStreamMessage_Message

+ func (*ServerStreamMessage) Descriptor() ([]byte, []int)

+ func (*ServerStreamMessage) ProtoMessage()

+ func (m *ServerStreamMessage) GetMessage() isServerStreamMessage_Message

+ func (x *ServerStreamMessage) GetRunReq() *ComputationRunReq

+ func (x *ServerStreamMessage) GetStopComputation() *StopComputation

+ func (x *ServerStreamMessage) GetTerminateReq() *Terminate

+ func (x *ServerStreamMessage) ProtoReflect() protoreflect.Message

+ func (x *ServerStreamMessage) Reset()

+ func (x *ServerStreamMessage) String() string

+ type ServerStreamMessage_RunReq struct

+ RunReq *ComputationRunReq

+ type ServerStreamMessage_StopComputation struct

+ StopComputation *StopComputation

+ type ServerStreamMessage_TerminateReq struct

+ TerminateReq *Terminate

+ type StopComputation struct

+ ComputationId string

+ func (*StopComputation) Descriptor() ([]byte, []int)

+ func (*StopComputation) ProtoMessage()

+ func (x *StopComputation) GetComputationId() string

+ func (x *StopComputation) ProtoReflect() protoreflect.Message

+ func (x *StopComputation) Reset()

+ func (x *StopComputation) String() string

+ type Terminate struct

+ Message string

+ func (*Terminate) Descriptor() ([]byte, []int)

+ func (*Terminate) ProtoMessage()

+ func (x *Terminate) GetMessage() string

+ func (x *Terminate) ProtoReflect() protoreflect.Message

+ func (x *Terminate) Reset()

+ func (x *Terminate) String() string

v0.1.0

Apr 17, 2024

Changes in this version

type AgentConfig

+ AttestedTls bool

+ func (x *AgentConfig) GetAttestedTls() bool

type ComputationRunReq

+ Algorithm *Algorithm

+ func (x *ComputationRunReq) GetAlgorithm() *Algorithm

v0.0.2

Mar 15, 2024

Changes in this version

+ const ManagerService_Process_FullMethodName

+ var File_manager_manager_proto protoreflect.FileDescriptor

+ var ManagerService_ServiceDesc = grpc.ServiceDesc

+ func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)

+ type AgentConfig struct

+ CertFile string

+ ClientCaFile string

+ Host string

+ KeyFile string

+ LogLevel string

+ Port string

+ ServerCaFile string

+ func (*AgentConfig) Descriptor() ([]byte, []int)

+ func (*AgentConfig) ProtoMessage()

+ 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 (x *AgentConfig) ProtoReflect() protoreflect.Message

+ func (x *AgentConfig) Reset()

+ func (x *AgentConfig) String() string

+ type AgentEvent struct

+ ComputationId string

+ Details []byte

+ EventType string

+ Originator string

+ Status string

+ Timestamp *timestamppb.Timestamp

+ func (*AgentEvent) Descriptor() ([]byte, []int)

+ func (*AgentEvent) ProtoMessage()

+ 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 (x *AgentEvent) ProtoReflect() protoreflect.Message

+ func (x *AgentEvent) Reset()

+ func (x *AgentEvent) String() string

+ type AgentLog struct

+ ComputationId string

+ Level string

+ Message string

+ Timestamp *timestamppb.Timestamp

+ func (*AgentLog) Descriptor() ([]byte, []int)

+ func (*AgentLog) ProtoMessage()

+ func (x *AgentLog) GetComputationId() string

+ func (x *AgentLog) GetLevel() string

+ func (x *AgentLog) GetMessage() string

+ func (x *AgentLog) GetTimestamp() *timestamppb.Timestamp

+ func (x *AgentLog) ProtoReflect() protoreflect.Message

+ func (x *AgentLog) Reset()

+ func (x *AgentLog) String() string

+ type Algorithm struct

+ Hash []byte

+ Id string

+ Provider string

+ func (*Algorithm) Descriptor() ([]byte, []int)

+ func (*Algorithm) ProtoMessage()

+ func (x *Algorithm) GetHash() []byte

+ func (x *Algorithm) GetId() string

+ func (x *Algorithm) GetProvider() string

+ func (x *Algorithm) ProtoReflect() protoreflect.Message

+ func (x *Algorithm) Reset()

+ func (x *Algorithm) String() string

+ type ClientStreamMessage struct

+ Message isClientStreamMessage_Message

+ func (*ClientStreamMessage) Descriptor() ([]byte, []int)

+ func (*ClientStreamMessage) ProtoMessage()

+ func (m *ClientStreamMessage) GetMessage() isClientStreamMessage_Message

+ func (x *ClientStreamMessage) GetAgentEvent() *AgentEvent

+ func (x *ClientStreamMessage) GetAgentLog() *AgentLog

+ func (x *ClientStreamMessage) GetRunRes() *RunResponse

+ func (x *ClientStreamMessage) GetWhoami() *WhoAmI

+ func (x *ClientStreamMessage) ProtoReflect() protoreflect.Message

+ func (x *ClientStreamMessage) Reset()

+ func (x *ClientStreamMessage) String() string

+ type ClientStreamMessage_AgentEvent struct

+ AgentEvent *AgentEvent

+ type ClientStreamMessage_AgentLog struct

+ AgentLog *AgentLog

+ type ClientStreamMessage_RunRes struct

+ RunRes *RunResponse

+ type ClientStreamMessage_Whoami struct

+ Whoami *WhoAmI

+ type ComputationRunReq struct

+ AgentConfig *AgentConfig

+ Algorithms []*Algorithm

+ Datasets []*Dataset

+ Description string

+ Id string

+ Name string

+ ResultConsumers []string

+ func (*ComputationRunReq) Descriptor() ([]byte, []int)

+ func (*ComputationRunReq) ProtoMessage()

+ 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 (x *ComputationRunReq) ProtoReflect() protoreflect.Message

+ func (x *ComputationRunReq) Reset()

+ func (x *ComputationRunReq) String() string

+ type Dataset struct

+ Hash []byte

+ Id string

+ Provider string

+ func (*Dataset) Descriptor() ([]byte, []int)

+ func (*Dataset) ProtoMessage()

+ func (x *Dataset) GetHash() []byte

+ func (x *Dataset) GetId() string

+ func (x *Dataset) GetProvider() string

+ func (x *Dataset) ProtoReflect() protoreflect.Message

+ func (x *Dataset) Reset()

+ func (x *Dataset) String() string

+ type ManagerServiceClient interface

+ Process func(ctx context.Context, opts ...grpc.CallOption) (ManagerService_ProcessClient, error)

+ func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient

+ type ManagerServiceServer interface

+ Process func(ManagerService_ProcessServer) error

+ type ManagerService_ProcessClient interface

+ Recv func() (*ComputationRunReq, error)

+ Send func(*ClientStreamMessage) error

+ type ManagerService_ProcessServer interface

+ Recv func() (*ClientStreamMessage, error)

+ Send func(*ComputationRunReq) error

+ type RunResponse struct

+ AgentPort string

+ ComputationId string

+ func (*RunResponse) Descriptor() ([]byte, []int)

+ func (*RunResponse) ProtoMessage()

+ func (x *RunResponse) GetAgentPort() string

+ func (x *RunResponse) GetComputationId() string

+ func (x *RunResponse) ProtoReflect() protoreflect.Message

+ func (x *RunResponse) Reset()

+ func (x *RunResponse) String() string

+ type UnimplementedManagerServiceServer struct

+ func (UnimplementedManagerServiceServer) Process(ManagerService_ProcessServer) error

+ type UnsafeManagerServiceServer interface

+ type WhoAmI struct

+ func (*WhoAmI) Descriptor() ([]byte, []int)

+ func (*WhoAmI) ProtoMessage()

+ func (x *WhoAmI) ProtoReflect() protoreflect.Message

+ func (x *WhoAmI) Reset()

+ func (x *WhoAmI) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL