cvms

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Service_Process_FullMethodName = "/cvms.Service/Process"
)

Variables

View Source 
var File_agent_cvms_cvms_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cvms.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Process",
			Handler:       _Service_Process_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent/cvms/cvms.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

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 

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 AgentStateReq 

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

func (*AgentStateReq) Descriptor deprecated 

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

Deprecated: Use AgentStateReq.ProtoReflect.Descriptor instead.

func (*AgentStateReq) GetId 

func (x *AgentStateReq) GetId() string

func (*AgentStateReq) ProtoMessage 

func (*AgentStateReq) ProtoMessage()

func (*AgentStateReq) ProtoReflect 

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

func (*AgentStateReq) Reset 

func (x *AgentStateReq) Reset()

func (*AgentStateReq) String 

func (x *AgentStateReq) String() string

type AgentStateRes 

type AgentStateRes struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentStateRes) Descriptor deprecated 

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

Deprecated: Use AgentStateRes.ProtoReflect.Descriptor instead.

func (*AgentStateRes) GetId 

func (x *AgentStateRes) GetId() string

func (*AgentStateRes) GetState 

func (x *AgentStateRes) GetState() string

func (*AgentStateRes) ProtoMessage 

func (*AgentStateRes) ProtoMessage()

func (*AgentStateRes) ProtoReflect 

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

func (*AgentStateRes) Reset 

func (x *AgentStateRes) Reset()

func (*AgentStateRes) String 

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

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 valid to be assigned to Message:
	//
	//	*ClientStreamMessage_AgentLog
	//	*ClientStreamMessage_AgentEvent
	//	*ClientStreamMessage_RunRes
	//	*ClientStreamMessage_StopComputationRes
	//	*ClientStreamMessage_AgentStateRes
	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) GetAgentStateRes 

func (x *ClientStreamMessage) GetAgentStateRes() *AgentStateRes

func (*ClientStreamMessage) GetMessage 

func (x *ClientStreamMessage) GetMessage() isClientStreamMessage_Message

func (*ClientStreamMessage) GetRunRes 

func (x *ClientStreamMessage) GetRunRes() *RunResponse

func (*ClientStreamMessage) GetStopComputationRes 

func (x *ClientStreamMessage) GetStopComputationRes() *StopComputationResponse

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_AgentStateRes 

type ClientStreamMessage_AgentStateRes struct {
	AgentStateRes *AgentStateRes `protobuf:"bytes,5,opt,name=agentStateRes,proto3,oneof"`
}

type ClientStreamMessage_RunRes 

type ClientStreamMessage_RunRes struct {
	RunRes *RunResponse `protobuf:"bytes,3,opt,name=run_res,json=runRes,proto3,oneof"`
}

type ClientStreamMessage_StopComputationRes 

