manager

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ManagerService_Process_FullMethodName = "/manager.ManagerService/Process"
)

Variables

View Source 
var File_manager_manager_proto protoreflect.FileDescriptor
View Source 
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"`
	AttestedTls  bool   `protobuf:"varint,8,opt,name=attested_tls,json=attestedTls,proto3" json:"attested_tls,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentConfig) Descriptor deprecated 

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

Deprecated: Use AgentConfig.ProtoReflect.Descriptor instead.

func (*AgentConfig) GetAttestedTls added in v0.1.0 

func (x *AgentConfig) GetAttestedTls() bool

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) Descriptor() ([]byte, []int)

Deprecated: Use AgentLog.ProtoReflect.Descriptor instead.

func (*AgentLog) GetComputationId 

func (x *AgentLog) GetComputationId() string

func (*AgentLog) GetLevel 

func (x *AgentLog) GetLevel() string

func (*AgentLog) GetMessage 

func (x *AgentLog) GetMessage() string

func (*AgentLog) GetTimestamp 

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

func (*AgentLog) ProtoMessage 

func (*AgentLog) ProtoMessage()

func (*AgentLog) ProtoReflect 

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

func (*AgentLog) Reset 

func (x *AgentLog) Reset()

func (*AgentLog) String 

func (x *AgentLog) String() string

type Algorithm 

type Algorithm struct {
	Hash    []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // should be sha3.Sum256, 32 byte length.
	UserKey []byte `protobuf:"bytes,2,opt,name=userKey,proto3" json:"userKey,omitempty"`
	// contains filtered or unexported fields
}

func (*Algorithm) Descriptor deprecated 

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

Deprecated: Use Algorithm.ProtoReflect.Descriptor instead.

func (*Algorithm) GetHash 

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

func (*Algorithm) GetUserKey added in v0.2.0 

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

func (*Algorithm) ProtoMessage 

func (*Algorithm) ProtoMessage()

func (*Algorithm) ProtoReflect 

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

func (*Algorithm) Reset 

func (x *Algorithm) Reset()

func (*Algorithm) String 

func (x *Algorithm) String() string

type ClientStreamMessage 

type ClientStreamMessage struct {

	// Types that are assignable to Message:
	//
	//	*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) 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,2,opt,name=agent_event,json=agentEvent,proto3,oneof"`
}

type ClientStreamMessage_AgentLog 

type ClientStreamMessage_AgentLog struct {
	AgentLog *AgentLog `protobuf:"bytes,1,opt,name=agent_log,json=agentLog,proto3,oneof"`
}

type ClientStreamMessage_RunRes 

type ClientStreamMessage_RunRes struct {
	RunRes *RunResponse `protobuf:"bytes,3,opt,name=run_res,json=runRes,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"`
	Algorithm       *Algorithm        `protobuf:"bytes,5,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	ResultConsumers []*ResultConsumer `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) GetAlgorithm added in v0.1.0 

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

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 {
	Hash    []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // should be sha3.Sum256, 32 byte length.
	UserKey []byte `protobuf:"bytes,2,opt,name=userKey,proto3" json:"userKey,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetHash 

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

func (*Dataset) GetUserKey added in v0.2.0 

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

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect 

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

func (*Dataset) Reset 

func (x *Dataset) Reset()

func (*Dataset) String 

func (x *Dataset) String() string

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() (*ServerStreamMessage, error)
	grpc.ClientStream
}

type ManagerService_ProcessServer 

type ManagerService_ProcessServer interface {
	Send(*ServerStreamMessage) error
	Recv() (*ClientStreamMessage, error)
	grpc.ServerStream
}

type ResultConsumer added in v0.2.0 

type ResultConsumer struct {
	UserKey []byte `protobuf:"bytes,1,opt,name=userKey,proto3" json:"userKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultConsumer) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ResultConsumer.ProtoReflect.Descriptor instead.

func (*ResultConsumer) GetUserKey added in v0.2.0 

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

func (*ResultConsumer) ProtoMessage added in v0.2.0 

func (*ResultConsumer) ProtoMessage()

func (*ResultConsumer) ProtoReflect added in v0.2.0 

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

func (*ResultConsumer) Reset added in v0.2.0 

func (x *ResultConsumer) Reset()

func (*ResultConsumer) String added in v0.2.0 

func (x *ResultConsumer) String() string

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 ServerStreamMessage added in v0.2.0 

type ServerStreamMessage struct {

	// Types that are assignable to Message:
	//
	//	*ServerStreamMessage_RunReq
	//	*ServerStreamMessage_TerminateReq
	//	*ServerStreamMessage_StopComputation
	Message isServerStreamMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*ServerStreamMessage) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ServerStreamMessage.ProtoReflect.Descriptor instead.

func (*ServerStreamMessage) GetMessage added in v0.2.0 

func (m *ServerStreamMessage) GetMessage() isServerStreamMessage_Message

func (*ServerStreamMessage) GetRunReq added in v0.2.0 

func (x *ServerStreamMessage) GetRunReq() *ComputationRunReq

func (*ServerStreamMessage) GetStopComputation added in v0.2.0 

func (x *ServerStreamMessage) GetStopComputation() *StopComputation

func (*ServerStreamMessage) GetTerminateReq added in v0.2.0 

func (x *ServerStreamMessage) GetTerminateReq() *Terminate

func (*ServerStreamMessage) ProtoMessage added in v0.2.0 

func (*ServerStreamMessage) ProtoMessage()

func (*ServerStreamMessage) ProtoReflect added in v0.2.0 

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

func (*ServerStreamMessage) Reset added in v0.2.0 

func (x *ServerStreamMessage) Reset()

func (*ServerStreamMessage) String added in v0.2.0 

func (x *ServerStreamMessage) String() string

type ServerStreamMessage_RunReq added in v0.2.0 

type ServerStreamMessage_RunReq struct {
	RunReq *ComputationRunReq `protobuf:"bytes,1,opt,name=runReq,proto3,oneof"`
}

type ServerStreamMessage_StopComputation added in v0.2.0 

type ServerStreamMessage_StopComputation struct {
	StopComputation *StopComputation `protobuf:"bytes,3,opt,name=stopComputation,proto3,oneof"`
}

type ServerStreamMessage_TerminateReq added in v0.2.0 

type ServerStreamMessage_TerminateReq struct {
	TerminateReq *Terminate `protobuf:"bytes,2,opt,name=terminateReq,proto3,oneof"`
}

type StopComputation added in v0.2.0 

type StopComputation struct {
	ComputationId string `protobuf:"bytes,1,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopComputation) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use StopComputation.ProtoReflect.Descriptor instead.

func (*StopComputation) GetComputationId added in v0.2.0 

func (x *StopComputation) GetComputationId() string

func (*StopComputation) ProtoMessage added in v0.2.0 

func (*StopComputation) ProtoMessage()

func (*StopComputation) ProtoReflect added in v0.2.0 

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

func (*StopComputation) Reset added in v0.2.0 

func (x *StopComputation) Reset()

func (*StopComputation) String added in v0.2.0 

func (x *StopComputation) String() string

type Terminate added in v0.2.0 

type Terminate struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Terminate) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Terminate.ProtoReflect.Descriptor instead.

func (*Terminate) GetMessage added in v0.2.0 

func (x *Terminate) GetMessage() string

func (*Terminate) ProtoMessage added in v0.2.0 

func (*Terminate) ProtoMessage()

func (*Terminate) ProtoReflect added in v0.2.0 

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

func (*Terminate) Reset added in v0.2.0 

func (x *Terminate) Reset()

func (*Terminate) String added in v0.2.0 

func (x *Terminate) 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.