manager

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Mar 15, 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"`
	// 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) 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 {
	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) Descriptor() ([]byte, []int)

Deprecated: Use Algorithm.ProtoReflect.Descriptor instead.

func (*Algorithm) GetHash

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

func (*Algorithm) GetId

func (x *Algorithm) GetId() string

func (*Algorithm) GetProvider

func (x *Algorithm) GetProvider() string

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetHash

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

func (*Dataset) GetId

func (x *Dataset) GetId() string

func (*Dataset) GetProvider

func (x *Dataset) GetProvider() string

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.

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

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

Deprecated: Use WhoAmI.ProtoReflect.Descriptor instead.

func (*WhoAmI) ProtoMessage

func (*WhoAmI) ProtoMessage()

func (*WhoAmI) ProtoReflect

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

func (*WhoAmI) Reset

func (x *WhoAmI) Reset()

func (*WhoAmI) String

func (x *WhoAmI) String() string

Jump to

Keyboard shortcuts

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