type ClientStreamMessage_StopComputationRes struct {
	StopComputationRes *StopComputationResponse `protobuf:"bytes,4,opt,name=stopComputationRes,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 

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"`
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetFilename 

func (x *Dataset) GetFilename() string

func (*Dataset) GetHash 

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

func (*Dataset) GetUserKey 

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 ResultConsumer 

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

func (*ResultConsumer) Descriptor deprecated 

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

Deprecated: Use ResultConsumer.ProtoReflect.Descriptor instead.

func (*ResultConsumer) GetUserKey 

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

func (*ResultConsumer) ProtoMessage 

func (*ResultConsumer) ProtoMessage()

func (*ResultConsumer) ProtoReflect 

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

func (*ResultConsumer) Reset 

func (x *ResultConsumer) Reset()

func (*ResultConsumer) String 

func (x *ResultConsumer) String() string

type RunReqChunks 

type RunReqChunks struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	IsLast bool   `protobuf:"varint,3,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	// contains filtered or unexported fields
}

func (*RunReqChunks) Descriptor deprecated 

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

Deprecated: Use RunReqChunks.ProtoReflect.Descriptor instead.

func (*RunReqChunks) GetData 

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

func (*RunReqChunks) GetId 

func (x *RunReqChunks) GetId() string

func (*RunReqChunks) GetIsLast 

func (x *RunReqChunks) GetIsLast() bool

func (*RunReqChunks) ProtoMessage 

func (*RunReqChunks) ProtoMessage()

func (*RunReqChunks) ProtoReflect 

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

func (*RunReqChunks) Reset 

func (x *RunReqChunks) Reset()

func (*RunReqChunks) String 

func (x *RunReqChunks) String() string

type RunResponse 

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

func (*RunResponse) Descriptor deprecated 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetComputationId 

func (x *RunResponse) GetComputationId() string

func (*RunResponse) GetError 

func (x *RunResponse) GetError() 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 

type ServerStreamMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*ServerStreamMessage_RunReqChunks
	//	*ServerStreamMessage_RunReq
	//	*ServerStreamMessage_StopComputation
	//	*ServerStreamMessage_AgentStateReq
	Message isServerStreamMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*ServerStreamMessage) Descriptor deprecated 

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

Deprecated: Use ServerStreamMessage.ProtoReflect.Descriptor instead.

func (*ServerStreamMessage) GetAgentStateReq 

func (x *ServerStreamMessage) GetAgentStateReq() *AgentStateReq

func (*ServerStreamMessage) GetMessage 

func (x *ServerStreamMessage) GetMessage() isServerStreamMessage_Message

func (*ServerStreamMessage) GetRunReq 

func (x *ServerStreamMessage) GetRunReq() *ComputationRunReq

func (*ServerStreamMessage) GetRunReqChunks 

func (x *ServerStreamMessage) GetRunReqChunks() *RunReqChunks

func (*ServerStreamMessage) GetStopComputation 

func (x *ServerStreamMessage) GetStopComputation() *StopComputation

func (*ServerStreamMessage) ProtoMessage 

func (*ServerStreamMessage) ProtoMessage()

func (*ServerStreamMessage) ProtoReflect 

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

func (*ServerStreamMessage) Reset 

func (x *ServerStreamMessage) Reset()

func (*ServerStreamMessage) String 

func (x *ServerStreamMessage) String() string

type ServerStreamMessage_AgentStateReq 

type ServerStreamMessage_AgentStateReq struct {
	AgentStateReq *AgentStateReq `protobuf:"bytes,4,opt,name=agentStateReq,proto3,oneof"`
}

type ServerStreamMessage_RunReq 

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

type ServerStreamMessage_RunReqChunks 

type ServerStreamMessage_RunReqChunks struct {
	RunReqChunks *RunReqChunks `protobuf:"bytes,1,opt,name=runReqChunks,proto3,oneof"`
}

type ServerStreamMessage_StopComputation 

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

type ServiceClient 

type ServiceClient interface {
	Process(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClientStreamMessage, ServerStreamMessage], error)
}

ServiceClient is the client API for Service 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 NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	Process(grpc.BidiStreamingServer[ClientStreamMessage, ServerStreamMessage]) error
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility.

type Service_ProcessClient 

type Service_ProcessClient = grpc.BidiStreamingClient[ClientStreamMessage, ServerStreamMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Service_ProcessServer 

type Service_ProcessServer = grpc.BidiStreamingServer[ClientStreamMessage, ServerStreamMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StopComputation 

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 

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

Deprecated: Use StopComputation.ProtoReflect.Descriptor instead.

func (*StopComputation) GetComputationId 

func (x *StopComputation) GetComputationId() string

func (*StopComputation) ProtoMessage 

func (*StopComputation) ProtoMessage()

func (*StopComputation) ProtoReflect 

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

func (*StopComputation) Reset 

func (x *StopComputation) Reset()

func (*StopComputation) String 

func (x *StopComputation) String() string

type StopComputationResponse 

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

func (*StopComputationResponse) Descriptor deprecated 

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

Deprecated: Use StopComputationResponse.ProtoReflect.Descriptor instead.

func (*StopComputationResponse) GetComputationId 

func (x *StopComputationResponse) GetComputationId() string

func (*StopComputationResponse) GetMessage 

func (x *StopComputationResponse) GetMessage() string

func (*StopComputationResponse) ProtoMessage 

func (*StopComputationResponse) ProtoMessage()

func (*StopComputationResponse) ProtoReflect 

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

func (*StopComputationResponse) Reset 

func (x *StopComputationResponse) Reset()

func (*StopComputationResponse) String 

func (x *StopComputationResponse) String() string

type UnimplementedServiceServer 

type UnimplementedServiceServer struct{}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedServiceServer) Process 

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

type UnsafeServiceServer 

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis
api
grpc
grpc/storage
grpc/storage/mocks
mocks

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.