pb

package
v0.0.0-...-9243632 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	Worker_GetServiceInfo_FullMethodName     = "/foreverbull.service.Worker/GetServiceInfo"
	Worker_ConfigureExecution_FullMethodName = "/foreverbull.service.Worker/ConfigureExecution"
	Worker_RunExecution_FullMethodName       = "/foreverbull.service.Worker/RunExecution"
)

Variables

View Source 
var (
	Instance_Status_Status_name = map[int32]string{
		0: "CREATED",
		1: "RUNNING",
		2: "CONFIGURED",
		3: "EXECUTING",
		4: "COMPLETED",
		5: "ERROR",
	}
	Instance_Status_Status_value = map[string]int32{
		"CREATED":    0,
		"RUNNING":    1,
		"CONFIGURED": 2,
		"EXECUTING":  3,
		"COMPLETED":  4,
		"ERROR":      5,
	}
)

Enum value maps for Instance_Status_Status.

View Source 
var (
	Service_Status_Status_name = map[int32]string{
		0: "CREATED",
		1: "INTERVIEW",
		2: "READY",
		3: "ERROR",
	}
	Service_Status_Status_value = map[string]int32{
		"CREATED":   0,
		"INTERVIEW": 1,
		"READY":     2,
		"ERROR":     3,
	}
)

Enum value maps for Service_Status_Status.

View Source 
var (
	NamespaceRequestType_name = map[int32]string{
		0: "GET",
		1: "SET",
	}
	NamespaceRequestType_value = map[string]int32{
		"GET": 0,
		"SET": 1,
	}
)

Enum value maps for NamespaceRequestType.

View Source 
var File_foreverbull_service_instance_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_service_service_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_service_worker_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_service_worker_service_proto protoreflect.FileDescriptor
View Source 
var Worker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "foreverbull.service.Worker",
	HandlerType: (*WorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetServiceInfo",
			Handler:    _Worker_GetServiceInfo_Handler,
		},
		{
			MethodName: "ConfigureExecution",
			Handler:    _Worker_ConfigureExecution_Handler,
		},
		{
			MethodName: "RunExecution",
			Handler:    _Worker_RunExecution_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "foreverbull/service/worker_service.proto",
}

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

Functions

func RegisterWorkerServer 

func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

Types

type Algorithm 

type Algorithm struct {
	FilePath   string                `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Functions  []*Algorithm_Function `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
	Namespaces []string              `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*Algorithm) Descriptor deprecated 

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

Deprecated: Use Algorithm.ProtoReflect.Descriptor instead.

func (*Algorithm) GetFilePath 

func (x *Algorithm) GetFilePath() string

func (*Algorithm) GetFunctions 

func (x *Algorithm) GetFunctions() []*Algorithm_Function

func (*Algorithm) GetNamespaces 

func (x *Algorithm) GetNamespaces() []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 Algorithm_Function 

type Algorithm_Function struct {
	Name              string                         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameters        []*Algorithm_FunctionParameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	ParallelExecution bool                           `protobuf:"varint,3,opt,name=parallelExecution,proto3" json:"parallelExecution,omitempty"`
	RunFirst          bool                           `protobuf:"varint,4,opt,name=runFirst,proto3" json:"runFirst,omitempty"`
	RunLast           bool                           `protobuf:"varint,5,opt,name=runLast,proto3" json:"runLast,omitempty"`
	// contains filtered or unexported fields
}

func (*Algorithm_Function) Descriptor deprecated 

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

Deprecated: Use Algorithm_Function.ProtoReflect.Descriptor instead.

func (*Algorithm_Function) GetName 

func (x *Algorithm_Function) GetName() string

func (*Algorithm_Function) GetParallelExecution 

func (x *Algorithm_Function) GetParallelExecution() bool

func (*Algorithm_Function) GetParameters 

func (x *Algorithm_Function) GetParameters() []*Algorithm_FunctionParameter

func (*Algorithm_Function) GetRunFirst 

func (x *Algorithm_Function) GetRunFirst() bool

func (*Algorithm_Function) GetRunLast 

func (x *Algorithm_Function) GetRunLast() bool

func (*Algorithm_Function) ProtoMessage 

func (*Algorithm_Function) ProtoMessage()

func (*Algorithm_Function) ProtoReflect 

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

func (*Algorithm_Function) Reset 

func (x *Algorithm_Function) Reset()

func (*Algorithm_Function) String 

func (x *Algorithm_Function) String() string

type Algorithm_FunctionParameter 

type Algorithm_FunctionParameter struct {
	Key          string  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	DefaultValue *string `protobuf:"bytes,2,opt,name=defaultValue,proto3,oneof" json:"defaultValue,omitempty"`
	Value        *string `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	ValueType    string  `protobuf:"bytes,4,opt,name=valueType,proto3" json:"valueType,omitempty"`
	// contains filtered or unexported fields
}

