silo

package
v0.0.0-...-7c85a9a Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RegistrationStatus_name = map[int32]string{
		0: "REGISTRATION_OK",
		1: "REGISTRATION_ERROR",
	}
	RegistrationStatus_value = map[string]int32{
		"REGISTRATION_OK":    0,
		"REGISTRATION_ERROR": 1,
	}
)

Enum value maps for RegistrationStatus.

View Source 
var (
	PlacementStatus_name = map[int32]string{
		0: "PLACEMENT_OK",
		1: "PLACEMENT_NO_COMPATIBLE_SILO",
		2: "PLACEMENT_ERROR",
	}
	PlacementStatus_value = map[string]int32{
		"PLACEMENT_OK":                 0,
		"PLACEMENT_NO_COMPATIBLE_SILO": 1,
		"PLACEMENT_ERROR":              2,
	}
)

Enum value maps for PlacementStatus.

View Source 
var (
	ExecutionStatus_name = map[int32]string{
		0: "EXECUTION_OK",
		1: "EXECUTION_ERROR",
		2: "EXECUTION_NO_LONGER_ABLE",
	}
	ExecutionStatus_value = map[string]int32{
		"EXECUTION_OK":             0,
		"EXECUTION_ERROR":          1,
		"EXECUTION_NO_LONGER_ABLE": 2,
	}
)

Enum value maps for ExecutionStatus.

View Source 
var File_silo_silo_proto protoreflect.FileDescriptor
View Source 
var SiloService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "silo.SiloService",
	HandlerType: (*SiloServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _SiloService_Ping_Handler,
		},
		{
			MethodName: "PlaceGrain",
			Handler:    _SiloService_PlaceGrain_Handler,
		},
		{
			MethodName: "InvokeGrain",
			Handler:    _SiloService_InvokeGrain_Handler,
		},
		{
			MethodName: "RegisterReminder",
			Handler:    _SiloService_RegisterReminder_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RegisterGrainHandler",
			Handler:       _SiloService_RegisterGrainHandler_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ResultStream",
			Handler:       _SiloService_ResultStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "silo/silo.proto",
}

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

Functions

func RegisterSiloServiceServer 

func RegisterSiloServiceServer(s grpc.ServiceRegistrar, srv SiloServiceServer)

Types

type ExecutionStatus 

type ExecutionStatus int32
const (
	ExecutionStatus_EXECUTION_OK             ExecutionStatus = 0
	ExecutionStatus_EXECUTION_ERROR          ExecutionStatus = 1
	ExecutionStatus_EXECUTION_NO_LONGER_ABLE ExecutionStatus = 2 // The grain is no longer able to execute
)

func (ExecutionStatus) Descriptor 

func (ExecutionStatus) Descriptor() protoreflect.EnumDescriptor

func (ExecutionStatus) Enum 

func (x ExecutionStatus) Enum() *ExecutionStatus

func (ExecutionStatus) EnumDescriptor deprecated 

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

Deprecated: Use ExecutionStatus.Descriptor instead.

func (ExecutionStatus) Number 

func (x ExecutionStatus) Number() protoreflect.EnumNumber

func (ExecutionStatus) String 

func (x ExecutionStatus) String() string

func (ExecutionStatus) Type 

func (ExecutionStatus) Type() protoreflect.EnumType

type GrainInvocationRequest 

type GrainInvocationRequest struct {
	RequestId  string `protobuf:"bytes,1,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	GrainType  string `protobuf:"bytes,2,opt,name=GrainType,proto3" json:"GrainType,omitempty"`
	GrainId    string `protobuf:"bytes,3,opt,name=GrainId,proto3" json:"GrainId,omitempty"`
	MethodName string `protobuf:"bytes,4,opt,name=MethodName,proto3" json:"MethodName,omitempty"`
	Data       []byte `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*GrainInvocationRequest) Descriptor deprecated 

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

Deprecated: Use GrainInvocationRequest.ProtoReflect.Descriptor instead.

func (*GrainInvocationRequest) GetData 

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

func (*GrainInvocationRequest) GetGrainId 

func (x *GrainInvocationRequest) GetGrainId() string

func (*GrainInvocationRequest) GetGrainType 

func (x *GrainInvocationRequest) GetGrainType() string

