manager

package

Go to main page

Versions in this module

v0

v0.4.0

Dec 6, 2024

Changes in this version

+ const ManagerService_Process_FullMethodName

+ type AgentConfig struct

+ AttestedTls bool

+ 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) GetAttestedTls() bool

+ 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

+ Hash []byte

+ UserKey []byte

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

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

+ type AttestationPolicy struct

+ Id string

+ Info []byte

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

+ func (*AttestationPolicy) ProtoMessage()

+ func (x *AttestationPolicy) GetId() string

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

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

+ func (x *AttestationPolicy) Reset()

+ func (x *AttestationPolicy) String() string

+ type AttestationPolicyReq struct

+ Id string

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

+ func (*AttestationPolicyReq) ProtoMessage()

+ func (x *AttestationPolicyReq) GetId() string

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

+ func (x *AttestationPolicyReq) Reset()

+ func (x *AttestationPolicyReq) 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) GetAttestationPolicy() *AttestationPolicy

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

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

+ func (x *ClientStreamMessage) GetSvmInfo() *SVMInfo

+ 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_AttestationPolicy struct

+ AttestationPolicy *AttestationPolicy

+ type ClientStreamMessage_RunRes struct

+ RunRes *RunResponse

+ type ClientStreamMessage_StopComputationRes struct

+ StopComputationRes *StopComputationResponse

+ type ClientStreamMessage_SvmInfo struct

+ SvmInfo *SVMInfo

+ type ComputationRunReq struct

+ AgentConfig *AgentConfig

+ Algorithm *Algorithm

+ Datasets []*Dataset

+ Description string

+ Id string

+ Name string

+ ResultConsumers []*ResultConsumer

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

+ func (*ComputationRunReq) ProtoMessage()

+ func (x *ComputationRunReq) GetAgentConfig() *AgentConfig

+ func (x *ComputationRunReq) GetAlgorithm() *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() []*ResultConsumer

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

+ func (x *ComputationRunReq) Reset()

+ func (x *ComputationRunReq) String() string

type Dataset

+ Filename string

+ Hash []byte

+ UserKey []byte

+ func (x *Dataset) GetFilename() string

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

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

type ManagerServiceClient

+ Process func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClientStreamMessage, ServerStreamMessage], error)

type ManagerServiceServer

+ Process func(grpc.BidiStreamingServer[ClientStreamMessage, ServerStreamMessage]) error

+ type ManagerService_ProcessClient = grpc.BidiStreamingClient[ClientStreamMessage, ServerStreamMessage]

+ type ManagerService_ProcessServer = grpc.BidiStreamingServer[ClientStreamMessage, ServerStreamMessage]

+ 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 RunReqChunks struct

+ Data []byte

+ Id string

+ IsLast bool

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

+ func (*RunReqChunks) ProtoMessage()

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

+ func (x *RunReqChunks) GetId() string

+ func (x *RunReqChunks) GetIsLast() bool

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

+ func (x *RunReqChunks) Reset()

+ func (x *RunReqChunks) String() string

type RunResponse

+ AgentPort string

+ ComputationId string

+ func (x *RunResponse) GetAgentPort() string

+ func (x *RunResponse) GetComputationId() string

+ type SVMInfo struct

+ CpuNum int32

+ CpuType string

+ EosVersion string

+ Id string

+ KernelCmd string

+ OvmfVersion string

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

+ func (*SVMInfo) ProtoMessage()

+ func (x *SVMInfo) GetCpuNum() int32

+ func (x *SVMInfo) GetCpuType() string

+ func (x *SVMInfo) GetEosVersion() string

+ func (x *SVMInfo) GetId() string

+ func (x *SVMInfo) GetKernelCmd() string

+ func (x *SVMInfo) GetOvmfVersion() string

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

+ func (x *SVMInfo) Reset()

+ func (x *SVMInfo) String() string

+ type SVMInfoReq struct

+ Id string

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

+ func (*SVMInfoReq) ProtoMessage()

+ func (x *SVMInfoReq) GetId() string

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

+ func (x *SVMInfoReq) Reset()

+ func (x *SVMInfoReq) 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) GetAttestationPolicyReq() *AttestationPolicyReq

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

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

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

+ func (x *ServerStreamMessage) GetSvmInfoReq() *SVMInfoReq

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

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