func (*Algorithm_FunctionParameter) Descriptor deprecated 

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

Deprecated: Use Algorithm_FunctionParameter.ProtoReflect.Descriptor instead.

func (*Algorithm_FunctionParameter) GetDefaultValue 

func (x *Algorithm_FunctionParameter) GetDefaultValue() string

func (*Algorithm_FunctionParameter) GetKey 

func (x *Algorithm_FunctionParameter) GetKey() string

func (*Algorithm_FunctionParameter) GetValue 

func (x *Algorithm_FunctionParameter) GetValue() string

func (*Algorithm_FunctionParameter) GetValueType 

func (x *Algorithm_FunctionParameter) GetValueType() string

func (*Algorithm_FunctionParameter) ProtoMessage 

func (*Algorithm_FunctionParameter) ProtoMessage()

func (*Algorithm_FunctionParameter) ProtoReflect 

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

func (*Algorithm_FunctionParameter) Reset 

func (x *Algorithm_FunctionParameter) Reset()

func (*Algorithm_FunctionParameter) String 

func (x *Algorithm_FunctionParameter) String() string

type ConfigureExecutionRequest 

type ConfigureExecutionRequest struct {
	Configuration *ExecutionConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureExecutionRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureExecutionRequest.ProtoReflect.Descriptor instead.

func (*ConfigureExecutionRequest) GetConfiguration 

func (x *ConfigureExecutionRequest) GetConfiguration() *ExecutionConfiguration

func (*ConfigureExecutionRequest) ProtoMessage 

func (*ConfigureExecutionRequest) ProtoMessage()

func (*ConfigureExecutionRequest) ProtoReflect 

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

func (*ConfigureExecutionRequest) Reset 

func (x *ConfigureExecutionRequest) Reset()

func (*ConfigureExecutionRequest) String 

func (x *ConfigureExecutionRequest) String() string

type ConfigureExecutionResponse 

type ConfigureExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*ConfigureExecutionResponse) Descriptor deprecated 

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

Deprecated: Use ConfigureExecutionResponse.ProtoReflect.Descriptor instead.

func (*ConfigureExecutionResponse) ProtoMessage 

func (*ConfigureExecutionResponse) ProtoMessage()

func (*ConfigureExecutionResponse) ProtoReflect 

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

func (*ConfigureExecutionResponse) Reset 

func (x *ConfigureExecutionResponse) Reset()

func (*ConfigureExecutionResponse) String 

func (x *ConfigureExecutionResponse) String() string

type ExecutionConfiguration 