func (*GrainInvocationRequest) GetMethodName 

func (x *GrainInvocationRequest) GetMethodName() string

func (*GrainInvocationRequest) GetRequestId 

func (x *GrainInvocationRequest) GetRequestId() string

func (*GrainInvocationRequest) ProtoMessage 

func (*GrainInvocationRequest) ProtoMessage()

func (*GrainInvocationRequest) ProtoReflect 

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

func (*GrainInvocationRequest) Reset 

func (x *GrainInvocationRequest) Reset()

func (*GrainInvocationRequest) String 

func (x *GrainInvocationRequest) String() string

type GrainInvocationResponse 

type GrainInvocationResponse struct {
	Status  ExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=silo.ExecutionStatus" json:"status,omitempty"`
	GrainId string          `protobuf:"bytes,2,opt,name=grainId,proto3" json:"grainId,omitempty"`
	Result  []byte          `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GrainInvocationResponse) Descriptor deprecated 

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

Deprecated: Use GrainInvocationResponse.ProtoReflect.Descriptor instead.

func (*GrainInvocationResponse) GetGrainId 

func (x *GrainInvocationResponse) GetGrainId() string

func (*GrainInvocationResponse) GetResult 

func (x *GrainInvocationResponse) GetResult() []byte

func (*GrainInvocationResponse) GetStatus 

func (x *GrainInvocationResponse) GetStatus() ExecutionStatus

func (*GrainInvocationResponse) ProtoMessage 

func (*GrainInvocationResponse) ProtoMessage()

func (*GrainInvocationResponse) ProtoReflect 

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

func (*GrainInvocationResponse) Reset 

func (x *GrainInvocationResponse) Reset()

func (*GrainInvocationResponse) String 

func (x *GrainInvocationResponse) String() string

type GrainInvocationResult 

type GrainInvocationResult struct {
	RequestId string          `protobuf:"bytes,1,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	Status    ExecutionStatus `protobuf:"varint,2,opt,name=Status,proto3,enum=silo.ExecutionStatus" json:"Status,omitempty"`
	// Types that are assignable to TestResult:
	//	*GrainInvocationResult_Result
	//	*GrainInvocationResult_Error
	TestResult isGrainInvocationResult_TestResult `protobuf_oneof:"test_result"`
	// contains filtered or unexported fields
}

func (*GrainInvocationResult) Descriptor deprecated 

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

Deprecated: Use GrainInvocationResult.ProtoReflect.Descriptor instead.

func (*GrainInvocationResult) GetError 

func (x *GrainInvocationResult) GetError() string

func (*GrainInvocationResult) GetRequestId 

func (x *GrainInvocationResult) GetRequestId() string

func (*GrainInvocationResult) GetResult 

func (x *GrainInvocationResult) GetResult() []byte

func (*GrainInvocationResult) GetStatus 

func (x *GrainInvocationResult) GetStatus() ExecutionStatus

func (*GrainInvocationResult) GetTestResult 

func (m *GrainInvocationResult) GetTestResult() isGrainInvocationResult_TestResult

func (*GrainInvocationResult) ProtoMessage 

func (*GrainInvocationResult) ProtoMessage()

func (*GrainInvocationResult) ProtoReflect 

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

func (*GrainInvocationResult) Reset 

func (x *GrainInvocationResult) Reset()

func (*GrainInvocationResult) String 

func (x *GrainInvocationResult) String() string

type GrainInvocationResult_Error 

type GrainInvocationResult_Error struct {
	Error string `protobuf:"bytes,4,opt,name=Error,proto3,oneof"`
}

type GrainInvocationResult_Result 

type GrainInvocationResult_Result struct {
	Result []byte `protobuf:"bytes,3,opt,name=Result,proto3,oneof"`
}

type PingResponse 