+ func (x *ServerStreamMessage) Reset()

+ func (x *ServerStreamMessage) String() string

+ type ServerStreamMessage_AttestationPolicyReq struct

+ AttestationPolicyReq *AttestationPolicyReq

+ type ServerStreamMessage_RunReq struct

+ RunReq *ComputationRunReq

+ type ServerStreamMessage_RunReqChunks struct

+ RunReqChunks *RunReqChunks

+ type ServerStreamMessage_StopComputation struct

+ StopComputation *StopComputation

+ type ServerStreamMessage_SvmInfoReq struct

+ SvmInfoReq *SVMInfoReq

+ type ServerStreamMessage_TerminateReq struct

+ TerminateReq *Terminate

type Service

+ FetchAttestationPolicy func(ctx context.Context, computationID string) ([]byte, error)

+ ReportBrokenConnection func(addr string)

+ ReturnSVMInfo func(ctx context.Context) (string, int, string, string)

+ 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 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

+ 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

type UnimplementedManagerServiceServer

+ func (UnimplementedManagerServiceServer) Process(grpc.BidiStreamingServer[ClientStreamMessage, ServerStreamMessage]) error

v0.3.1

Aug 26, 2024

v0.3.0

Aug 23, 2024

Changes in this version

type Service

+ FetchBackendInfo func() ([]byte, error)

v0.2.0

Jul 31, 2024

Changes in this version

+ var ErrFailedToCalculateHash = errors.New("error while calculating the hash of the computation")

type Service

+ Stop func(ctx context.Context, computationID string) error

v0.1.0

Apr 17, 2024

v0.0.2

Mar 15, 2024

Changes in this version

+ const ManagerVsockPort

+ const VsockConfigPort

+ func SendAgentConfig(cid uint32, ac agent.Computation) error

type Service

+ RetrieveAgentEventsLogs func()

v0.0.1

Jan 12, 2024

Changes in this version

+ const ManagerService_Run_FullMethodName

+ var ErrFailedToAllocatePort = errors.New("failed to allocate free port on host")

+ var ErrMalformedEntity = errors.New("malformed entity specification")

+ var ErrNotFound = errors.New("entity not found")

+ var ErrUnauthorizedAccess = errors.New("missing or invalid credentials provided")

+ var File_manager_manager_proto protoreflect.FileDescriptor

+ var ManagerService_ServiceDesc = grpc.ServiceDesc

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

+ type Algorithm struct

+ Id string

+ Provider string

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

+ func (*Algorithm) ProtoMessage()

+ 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 Computation struct

+ Algorithms []*Algorithm

+ Datasets []*Dataset

+ Description string

+ Id string

+ Name string

+ ResultConsumers []string

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

+ func (*Computation) ProtoMessage()

+ func (x *Computation) GetAlgorithms() []*Algorithm

+ func (x *Computation) GetDatasets() []*Dataset

+ func (x *Computation) GetDescription() string

+ func (x *Computation) GetId() string

+ func (x *Computation) GetName() string

+ func (x *Computation) GetResultConsumers() []string

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

+ func (x *Computation) Reset()

+ func (x *Computation) String() string

+ type Dataset struct

+ Id string

+ Provider string

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

+ func (*Dataset) ProtoMessage()

+ 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

+ Run func(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)

+ func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient

+ type ManagerServiceServer interface

+ Run func(context.Context, *RunRequest) (*RunResponse, error)

+ type RunRequest struct

+ Computation *Computation

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

+ func (*RunRequest) ProtoMessage()

+ func (x *RunRequest) GetComputation() *Computation

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

+ func (x *RunRequest) Reset()

+ func (x *RunRequest) String() string

+ type RunResponse struct

+ AgentAddress string

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

+ func (*RunResponse) ProtoMessage()

+ func (x *RunResponse) GetAgentAddress() string

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

+ func (x *RunResponse) Reset()

+ func (x *RunResponse) String() string

+ type Service interface

+ Run func(ctx context.Context, c *Computation) (string, error)

+ func New(qemuCfg qemu.Config, logger mglog.Logger, eventSvc events.Service, ...) Service

+ type UnimplementedManagerServiceServer struct

+ func (UnimplementedManagerServiceServer) Run(context.Context, *RunRequest) (*RunResponse, error)

+ type UnsafeManagerServiceServer interface

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