type ExecutionConfiguration struct {
	BrokerPort    int32                              `protobuf:"varint,1,opt,name=brokerPort,proto3" json:"brokerPort,omitempty"`
	NamespacePort int32                              `protobuf:"varint,2,opt,name=namespacePort,proto3" json:"namespacePort,omitempty"`
	DatabaseURL   string                             `protobuf:"bytes,3,opt,name=databaseURL,proto3" json:"databaseURL,omitempty"`
	Functions     []*ExecutionConfiguration_Function `protobuf:"bytes,4,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionConfiguration) Descriptor deprecated 

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

Deprecated: Use ExecutionConfiguration.ProtoReflect.Descriptor instead.

func (*ExecutionConfiguration) GetBrokerPort 

func (x *ExecutionConfiguration) GetBrokerPort() int32

func (*ExecutionConfiguration) GetDatabaseURL 

func (x *ExecutionConfiguration) GetDatabaseURL() string

func (*ExecutionConfiguration) GetFunctions 

func (x *ExecutionConfiguration) GetFunctions() []*ExecutionConfiguration_Function

func (*ExecutionConfiguration) GetNamespacePort 

func (x *ExecutionConfiguration) GetNamespacePort() int32

func (*ExecutionConfiguration) ProtoMessage 

func (*ExecutionConfiguration) ProtoMessage()

func (*ExecutionConfiguration) ProtoReflect 

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

func (*ExecutionConfiguration) Reset 

func (x *ExecutionConfiguration) Reset()

func (*ExecutionConfiguration) String 

func (x *ExecutionConfiguration) String() string

type ExecutionConfiguration_Function 

type ExecutionConfiguration_Function struct {
	Name       string                                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameters []*ExecutionConfiguration_FunctionParameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionConfiguration_Function) Descriptor deprecated 

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

Deprecated: Use ExecutionConfiguration_Function.ProtoReflect.Descriptor instead.

func (*ExecutionConfiguration_Function) GetName 

func (x *ExecutionConfiguration_Function) GetName() string

func (*ExecutionConfiguration_Function) GetParameters 

func (x *ExecutionConfiguration_Function) GetParameters() []*ExecutionConfiguration_FunctionParameter

func (*ExecutionConfiguration_Function) ProtoMessage 

func (*ExecutionConfiguration_Function) ProtoMessage()

func (*ExecutionConfiguration_Function) ProtoReflect 

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

func (*ExecutionConfiguration_Function) Reset 

func (x *ExecutionConfiguration_Function) Reset()

func (*ExecutionConfiguration_Function) String 

func (x *ExecutionConfiguration_Function) String() string

type ExecutionConfiguration_FunctionParameter 

type ExecutionConfiguration_FunctionParameter struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionConfiguration_FunctionParameter) Descriptor deprecated 

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

Deprecated: Use ExecutionConfiguration_FunctionParameter.ProtoReflect.Descriptor instead.

func (*ExecutionConfiguration_FunctionParameter) GetKey 

func (x *ExecutionConfiguration_FunctionParameter) GetKey() string

func (*ExecutionConfiguration_FunctionParameter) GetValue 

func (x *ExecutionConfiguration_FunctionParameter) GetValue() string

func (*ExecutionConfiguration_FunctionParameter) ProtoMessage 

func (*ExecutionConfiguration_FunctionParameter) ProtoMessage()

func (*ExecutionConfiguration_FunctionParameter) ProtoReflect 

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

func (*ExecutionConfiguration_FunctionParameter) Reset 

func (x *ExecutionConfiguration_FunctionParameter) Reset()

func (*ExecutionConfiguration_FunctionParameter) String 

func (x *ExecutionConfiguration_FunctionParameter) String() string

type GetServiceInfoRequest 

type GetServiceInfoRequest struct {
	// contains filtered or unexported fields
}

func (*GetServiceInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetServiceInfoRequest.ProtoReflect.Descriptor instead.

func (*GetServiceInfoRequest) ProtoMessage 

func (*GetServiceInfoRequest) ProtoMessage()

func (*GetServiceInfoRequest) ProtoReflect 

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

func (*GetServiceInfoRequest) Reset 

func (x *GetServiceInfoRequest) Reset()

func (*GetServiceInfoRequest) String 

func (x *GetServiceInfoRequest) String() string

type GetServiceInfoResponse 

type GetServiceInfoResponse struct {
	Algorithm *Algorithm `protobuf:"bytes,1,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServiceInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetServiceInfoResponse.ProtoReflect.Descriptor instead.

func (*GetServiceInfoResponse) GetAlgorithm 

func (x *GetServiceInfoResponse) GetAlgorithm() *Algorithm

func (*GetServiceInfoResponse) ProtoMessage 

func (*GetServiceInfoResponse) ProtoMessage()

func (*GetServiceInfoResponse) ProtoReflect 

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

func (*GetServiceInfoResponse) Reset 

func (x *GetServiceInfoResponse) Reset()

func (*GetServiceInfoResponse) String 

func (x *GetServiceInfoResponse) String() string

type Instance 

type Instance struct {
	ID       string             `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Image    *string            `protobuf:"bytes,2,opt,name=Image,proto3,oneof" json:"Image,omitempty"`
	Host     *string            `protobuf:"bytes,3,opt,name=Host,proto3,oneof" json:"Host,omitempty"`
	Port     *int32             `protobuf:"varint,4,opt,name=Port,proto3,oneof" json:"Port,omitempty"`
	Statuses []*Instance_Status `protobuf:"bytes,5,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance) Descriptor deprecated 

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetHost 

func (x *Instance) GetHost() string

func (*Instance) GetID 

func (x *Instance) GetID() string

func (*Instance) GetImage 

func (x *Instance) GetImage() string

func (*Instance) GetPort 

func (x *Instance) GetPort() int32

func (*Instance) GetStatuses 

func (x *Instance) GetStatuses() []*Instance_Status

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

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

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type Instance_Status 

type Instance_Status struct {
	Status     Instance_Status_Status `protobuf:"varint,1,opt,name=status,proto3,enum=foreverbull.service.Instance_Status_Status" json:"status,omitempty"`
	Error      *string                `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=OccurredAt,proto3" json:"OccurredAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance_Status) Descriptor deprecated 

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

Deprecated: Use Instance_Status.ProtoReflect.Descriptor instead.

func (*Instance_Status) GetError 

func (x *Instance_Status) GetError() string

func (*Instance_Status) GetOccurredAt 

func (x *Instance_Status) GetOccurredAt() *timestamppb.Timestamp

func (*Instance_Status) GetStatus 

func (x *Instance_Status) GetStatus() Instance_Status_Status

func (*Instance_Status) ProtoMessage 

func (*Instance_Status) ProtoMessage()

func (*Instance_Status) ProtoReflect 

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

func (*Instance_Status) Reset 

func (x *Instance_Status) Reset()

func (*Instance_Status) String 

func (x *Instance_Status) String() string

type Instance_Status_Status 

type Instance_Status_Status int32
const (
	Instance_Status_CREATED    Instance_Status_Status = 0
	Instance_Status_RUNNING    Instance_Status_Status = 1
	Instance_Status_CONFIGURED Instance_Status_Status = 2
	Instance_Status_EXECUTING  Instance_Status_Status = 3
	Instance_Status_COMPLETED  Instance_Status_Status = 4
	Instance_Status_ERROR      Instance_Status_Status = 5
)

func (Instance_Status_Status) Descriptor 

func (Instance_Status_Status) Descriptor() protoreflect.EnumDescriptor

func (Instance_Status_Status) Enum 

func (x Instance_Status_Status) Enum() *Instance_Status_Status

func (Instance_Status_Status) EnumDescriptor deprecated 

func (Instance_Status_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Instance_Status_Status.Descriptor instead.

func (Instance_Status_Status) Number 

func (x Instance_Status_Status) Number() protoreflect.EnumNumber

func (Instance_Status_Status) String 

func (x Instance_Status_Status) String() string

func (Instance_Status_Status) Type 

func (Instance_Status_Status) Type() protoreflect.EnumType

type MockUnsafeWorkerServer 

type MockUnsafeWorkerServer struct {
	mock.Mock
}

MockUnsafeWorkerServer is an autogenerated mock type for the UnsafeWorkerServer type

func NewMockUnsafeWorkerServer 

func NewMockUnsafeWorkerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeWorkerServer

NewMockUnsafeWorkerServer creates a new instance of MockUnsafeWorkerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

type MockWorkerClient 

type MockWorkerClient struct {
	mock.Mock
}

MockWorkerClient is an autogenerated mock type for the WorkerClient type

func NewMockWorkerClient 

func NewMockWorkerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockWorkerClient

NewMockWorkerClient creates a new instance of MockWorkerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockWorkerClient) ConfigureExecution 

func (_m *MockWorkerClient) ConfigureExecution(ctx context.Context, in *ConfigureExecutionRequest, opts ...grpc.CallOption) (*ConfigureExecutionResponse, error)

ConfigureExecution provides a mock function with given fields: ctx, in, opts

func (*MockWorkerClient) GetServiceInfo 

func (_m *MockWorkerClient) GetServiceInfo(ctx context.Context, in *GetServiceInfoRequest, opts ...grpc.CallOption) (*GetServiceInfoResponse, error)

GetServiceInfo provides a mock function with given fields: ctx, in, opts

func (*MockWorkerClient) RunExecution 

func (_m *MockWorkerClient) RunExecution(ctx context.Context, in *RunExecutionRequest, opts ...grpc.CallOption) (*RunExecutionResponse, error)

RunExecution provides a mock function with given fields: ctx, in, opts

type MockWorkerServer 

type MockWorkerServer struct {
	mock.Mock
}

MockWorkerServer is an autogenerated mock type for the WorkerServer type

func NewMockWorkerServer 

func NewMockWorkerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockWorkerServer

NewMockWorkerServer creates a new instance of MockWorkerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockWorkerServer) ConfigureExecution 

func (_m *MockWorkerServer) ConfigureExecution(_a0 context.Context, _a1 *ConfigureExecutionRequest) (*ConfigureExecutionResponse, error)

ConfigureExecution provides a mock function with given fields: _a0, _a1

func (*MockWorkerServer) GetServiceInfo 

func (_m *MockWorkerServer) GetServiceInfo(_a0 context.Context, _a1 *GetServiceInfoRequest) (*GetServiceInfoResponse, error)

GetServiceInfo provides a mock function with given fields: _a0, _a1

func (*MockWorkerServer) RunExecution 

func (_m *MockWorkerServer) RunExecution(_a0 context.Context, _a1 *RunExecutionRequest) (*RunExecutionResponse, error)

RunExecution provides a mock function with given fields: _a0, _a1

type NamespaceRequest 

type NamespaceRequest struct {
	Key   string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Type  NamespaceRequestType `protobuf:"varint,2,opt,name=type,proto3,enum=foreverbull.service.NamespaceRequestType" json:"type,omitempty"`
	Value *structpb.Struct     `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceRequest) Descriptor deprecated 

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

Deprecated: Use NamespaceRequest.ProtoReflect.Descriptor instead.

func (*NamespaceRequest) GetKey 

func (x *NamespaceRequest) GetKey() string

func (*NamespaceRequest) GetType 

func (x *NamespaceRequest) GetType() NamespaceRequestType

func (*NamespaceRequest) GetValue 

func (x *NamespaceRequest) GetValue() *structpb.Struct

func (*NamespaceRequest) ProtoMessage 

func (*NamespaceRequest) ProtoMessage()

func (*NamespaceRequest) ProtoReflect 

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

func (*NamespaceRequest) Reset 

func (x *NamespaceRequest) Reset()

func (*NamespaceRequest) String 

func (x *NamespaceRequest) String() string

type NamespaceRequestType 

type NamespaceRequestType int32
const (
	NamespaceRequestType_GET NamespaceRequestType = 0
	NamespaceRequestType_SET NamespaceRequestType = 1
)

func (NamespaceRequestType) Descriptor 

func (NamespaceRequestType) Descriptor() protoreflect.EnumDescriptor

func (NamespaceRequestType) Enum 

func (x NamespaceRequestType) Enum() *NamespaceRequestType

func (NamespaceRequestType) EnumDescriptor deprecated 

func (NamespaceRequestType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NamespaceRequestType.Descriptor instead.

func (NamespaceRequestType) Number 

func (x NamespaceRequestType) Number() protoreflect.EnumNumber

func (NamespaceRequestType) String 

func (x NamespaceRequestType) String() string

func (NamespaceRequestType) Type 

func (NamespaceRequestType) Type() protoreflect.EnumType

type NamespaceResponse 

type NamespaceResponse struct {
	Value *structpb.Struct `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Error *string          `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceResponse) Descriptor deprecated 

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

Deprecated: Use NamespaceResponse.ProtoReflect.Descriptor instead.

func (*NamespaceResponse) GetError 

func (x *NamespaceResponse) GetError() string

func (*NamespaceResponse) GetValue 

func (x *NamespaceResponse) GetValue() *structpb.Struct

func (*NamespaceResponse) ProtoMessage 

func (*NamespaceResponse) ProtoMessage()

func (*NamespaceResponse) ProtoReflect 

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

func (*NamespaceResponse) Reset 

func (x *NamespaceResponse) Reset()

func (*NamespaceResponse) String 

func (x *NamespaceResponse) String() string

type RunExecutionRequest 

type RunExecutionRequest struct {
	// contains filtered or unexported fields
}

func (*RunExecutionRequest) Descriptor deprecated 

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

Deprecated: Use RunExecutionRequest.ProtoReflect.Descriptor instead.

func (*RunExecutionRequest) ProtoMessage 

func (*RunExecutionRequest) ProtoMessage()

func (*RunExecutionRequest) ProtoReflect 

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

func (*RunExecutionRequest) Reset 

func (x *RunExecutionRequest) Reset()

func (*RunExecutionRequest) String 

func (x *RunExecutionRequest) String() string

type RunExecutionResponse 

type RunExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*RunExecutionResponse) Descriptor deprecated 

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

Deprecated: Use RunExecutionResponse.ProtoReflect.Descriptor instead.

func (*RunExecutionResponse) ProtoMessage 

func (*RunExecutionResponse) ProtoMessage()

func (*RunExecutionResponse) ProtoReflect 

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

func (*RunExecutionResponse) Reset 

func (x *RunExecutionResponse) Reset()

func (*RunExecutionResponse) String 

func (x *RunExecutionResponse) String() string

type Service 

type Service struct {
	Image     string            `protobuf:"bytes,1,opt,name=Image,proto3" json:"Image,omitempty"`
	Algorithm *Algorithm        `protobuf:"bytes,2,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	Statuses  []*Service_Status `protobuf:"bytes,3,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetAlgorithm 

func (x *Service) GetAlgorithm() *Algorithm

func (*Service) GetImage 

func (x *Service) GetImage() string

func (*Service) GetStatuses 

func (x *Service) GetStatuses() []*Service_Status

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type Service_Status 

type Service_Status struct {
	Status     Service_Status_Status  `protobuf:"varint,1,opt,name=status,proto3,enum=foreverbull.service.Service_Status_Status" json:"status,omitempty"`
	Error      *string                `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=OccurredAt,proto3" json:"OccurredAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Service_Status) Descriptor deprecated 

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

Deprecated: Use Service_Status.ProtoReflect.Descriptor instead.

func (*Service_Status) GetError 

func (x *Service_Status) GetError() string

func (*Service_Status) GetOccurredAt 

func (x *Service_Status) GetOccurredAt() *timestamppb.Timestamp

func (*Service_Status) GetStatus 

func (x *Service_Status) GetStatus() Service_Status_Status

func (*Service_Status) ProtoMessage 

func (*Service_Status) ProtoMessage()

func (*Service_Status) ProtoReflect 

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

func (*Service_Status) Reset 

func (x *Service_Status) Reset()

func (*Service_Status) String 

func (x *Service_Status) String() string

type Service_Status_Status 

type Service_Status_Status int32
const (
	Service_Status_CREATED   Service_Status_Status = 0
	Service_Status_INTERVIEW Service_Status_Status = 1
	Service_Status_READY     Service_Status_Status = 2
	Service_Status_ERROR     Service_Status_Status = 3
)

func (Service_Status_Status) Descriptor 

func (Service_Status_Status) Descriptor() protoreflect.EnumDescriptor

func (Service_Status_Status) Enum 

func (x Service_Status_Status) Enum() *Service_Status_Status

func (Service_Status_Status) EnumDescriptor deprecated 

func (Service_Status_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Service_Status_Status.Descriptor instead.

func (Service_Status_Status) Number 

func (x Service_Status_Status) Number() protoreflect.EnumNumber

func (Service_Status_Status) String 

func (x Service_Status_Status) String() string

func (Service_Status_Status) Type 

func (Service_Status_Status) Type() protoreflect.EnumType

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct{}

UnimplementedWorkerServer 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 (UnimplementedWorkerServer) ConfigureExecution 

func (UnimplementedWorkerServer) ConfigureExecution(context.Context, *ConfigureExecutionRequest) (*ConfigureExecutionResponse, error)

func (UnimplementedWorkerServer) GetServiceInfo 

func (UnimplementedWorkerServer) GetServiceInfo(context.Context, *GetServiceInfoRequest) (*GetServiceInfoResponse, error)

func (UnimplementedWorkerServer) RunExecution 

func (UnimplementedWorkerServer) RunExecution(context.Context, *RunExecutionRequest) (*RunExecutionResponse, error)

type UnsafeWorkerServer 

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

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

type WorkerClient 

type WorkerClient interface {
	GetServiceInfo(ctx context.Context, in *GetServiceInfoRequest, opts ...grpc.CallOption) (*GetServiceInfoResponse, error)
	ConfigureExecution(ctx context.Context, in *ConfigureExecutionRequest, opts ...grpc.CallOption) (*ConfigureExecutionResponse, error)
	RunExecution(ctx context.Context, in *RunExecutionRequest, opts ...grpc.CallOption) (*RunExecutionResponse, error)
}

WorkerClient is the client API for Worker 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 NewWorkerClient 

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerRequest 

type WorkerRequest struct {
	Task      string        `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Symbols   []string      `protobuf:"bytes,2,rep,name=symbols,proto3" json:"symbols,omitempty"`
	Portfolio *pb.Portfolio `protobuf:"bytes,3,opt,name=portfolio,proto3" json:"portfolio,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerRequest) Descriptor deprecated 

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

Deprecated: Use WorkerRequest.ProtoReflect.Descriptor instead.

func (*WorkerRequest) GetPortfolio 

func (x *WorkerRequest) GetPortfolio() *pb.Portfolio

func (*WorkerRequest) GetSymbols 

func (x *WorkerRequest) GetSymbols() []string

func (*WorkerRequest) GetTask 

func (x *WorkerRequest) GetTask() string

func (*WorkerRequest) ProtoMessage 

func (*WorkerRequest) ProtoMessage()

func (*WorkerRequest) ProtoReflect 

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

func (*WorkerRequest) Reset 

func (x *WorkerRequest) Reset()

func (*WorkerRequest) String 

func (x *WorkerRequest) String() string

type WorkerResponse 

type WorkerResponse struct {
	Task   string      `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Orders []*pb.Order `protobuf:"bytes,2,rep,name=orders,proto3" json:"orders,omitempty"`
	Error  *string     `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerResponse) Descriptor deprecated 

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

Deprecated: Use WorkerResponse.ProtoReflect.Descriptor instead.

func (*WorkerResponse) GetError 

func (x *WorkerResponse) GetError() string

func (*WorkerResponse) GetOrders 

func (x *WorkerResponse) GetOrders() []*pb.Order

func (*WorkerResponse) GetTask 

func (x *WorkerResponse) GetTask() string

func (*WorkerResponse) ProtoMessage 

func (*WorkerResponse) ProtoMessage()

func (*WorkerResponse) ProtoReflect 

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

func (*WorkerResponse) Reset 

func (x *WorkerResponse) Reset()

func (*WorkerResponse) String 

func (x *WorkerResponse) String() string

type WorkerServer 

type WorkerServer interface {
	GetServiceInfo(context.Context, *GetServiceInfoRequest) (*GetServiceInfoResponse, error)
	ConfigureExecution(context.Context, *ConfigureExecutionRequest) (*ConfigureExecutionResponse, error)
	RunExecution(context.Context, *RunExecutionRequest) (*RunExecutionResponse, error)
	// contains filtered or unexported methods
}

WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility.

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.