type PingResponse struct {
	Epoch int64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetEpoch 

func (x *PingResponse) GetEpoch() int64

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type PlaceGrainRequest 

type PlaceGrainRequest struct {
	GrainType string `protobuf:"bytes,1,opt,name=grainType,proto3" json:"grainType,omitempty"`
	GrainId   string `protobuf:"bytes,2,opt,name=grainId,proto3" json:"grainId,omitempty"`
	// contains filtered or unexported fields
}

func (*PlaceGrainRequest) Descriptor deprecated 

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

Deprecated: Use PlaceGrainRequest.ProtoReflect.Descriptor instead.

func (*PlaceGrainRequest) GetGrainId 

func (x *PlaceGrainRequest) GetGrainId() string

func (*PlaceGrainRequest) GetGrainType 

func (x *PlaceGrainRequest) GetGrainType() string

func (*PlaceGrainRequest) ProtoMessage 

func (*PlaceGrainRequest) ProtoMessage()

func (*PlaceGrainRequest) ProtoReflect 

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

func (*PlaceGrainRequest) Reset 

func (x *PlaceGrainRequest) Reset()

func (*PlaceGrainRequest) String 

func (x *PlaceGrainRequest) String() string

type PlaceGrainResponse 

type PlaceGrainResponse struct {
	Status   PlacementStatus `protobuf:"varint,1,opt,name=status,proto3,enum=silo.PlacementStatus" json:"status,omitempty"`
	Location string          `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

func (*PlaceGrainResponse) Descriptor deprecated 

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

Deprecated: Use PlaceGrainResponse.ProtoReflect.Descriptor instead.

func (*PlaceGrainResponse) GetLocation 

func (x *PlaceGrainResponse) GetLocation() string

func (*PlaceGrainResponse) GetStatus 

func (x *PlaceGrainResponse) GetStatus() PlacementStatus

func (*PlaceGrainResponse) ProtoMessage 

func (*PlaceGrainResponse) ProtoMessage()

func (*PlaceGrainResponse) ProtoReflect 

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

func (*PlaceGrainResponse) Reset 

func (x *PlaceGrainResponse) Reset()

func (*PlaceGrainResponse) String 

func (x *PlaceGrainResponse) String() string

type PlacementStatus 

type PlacementStatus int32
const (
	PlacementStatus_PLACEMENT_OK                 PlacementStatus = 0
	PlacementStatus_PLACEMENT_NO_COMPATIBLE_SILO PlacementStatus = 1
	PlacementStatus_PLACEMENT_ERROR              PlacementStatus = 2
)

func (PlacementStatus) Descriptor 

func (PlacementStatus) Descriptor() protoreflect.EnumDescriptor

func (PlacementStatus) Enum 

func (x PlacementStatus) Enum() *PlacementStatus

func (PlacementStatus) EnumDescriptor deprecated 

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

Deprecated: Use PlacementStatus.Descriptor instead.

func (PlacementStatus) Number 

func (x PlacementStatus) Number() protoreflect.EnumNumber

func (PlacementStatus) String 

func (x PlacementStatus) String() string

func (PlacementStatus) Type 

func (PlacementStatus) Type() protoreflect.EnumType

type RegisterGrainHandlerRequest 

type RegisterGrainHandlerRequest struct {
	GrainType    string `protobuf:"bytes,1,opt,name=grainType,proto3" json:"grainType,omitempty"`
	GrainVersion string `protobuf:"bytes,2,opt,name=grainVersion,proto3" json:"grainVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterGrainHandlerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterGrainHandlerRequest.ProtoReflect.Descriptor instead.

func (*RegisterGrainHandlerRequest) GetGrainType 

func (x *RegisterGrainHandlerRequest) GetGrainType() string

func (*RegisterGrainHandlerRequest) GetGrainVersion 

func (x *RegisterGrainHandlerRequest) GetGrainVersion() string

func (*RegisterGrainHandlerRequest) ProtoMessage 

func (*RegisterGrainHandlerRequest) ProtoMessage()

func (*RegisterGrainHandlerRequest) ProtoReflect 

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

func (*RegisterGrainHandlerRequest) Reset 

func (x *RegisterGrainHandlerRequest) Reset()

func (*RegisterGrainHandlerRequest) String 

func (x *RegisterGrainHandlerRequest) String() string

type RegisterGrainHandlerResponse 

type RegisterGrainHandlerResponse struct {
	Status RegistrationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=silo.RegistrationStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterGrainHandlerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterGrainHandlerResponse.ProtoReflect.Descriptor instead.

func (*RegisterGrainHandlerResponse) GetStatus 

func (x *RegisterGrainHandlerResponse) GetStatus() RegistrationStatus

func (*RegisterGrainHandlerResponse) ProtoMessage 

func (*RegisterGrainHandlerResponse) ProtoMessage()

func (*RegisterGrainHandlerResponse) ProtoReflect 

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

func (*RegisterGrainHandlerResponse) Reset 

func (x *RegisterGrainHandlerResponse) Reset()

func (*RegisterGrainHandlerResponse) String 

func (x *RegisterGrainHandlerResponse) String() string

type RegisterReminderRequest 

type RegisterReminderRequest struct {
	GrainType    string `protobuf:"bytes,1,opt,name=grainType,proto3" json:"grainType,omitempty"`
	GrainId      string `protobuf:"bytes,2,opt,name=grainId,proto3" json:"grainId,omitempty"`
	ReminderName string `protobuf:"bytes,3,opt,name=reminderName,proto3" json:"reminderName,omitempty"`
	DueTime      int64  `protobuf:"varint,4,opt,name=dueTime,proto3" json:"dueTime,omitempty"`
	Period       int64  `protobuf:"varint,5,opt,name=period,proto3" json:"period,omitempty"`
	Data         []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterReminderRequest) Descriptor deprecated 

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

Deprecated: Use RegisterReminderRequest.ProtoReflect.Descriptor instead.

func (*RegisterReminderRequest) GetData 

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

func (*RegisterReminderRequest) GetDueTime 

func (x *RegisterReminderRequest) GetDueTime() int64

func (*RegisterReminderRequest) GetGrainId 

func (x *RegisterReminderRequest) GetGrainId() string

func (*RegisterReminderRequest) GetGrainType 

func (x *RegisterReminderRequest) GetGrainType() string

func (*RegisterReminderRequest) GetPeriod 

func (x *RegisterReminderRequest) GetPeriod() int64

func (*RegisterReminderRequest) GetReminderName 

func (x *RegisterReminderRequest) GetReminderName() string

func (*RegisterReminderRequest) ProtoMessage 

func (*RegisterReminderRequest) ProtoMessage()

func (*RegisterReminderRequest) ProtoReflect 

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

func (*RegisterReminderRequest) Reset 

func (x *RegisterReminderRequest) Reset()

func (*RegisterReminderRequest) String 

func (x *RegisterReminderRequest) String() string

type RegisterReminderResponse 

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

func (*RegisterReminderResponse) Descriptor deprecated 

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

Deprecated: Use RegisterReminderResponse.ProtoReflect.Descriptor instead.

func (*RegisterReminderResponse) GetReminderId 

func (x *RegisterReminderResponse) GetReminderId() string

func (*RegisterReminderResponse) ProtoMessage 

func (*RegisterReminderResponse) ProtoMessage()

func (*RegisterReminderResponse) ProtoReflect 

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

func (*RegisterReminderResponse) Reset 

func (x *RegisterReminderResponse) Reset()

func (*RegisterReminderResponse) String 

func (x *RegisterReminderResponse) String() string

type RegistrationStatus 

type RegistrationStatus int32
const (
	RegistrationStatus_REGISTRATION_OK    RegistrationStatus = 0
	RegistrationStatus_REGISTRATION_ERROR RegistrationStatus = 1
)

func (RegistrationStatus) Descriptor 

func (RegistrationStatus) Descriptor() protoreflect.EnumDescriptor

func (RegistrationStatus) Enum 

func (x RegistrationStatus) Enum() *RegistrationStatus

func (RegistrationStatus) EnumDescriptor deprecated 

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

Deprecated: Use RegistrationStatus.Descriptor instead.

func (RegistrationStatus) Number 

func (x RegistrationStatus) Number() protoreflect.EnumNumber

func (RegistrationStatus) String 

func (x RegistrationStatus) String() string

func (RegistrationStatus) Type 

func (RegistrationStatus) Type() protoreflect.EnumType

type SiloServiceClient 

type SiloServiceClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
	PlaceGrain(ctx context.Context, in *PlaceGrainRequest, opts ...grpc.CallOption) (*PlaceGrainResponse, error)
	InvokeGrain(ctx context.Context, in *GrainInvocationRequest, opts ...grpc.CallOption) (*GrainInvocationResponse, error)
	RegisterGrainHandler(ctx context.Context, in *RegisterGrainHandlerRequest, opts ...grpc.CallOption) (SiloService_RegisterGrainHandlerClient, error)
	ResultStream(ctx context.Context, opts ...grpc.CallOption) (SiloService_ResultStreamClient, error)
	RegisterReminder(ctx context.Context, in *RegisterReminderRequest, opts ...grpc.CallOption) (*RegisterReminderResponse, error)
}

SiloServiceClient is the client API for SiloService 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 NewSiloServiceClient 

func NewSiloServiceClient(cc grpc.ClientConnInterface) SiloServiceClient

type SiloServiceServer 

type SiloServiceServer interface {
	Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
	PlaceGrain(context.Context, *PlaceGrainRequest) (*PlaceGrainResponse, error)
	InvokeGrain(context.Context, *GrainInvocationRequest) (*GrainInvocationResponse, error)
	RegisterGrainHandler(*RegisterGrainHandlerRequest, SiloService_RegisterGrainHandlerServer) error
	ResultStream(SiloService_ResultStreamServer) error
	RegisterReminder(context.Context, *RegisterReminderRequest) (*RegisterReminderResponse, error)
	// contains filtered or unexported methods
}

SiloServiceServer is the server API for SiloService service. All implementations must embed UnimplementedSiloServiceServer for forward compatibility

type SiloService_RegisterGrainHandlerClient 

type SiloService_RegisterGrainHandlerClient interface {
	Recv() (*GrainInvocationRequest, error)
	grpc.ClientStream
}

type SiloService_RegisterGrainHandlerServer 

type SiloService_RegisterGrainHandlerServer interface {
	Send(*GrainInvocationRequest) error
	grpc.ServerStream
}

type SiloService_ResultStreamClient 

type SiloService_ResultStreamClient interface {
	Send(*GrainInvocationResult) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type SiloService_ResultStreamServer 

type SiloService_ResultStreamServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*GrainInvocationResult, error)
	grpc.ServerStream
}

type SupportedGrainsResponse 

type SupportedGrainsResponse struct {
	GrainTypes []string `protobuf:"bytes,1,rep,name=grainTypes,proto3" json:"grainTypes,omitempty"`
	// contains filtered or unexported fields
}

func (*SupportedGrainsResponse) Descriptor deprecated 

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

Deprecated: Use SupportedGrainsResponse.ProtoReflect.Descriptor instead.

func (*SupportedGrainsResponse) GetGrainTypes 

func (x *SupportedGrainsResponse) GetGrainTypes() []string

func (*SupportedGrainsResponse) ProtoMessage 

func (*SupportedGrainsResponse) ProtoMessage()

func (*SupportedGrainsResponse) ProtoReflect 

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

func (*SupportedGrainsResponse) Reset 

func (x *SupportedGrainsResponse) Reset()

func (*SupportedGrainsResponse) String 

func (x *SupportedGrainsResponse) String() string

type UnimplementedSiloServiceServer 

type UnimplementedSiloServiceServer struct {
}

UnimplementedSiloServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSiloServiceServer) InvokeGrain 

func (UnimplementedSiloServiceServer) InvokeGrain(context.Context, *GrainInvocationRequest) (*GrainInvocationResponse, error)

func (UnimplementedSiloServiceServer) Ping 

func (UnimplementedSiloServiceServer) Ping(context.Context, *emptypb.Empty) (*PingResponse, error)

func (UnimplementedSiloServiceServer) PlaceGrain 

func (UnimplementedSiloServiceServer) PlaceGrain(context.Context, *PlaceGrainRequest) (*PlaceGrainResponse, error)

func (UnimplementedSiloServiceServer) RegisterGrainHandler 

func (UnimplementedSiloServiceServer) RegisterGrainHandler(*RegisterGrainHandlerRequest, SiloService_RegisterGrainHandlerServer) error

func (UnimplementedSiloServiceServer) RegisterReminder 

func (UnimplementedSiloServiceServer) RegisterReminder(context.Context, *RegisterReminderRequest) (*RegisterReminderResponse, error)

func (UnimplementedSiloServiceServer) ResultStream 

func (UnimplementedSiloServiceServer) ResultStream(SiloService_ResultStreamServer) error

type UnsafeSiloServiceServer 

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

UnsafeSiloServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SiloServiceServer 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.