entity

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CrdtWriteConsistency_name = map[int32]string{
		0: "LOCAL",
		1: "MAJORITY",
		2: "ALL",
	}
	CrdtWriteConsistency_value = map[string]int32{
		"LOCAL":    0,
		"MAJORITY": 1,
		"ALL":      2,
	}
)

Enum value maps for CrdtWriteConsistency.

View Source 
var (
	CrdtClock_name = map[int32]string{
		0: "DEFAULT",
		1: "REVERSE",
		2: "CUSTOM",
		3: "CUSTOM_AUTO_INCREMENT",
	}
	CrdtClock_value = map[string]int32{
		"DEFAULT":               0,
		"REVERSE":               1,
		"CUSTOM":                2,
		"CUSTOM_AUTO_INCREMENT": 3,
	}
)

Enum value maps for CrdtClock.

View Source 
var File_action_proto protoreflect.FileDescriptor
View Source 
var File_crdt_proto protoreflect.FileDescriptor
View Source 
var File_event_sourced_proto protoreflect.FileDescriptor
View Source 
var File_value_entity_proto protoreflect.FileDescriptor

Functions

func RegisterActionProtocolServer added in v0.3.0 

func RegisterActionProtocolServer(s grpc.ServiceRegistrar, srv ActionProtocolServer)

func RegisterCrdtServer 

func RegisterCrdtServer(s grpc.ServiceRegistrar, srv CrdtServer)

func RegisterEventSourcedServer 

func RegisterEventSourcedServer(s grpc.ServiceRegistrar, srv EventSourcedServer)

func RegisterValueEntityServer added in v0.3.0 

func RegisterValueEntityServer(s grpc.ServiceRegistrar, srv ValueEntityServer)

Types

type ActionCommand added in v0.3.0 

type ActionCommand struct {

	// The name of the service this action is on.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Command name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// The command payload.
	Payload *any.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Metadata
	Metadata *protocol.Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

An action command.

For unary and streamed out calls, the service name, command name and payload will always be set.

For streamed in and duplex streamed calls, the first command sent will just contain the service name and command name, but no payload. This will indicate that the action has been invoked. Subsequent commands on the stream will only have the payload set, the service name and command name will not be set.

func (*ActionCommand) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ActionCommand.ProtoReflect.Descriptor instead.

func (*ActionCommand) GetMetadata added in v0.3.0 

func (x *ActionCommand) GetMetadata() *protocol.Metadata

func (*ActionCommand) GetName added in v0.3.0 

func (x *ActionCommand) GetName() string

func (*ActionCommand) GetPayload added in v0.3.0 

func (x *ActionCommand) GetPayload() *any.Any

func (*ActionCommand) GetServiceName added in v0.3.0 

func (x *ActionCommand) GetServiceName() string

func (*ActionCommand) ProtoMessage added in v0.3.0 

func (*ActionCommand) ProtoMessage()

func (*ActionCommand) ProtoReflect added in v0.3.0 

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

func (*ActionCommand) Reset added in v0.3.0 

func (x *ActionCommand) Reset()

func (*ActionCommand) String added in v0.3.0 

func (x *ActionCommand) String() string

type ActionProtocolClient added in v0.3.0 

type ActionProtocolClient interface {
	// Handle a unary command.
	//
	// The input command will contain the service name, command name, request metadata and the command
	// payload. The reply may contain a direct reply, a forward or a failure, and it may contain many
	// side effects.
	HandleUnary(ctx context.Context, in *ActionCommand, opts ...grpc.CallOption) (*ActionResponse, error)
	// Handle a streamed in command.
	//
	// The first message in will contain the request metadata, including the service name and command
	// name. It will not have an associated payload set. This will be followed by zero to many messages
	// in with a payload, but no service name or command name set.
	//
	// If the underlying transport supports per stream metadata, rather than per message metadata, then
	// that metadata will only be included in the metadata of the first message. In contrast, if the
	// underlying transport supports per message metadata, there will be no metadata on the first message,
	// the metadata will instead be found on each subsequent message.
	//
	// The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure,
	// that is, when the client closes the stream, the stream is considered half closed, and the server
	// should eventually, but not necessarily immediately, send a response message with a status code and
	// trailers.
	//
	// If however the server sends a response message before the client closes the stream, the stream is
	// completely closed, and the client should handle this and stop sending more messages.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamedIn(ctx context.Context, opts ...grpc.CallOption) (ActionProtocol_HandleStreamedInClient, error)
	// Handle a streamed out command.
	//
	// The input command will contain the service name, command name, request metadata and the command
	// payload. Zero or more replies may be sent, each containing either a direct reply, a forward or a
	// failure, and each may contain many side effects. The stream to the client will be closed when the
	// this stream is closed, with the same status as this stream is closed with.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamedOut(ctx context.Context, in *ActionCommand, opts ...grpc.CallOption) (ActionProtocol_HandleStreamedOutClient, error)
	// Handle a full duplex streamed command.
	//
	// The first message in will contain the request metadata, including the service name and command
	// name. It will not have an associated payload set. This will be followed by zero to many messages
	// in with a payload, but no service name or command name set.
	//
	// Zero or more replies may be sent, each containing either a direct reply, a forward or a failure,
	// and each may contain many side effects.
	//
	// If the underlying transport supports per stream metadata, rather than per message metadata, then
	// that metadata will only be included in the metadata of the first message. In contrast, if the
	// underlying transport supports per message metadata, there will be no metadata on the first message,
	// the metadata will instead be found on each subsequent message.
	//
	// The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure,
	// that is, when the client closes the stream, the stream is considered half closed, and the server
	// should eventually, but not necessarily immediately, close the stream with a status code and
	// trailers.
	//
	// If however the server closes the stream with a status code and trailers, the stream is immediately
	// considered completely closed, and no further messages sent by the client will be handled by the
	// server.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamed(ctx context.Context, opts ...grpc.CallOption) (ActionProtocol_HandleStreamedClient, error)
}

ActionProtocolClient is the client API for ActionProtocol 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 NewActionProtocolClient added in v0.3.0 

func NewActionProtocolClient(cc grpc.ClientConnInterface) ActionProtocolClient

type ActionProtocolServer added in v0.3.0 

type ActionProtocolServer interface {
	// Handle a unary command.
	//
	// The input command will contain the service name, command name, request metadata and the command
	// payload. The reply may contain a direct reply, a forward or a failure, and it may contain many
	// side effects.
	HandleUnary(context.Context, *ActionCommand) (*ActionResponse, error)
	// Handle a streamed in command.
	//
	// The first message in will contain the request metadata, including the service name and command
	// name. It will not have an associated payload set. This will be followed by zero to many messages
	// in with a payload, but no service name or command name set.
	//
	// If the underlying transport supports per stream metadata, rather than per message metadata, then
	// that metadata will only be included in the metadata of the first message. In contrast, if the
	// underlying transport supports per message metadata, there will be no metadata on the first message,
	// the metadata will instead be found on each subsequent message.
	//
	// The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure,
	// that is, when the client closes the stream, the stream is considered half closed, and the server
	// should eventually, but not necessarily immediately, send a response message with a status code and
	// trailers.
	//
	// If however the server sends a response message before the client closes the stream, the stream is
	// completely closed, and the client should handle this and stop sending more messages.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamedIn(ActionProtocol_HandleStreamedInServer) error
	// Handle a streamed out command.
	//
	// The input command will contain the service name, command name, request metadata and the command
	// payload. Zero or more replies may be sent, each containing either a direct reply, a forward or a
	// failure, and each may contain many side effects. The stream to the client will be closed when the
	// this stream is closed, with the same status as this stream is closed with.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamedOut(*ActionCommand, ActionProtocol_HandleStreamedOutServer) error
	// Handle a full duplex streamed command.
	//
	// The first message in will contain the request metadata, including the service name and command
	// name. It will not have an associated payload set. This will be followed by zero to many messages
	// in with a payload, but no service name or command name set.
	//
	// Zero or more replies may be sent, each containing either a direct reply, a forward or a failure,
	// and each may contain many side effects.
	//
	// If the underlying transport supports per stream metadata, rather than per message metadata, then
	// that metadata will only be included in the metadata of the first message. In contrast, if the
	// underlying transport supports per message metadata, there will be no metadata on the first message,
	// the metadata will instead be found on each subsequent message.
	//
	// The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure,
	// that is, when the client closes the stream, the stream is considered half closed, and the server
	// should eventually, but not necessarily immediately, close the stream with a status code and
	// trailers.
	//
	// If however the server closes the stream with a status code and trailers, the stream is immediately
	// considered completely closed, and no further messages sent by the client will be handled by the
	// server.
	//
	// Either the client or the server may cancel the stream at any time, cancellation is indicated
	// through an HTTP2 stream RST message.
	HandleStreamed(ActionProtocol_HandleStreamedServer) error
	// contains filtered or unexported methods
}

ActionProtocolServer is the server API for ActionProtocol service. All implementations must embed UnimplementedActionProtocolServer for forward compatibility

type ActionProtocol_HandleStreamedClient added in v0.3.0 

type ActionProtocol_HandleStreamedClient interface {
	Send(*ActionCommand) error
	Recv() (*ActionResponse, error)
	grpc.ClientStream
}

type ActionProtocol_HandleStreamedInClient added in v0.3.0 

type ActionProtocol_HandleStreamedInClient interface {
	Send(*ActionCommand) error
	CloseAndRecv() (*ActionResponse, error)
	grpc.ClientStream
}

type ActionProtocol_HandleStreamedInServer added in v0.3.0 

type ActionProtocol_HandleStreamedInServer interface {
	SendAndClose(*ActionResponse) error
	Recv() (*ActionCommand, error)
	grpc.ServerStream
}

type ActionProtocol_HandleStreamedOutClient added in v0.3.0 

type ActionProtocol_HandleStreamedOutClient interface {
	Recv() (*ActionResponse, error)
	grpc.ClientStream
}

type ActionProtocol_HandleStreamedOutServer added in v0.3.0 

type ActionProtocol_HandleStreamedOutServer interface {
	Send(*ActionResponse) error
	grpc.ServerStream
}

type ActionProtocol_HandleStreamedServer added in v0.3.0 

type ActionProtocol_HandleStreamedServer interface {
	Send(*ActionResponse) error
	Recv() (*ActionCommand, error)
	grpc.ServerStream
}

type ActionResponse added in v0.3.0 

type ActionResponse struct {

	// Types that are assignable to Response:
	//	*ActionResponse_Failure
	//	*ActionResponse_Reply
	//	*ActionResponse_Forward
	Response    isActionResponse_Response `protobuf_oneof:"response"`
	SideEffects []*protocol.SideEffect    `protobuf:"bytes,4,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ActionResponse.ProtoReflect.Descriptor instead.

func (*ActionResponse) GetFailure added in v0.3.0 

func (x *ActionResponse) GetFailure() *protocol.Failure

func (*ActionResponse) GetForward added in v0.3.0 

func (x *ActionResponse) GetForward() *protocol.Forward

func (*ActionResponse) GetReply added in v0.3.0 

func (x *ActionResponse) GetReply() *protocol.Reply

func (*ActionResponse) GetResponse added in v0.3.0 

func (m *ActionResponse) GetResponse() isActionResponse_Response

func (*ActionResponse) GetSideEffects added in v0.3.0 

func (x *ActionResponse) GetSideEffects() []*protocol.SideEffect

func (*ActionResponse) ProtoMessage added in v0.3.0 

func (*ActionResponse) ProtoMessage()

func (*ActionResponse) ProtoReflect added in v0.3.0 

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

func (*ActionResponse) Reset added in v0.3.0 

func (x *ActionResponse) Reset()

func (*ActionResponse) String added in v0.3.0 

func (x *ActionResponse) String() string

type ActionResponse_Failure added in v0.3.0 

type ActionResponse_Failure struct {
	Failure *protocol.Failure `protobuf:"bytes,1,opt,name=failure,proto3,oneof"`
}

type ActionResponse_Forward added in v0.3.0 

type ActionResponse_Forward struct {
	Forward *protocol.Forward `protobuf:"bytes,3,opt,name=forward,proto3,oneof"`
}

type ActionResponse_Reply added in v0.3.0 

type ActionResponse_Reply struct {
	Reply *protocol.Reply `protobuf:"bytes,2,opt,name=reply,proto3,oneof"`
}

type CrdtClient 

type CrdtClient interface {
	// After invoking handle, the first message sent will always be a CrdtInit message, containing the entity ID, and,
	// if it exists or is available, a delta for the inital state of the entity. After that, one or more commands may
	// be sent, as well as deltas as they arrive.
	//
	// The user function must respond with one reply per command in. They do not necessarily have to be sent in the same
	// order that the commands were sent, the command ID is used to correlate commands to replies.
	Handle(ctx context.Context, opts ...grpc.CallOption) (Crdt_HandleClient, error)
}

CrdtClient is the client API for Crdt 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 NewCrdtClient 

func NewCrdtClient(cc grpc.ClientConnInterface) CrdtClient

type CrdtClock 

type CrdtClock int32
const (
	// Use the default clock for deciding the last write, which is the system clocks
	// milliseconds since epoch.
	CrdtClock_DEFAULT CrdtClock = 0
	// Use the reverse semantics with the default clock, to enable first write wins.
	CrdtClock_REVERSE CrdtClock = 1
	// Use a custom clock value, set using custom_clock_value.
	CrdtClock_CUSTOM CrdtClock = 2
	// Use a custom clock value, but automatically increment it by one if the clock
	// value from the current value is equal to the custom_clock_value.
	CrdtClock_CUSTOM_AUTO_INCREMENT CrdtClock = 3
)

func (CrdtClock) Descriptor 

func (CrdtClock) Descriptor() protoreflect.EnumDescriptor

func (CrdtClock) Enum 

func (x CrdtClock) Enum() *CrdtClock

func (CrdtClock) EnumDescriptor deprecated 

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

Deprecated: Use CrdtClock.Descriptor instead.

func (CrdtClock) Number 

func (x CrdtClock) Number() protoreflect.EnumNumber

func (CrdtClock) String 

func (x CrdtClock) String() string

func (CrdtClock) Type 

func (CrdtClock) Type() protoreflect.EnumType

type CrdtDelete 

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

func (*CrdtDelete) Descriptor deprecated 

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

Deprecated: Use CrdtDelete.ProtoReflect.Descriptor instead.

func (*CrdtDelete) ProtoMessage 

func (*CrdtDelete) ProtoMessage()

func (*CrdtDelete) ProtoReflect 

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

func (*CrdtDelete) Reset 

func (x *CrdtDelete) Reset()

func (*CrdtDelete) String 

func (x *CrdtDelete) String() string

type CrdtDelta 

type CrdtDelta struct {

	// Types that are assignable to Delta:
	//	*CrdtDelta_Gcounter
	//	*CrdtDelta_Pncounter
	//	*CrdtDelta_Gset
	//	*CrdtDelta_Orset
	//	*CrdtDelta_Lwwregister
	//	*CrdtDelta_Flag
	//	*CrdtDelta_Ormap
	//	*CrdtDelta_Vote
	Delta isCrdtDelta_Delta `protobuf_oneof:"delta"`
	// contains filtered or unexported fields
}

A CRDT delta

Deltas only carry the change in value to be applied to the current (possibly empty) state.

func (*CrdtDelta) Descriptor deprecated 

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

Deprecated: Use CrdtDelta.ProtoReflect.Descriptor instead.

func (*CrdtDelta) GetDelta 

func (m *CrdtDelta) GetDelta() isCrdtDelta_Delta

func (*CrdtDelta) GetFlag 

func (x *CrdtDelta) GetFlag() *FlagDelta

func (*CrdtDelta) GetGcounter 

func (x *CrdtDelta) GetGcounter() *GCounterDelta

func (*CrdtDelta) GetGset 

func (x *CrdtDelta) GetGset() *GSetDelta

func (*CrdtDelta) GetLwwregister 

func (x *CrdtDelta) GetLwwregister() *LWWRegisterDelta

func (*CrdtDelta) GetOrmap 

func (x *CrdtDelta) GetOrmap() *ORMapDelta

func (*CrdtDelta) GetOrset 

func (x *CrdtDelta) GetOrset() *ORSetDelta

func (*CrdtDelta) GetPncounter 

func (x *CrdtDelta) GetPncounter() *PNCounterDelta

func (*CrdtDelta) GetVote 

func (x *CrdtDelta) GetVote() *VoteDelta

func (*CrdtDelta) ProtoMessage 

func (*CrdtDelta) ProtoMessage()

func (*CrdtDelta) ProtoReflect 

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

func (*CrdtDelta) Reset 

func (x *CrdtDelta) Reset()

func (*CrdtDelta) String 

func (x *CrdtDelta) String() string

type CrdtDelta_Flag 

type CrdtDelta_Flag struct {
	Flag *FlagDelta `protobuf:"bytes,6,opt,name=flag,proto3,oneof"`
}

type CrdtDelta_Gcounter 

type CrdtDelta_Gcounter struct {
	Gcounter *GCounterDelta `protobuf:"bytes,1,opt,name=gcounter,proto3,oneof"`
}

type CrdtDelta_Gset 

type CrdtDelta_Gset struct {
	Gset *GSetDelta `protobuf:"bytes,3,opt,name=gset,proto3,oneof"`
}

type CrdtDelta_Lwwregister 

type CrdtDelta_Lwwregister struct {
	Lwwregister *LWWRegisterDelta `protobuf:"bytes,5,opt,name=lwwregister,proto3,oneof"`
}

type CrdtDelta_Ormap 

type CrdtDelta_Ormap struct {
	Ormap *ORMapDelta `protobuf:"bytes,7,opt,name=ormap,proto3,oneof"`
}

type CrdtDelta_Orset 

type CrdtDelta_Orset struct {
	Orset *ORSetDelta `protobuf:"bytes,4,opt,name=orset,proto3,oneof"`
}

type CrdtDelta_Pncounter 

type CrdtDelta_Pncounter struct {
	Pncounter *PNCounterDelta `protobuf:"bytes,2,opt,name=pncounter,proto3,oneof"`
}

type CrdtDelta_Vote 

type CrdtDelta_Vote struct {
	Vote *VoteDelta `protobuf:"bytes,8,opt,name=vote,proto3,oneof"`
}

type CrdtInit 

type CrdtInit struct {
	ServiceName string     `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	EntityId    string     `protobuf:"bytes,2,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	Delta       *CrdtDelta `protobuf:"bytes,3,opt,name=delta,proto3" json:"delta,omitempty"`
	// contains filtered or unexported fields
}

func (*CrdtInit) Descriptor deprecated 

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

Deprecated: Use CrdtInit.ProtoReflect.Descriptor instead.

func (*CrdtInit) GetDelta added in v0.3.0 

func (x *CrdtInit) GetDelta() *CrdtDelta

func (*CrdtInit) GetEntityId 

func (x *CrdtInit) GetEntityId() string

func (*CrdtInit) GetServiceName 

func (x *CrdtInit) GetServiceName() string

func (*CrdtInit) ProtoMessage 

func (*CrdtInit) ProtoMessage()

func (*CrdtInit) ProtoReflect 

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

func (*CrdtInit) Reset 

func (x *CrdtInit) Reset()

func (*CrdtInit) String 

func (x *CrdtInit) String() string

type CrdtReply 

type CrdtReply struct {
	CommandId    int64                  `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	ClientAction *protocol.ClientAction `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	SideEffects  []*protocol.SideEffect `protobuf:"bytes,4,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	StateAction  *CrdtStateAction       `protobuf:"bytes,5,opt,name=state_action,json=stateAction,proto3" json:"state_action,omitempty"`
	// If the request was streamed, setting this to true indicates that the command should
	// be handled as a stream. Subsequently, the user function may send CrdtStreamedMessage,
	// and a CrdtStreamCancelled message will be sent if the stream is cancelled (though
	// not if the a CrdtStreamedMessage ends the stream first).
	Streamed bool `protobuf:"varint,6,opt,name=streamed,proto3" json:"streamed,omitempty"`
	// contains filtered or unexported fields
}

func (*CrdtReply) Descriptor deprecated 

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

Deprecated: Use CrdtReply.ProtoReflect.Descriptor instead.

func (*CrdtReply) GetClientAction 

func (x *CrdtReply) GetClientAction() *protocol.ClientAction

func (*CrdtReply) GetCommandId 

func (x *CrdtReply) GetCommandId() int64

func (*CrdtReply) GetSideEffects 

func (x *CrdtReply) GetSideEffects() []*protocol.SideEffect

func (*CrdtReply) GetStateAction 

func (x *CrdtReply) GetStateAction() *CrdtStateAction

func (*CrdtReply) GetStreamed 

func (x *CrdtReply) GetStreamed() bool

func (*CrdtReply) ProtoMessage 

func (*CrdtReply) ProtoMessage()

func (*CrdtReply) ProtoReflect 

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

func (*CrdtReply) Reset 

func (x *CrdtReply) Reset()

func (*CrdtReply) String 

func (x *CrdtReply) String() string

type CrdtServer 

type CrdtServer interface {
	// After invoking handle, the first message sent will always be a CrdtInit message, containing the entity ID, and,
	// if it exists or is available, a delta for the inital state of the entity. After that, one or more commands may
	// be sent, as well as deltas as they arrive.
	//
	// The user function must respond with one reply per command in. They do not necessarily have to be sent in the same
	// order that the commands were sent, the command ID is used to correlate commands to replies.
	Handle(Crdt_HandleServer) error
	// contains filtered or unexported methods
}

CrdtServer is the server API for Crdt service. All implementations must embed UnimplementedCrdtServer for forward compatibility

type CrdtStateAction 

type CrdtStateAction struct {

	// Types that are assignable to Action:
	//	*CrdtStateAction_Update
	//	*CrdtStateAction_Delete
	Action           isCrdtStateAction_Action `protobuf_oneof:"action"`
	WriteConsistency CrdtWriteConsistency     `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CrdtStateAction) Descriptor deprecated 

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

Deprecated: Use CrdtStateAction.ProtoReflect.Descriptor instead.

func (*CrdtStateAction) GetAction 

func (m *CrdtStateAction) GetAction() isCrdtStateAction_Action

func (*CrdtStateAction) GetDelete 

func (x *CrdtStateAction) GetDelete() *CrdtDelete

func (*CrdtStateAction) GetUpdate 

func (x *CrdtStateAction) GetUpdate() *CrdtDelta

func (*CrdtStateAction) GetWriteConsistency 

func (x *CrdtStateAction) GetWriteConsistency() CrdtWriteConsistency

func (*CrdtStateAction) ProtoMessage 

func (*CrdtStateAction) ProtoMessage()

func (*CrdtStateAction) ProtoReflect 

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

func (*CrdtStateAction) Reset 

func (x *CrdtStateAction) Reset()

func (*CrdtStateAction) String 

func (x *CrdtStateAction) String() string

type CrdtStateAction_Delete 

type CrdtStateAction_Delete struct {
	Delete *CrdtDelete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type CrdtStateAction_Update 

type CrdtStateAction_Update struct {
	Update *CrdtDelta `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type CrdtStreamCancelledResponse 

type CrdtStreamCancelledResponse struct {
	CommandId   int64                  `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	SideEffects []*protocol.SideEffect `protobuf:"bytes,2,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	StateAction *CrdtStateAction       `protobuf:"bytes,3,opt,name=state_action,json=stateAction,proto3" json:"state_action,omitempty"`
	// contains filtered or unexported fields
}

func (*CrdtStreamCancelledResponse) Descriptor deprecated 

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

Deprecated: Use CrdtStreamCancelledResponse.ProtoReflect.Descriptor instead.

func (*CrdtStreamCancelledResponse) GetCommandId 

func (x *CrdtStreamCancelledResponse) GetCommandId() int64

func (*CrdtStreamCancelledResponse) GetSideEffects 

func (x *CrdtStreamCancelledResponse) GetSideEffects() []*protocol.SideEffect

func (*CrdtStreamCancelledResponse) GetStateAction 

func (x *CrdtStreamCancelledResponse) GetStateAction() *CrdtStateAction

func (*CrdtStreamCancelledResponse) ProtoMessage 

func (*CrdtStreamCancelledResponse) ProtoMessage()

func (*CrdtStreamCancelledResponse) ProtoReflect 

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

func (*CrdtStreamCancelledResponse) Reset 

func (x *CrdtStreamCancelledResponse) Reset()

func (*CrdtStreamCancelledResponse) String 

func (x *CrdtStreamCancelledResponse) String() string

type CrdtStreamIn 

type CrdtStreamIn struct {

	// Types that are assignable to Message:
	//	*CrdtStreamIn_Init
	//	*CrdtStreamIn_Delta
	//	*CrdtStreamIn_Delete
	//	*CrdtStreamIn_Command
	//	*CrdtStreamIn_StreamCancelled
	Message isCrdtStreamIn_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Message for the Crdt handle stream in.

func (*CrdtStreamIn) Descriptor deprecated 

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

Deprecated: Use CrdtStreamIn.ProtoReflect.Descriptor instead.

func (*CrdtStreamIn) GetCommand 

func (x *CrdtStreamIn) GetCommand() *protocol.Command

func (*CrdtStreamIn) GetDelete added in v0.3.0 

func (x *CrdtStreamIn) GetDelete() *CrdtDelete

func (*CrdtStreamIn) GetDelta added in v0.3.0 

func (x *CrdtStreamIn) GetDelta() *CrdtDelta

func (*CrdtStreamIn) GetInit 

func (x *CrdtStreamIn) GetInit() *CrdtInit

func (*CrdtStreamIn) GetMessage 

func (m *CrdtStreamIn) GetMessage() isCrdtStreamIn_Message

func (*CrdtStreamIn) GetStreamCancelled 

func (x *CrdtStreamIn) GetStreamCancelled() *protocol.StreamCancelled

func (*CrdtStreamIn) ProtoMessage 

func (*CrdtStreamIn) ProtoMessage()

func (*CrdtStreamIn) ProtoReflect 

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

func (*CrdtStreamIn) Reset 

func (x *CrdtStreamIn) Reset()

func (*CrdtStreamIn) String 

func (x *CrdtStreamIn) String() string

type CrdtStreamIn_Command 

type CrdtStreamIn_Command struct {
	// A command, may be sent at any time.
	Command *protocol.Command `protobuf:"bytes,4,opt,name=command,proto3,oneof"`
}

type CrdtStreamIn_Delete added in v0.3.0 

type CrdtStreamIn_Delete struct {
	// Delete the entity. May be sent at any time. The user function should clear its state when it receives this.
	// A proxy may decide to terminate the stream after sending this.
	Delete *CrdtDelete `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type CrdtStreamIn_Delta added in v0.3.0 

type CrdtStreamIn_Delta struct {
	// A delta to be applied to the current state. May be sent at any time.
	Delta *CrdtDelta `protobuf:"bytes,2,opt,name=delta,proto3,oneof"`
}

type CrdtStreamIn_Init 

type CrdtStreamIn_Init struct {
	// Always sent first, and only once.
	Init *CrdtInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type CrdtStreamIn_StreamCancelled 

type CrdtStreamIn_StreamCancelled struct {
	// A stream has been cancelled.
	StreamCancelled *protocol.StreamCancelled `protobuf:"bytes,5,opt,name=stream_cancelled,json=streamCancelled,proto3,oneof"`
}

type CrdtStreamOut 

type CrdtStreamOut struct {

	// Types that are assignable to Message:
	//	*CrdtStreamOut_Reply
	//	*CrdtStreamOut_StreamedMessage
	//	*CrdtStreamOut_StreamCancelledResponse
	//	*CrdtStreamOut_Failure
	Message isCrdtStreamOut_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Message for the Crdt handle stream out.

func (*CrdtStreamOut) Descriptor deprecated 

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

Deprecated: Use CrdtStreamOut.ProtoReflect.Descriptor instead.

func (*CrdtStreamOut) GetFailure 

func (x *CrdtStreamOut) GetFailure() *protocol.Failure

func (*CrdtStreamOut) GetMessage 

func (m *CrdtStreamOut) GetMessage() isCrdtStreamOut_Message

func (*CrdtStreamOut) GetReply 

func (x *CrdtStreamOut) GetReply() *CrdtReply

func (*CrdtStreamOut) GetStreamCancelledResponse 

func (x *CrdtStreamOut) GetStreamCancelledResponse() *CrdtStreamCancelledResponse

func (*CrdtStreamOut) GetStreamedMessage 

func (x *CrdtStreamOut) GetStreamedMessage() *CrdtStreamedMessage

func (*CrdtStreamOut) ProtoMessage 

func (*CrdtStreamOut) ProtoMessage()

func (*CrdtStreamOut) ProtoReflect 

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

func (*CrdtStreamOut) Reset 

func (x *CrdtStreamOut) Reset()

func (*CrdtStreamOut) String 

func (x *CrdtStreamOut) String() string

type CrdtStreamOut_Failure 

type CrdtStreamOut_Failure struct {
	// A failure. Either sent in response to a command, or sent if some other error occurs.
	Failure *protocol.Failure `protobuf:"bytes,4,opt,name=failure,proto3,oneof"`
}

type CrdtStreamOut_Reply 

type CrdtStreamOut_Reply struct {
	// A reply to an incoming command. Either one reply, or one failure, must be sent in response to each command.
	Reply *CrdtReply `protobuf:"bytes,1,opt,name=reply,proto3,oneof"`
}

type CrdtStreamOut_StreamCancelledResponse 

type CrdtStreamOut_StreamCancelledResponse struct {
	// A stream cancelled response, may be sent in response to stream_cancelled.
	StreamCancelledResponse *CrdtStreamCancelledResponse `protobuf:"bytes,3,opt,name=stream_cancelled_response,json=streamCancelledResponse,proto3,oneof"`
}

type CrdtStreamOut_StreamedMessage 

type CrdtStreamOut_StreamedMessage struct {
	// A streamed message.
	StreamedMessage *CrdtStreamedMessage `protobuf:"bytes,2,opt,name=streamed_message,json=streamedMessage,proto3,oneof"`
}

type CrdtStreamedMessage 

type CrdtStreamedMessage struct {
	CommandId    int64                  `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	ClientAction *protocol.ClientAction `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	SideEffects  []*protocol.SideEffect `protobuf:"bytes,3,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	// Indicates the stream should end, no messages may be sent for this command after this.
	EndStream bool `protobuf:"varint,4,opt,name=end_stream,json=endStream,proto3" json:"end_stream,omitempty"`
	// contains filtered or unexported fields
}

May be sent as often as liked if the first reply set streamed to true

func (*CrdtStreamedMessage) Descriptor deprecated 

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

Deprecated: Use CrdtStreamedMessage.ProtoReflect.Descriptor instead.

func (*CrdtStreamedMessage) GetClientAction 

func (x *CrdtStreamedMessage) GetClientAction() *protocol.ClientAction

func (*CrdtStreamedMessage) GetCommandId 

func (x *CrdtStreamedMessage) GetCommandId() int64

func (*CrdtStreamedMessage) GetEndStream 

func (x *CrdtStreamedMessage) GetEndStream() bool

func (*CrdtStreamedMessage) GetSideEffects 

func (x *CrdtStreamedMessage) GetSideEffects() []*protocol.SideEffect

func (*CrdtStreamedMessage) ProtoMessage 

func (*CrdtStreamedMessage) ProtoMessage()

func (*CrdtStreamedMessage) ProtoReflect 

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

func (*CrdtStreamedMessage) Reset 

func (x *CrdtStreamedMessage) Reset()

func (*CrdtStreamedMessage) String 

func (x *CrdtStreamedMessage) String() string

type CrdtWriteConsistency 

type CrdtWriteConsistency int32
const (
	CrdtWriteConsistency_LOCAL    CrdtWriteConsistency = 0
	CrdtWriteConsistency_MAJORITY CrdtWriteConsistency = 1
	CrdtWriteConsistency_ALL      CrdtWriteConsistency = 2
)

func (CrdtWriteConsistency) Descriptor 

func (CrdtWriteConsistency) Descriptor() protoreflect.EnumDescriptor

func (CrdtWriteConsistency) Enum 

func (x CrdtWriteConsistency) Enum() *CrdtWriteConsistency

func (CrdtWriteConsistency) EnumDescriptor deprecated 

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

Deprecated: Use CrdtWriteConsistency.Descriptor instead.

func (CrdtWriteConsistency) Number 

func (x CrdtWriteConsistency) Number() protoreflect.EnumNumber

func (CrdtWriteConsistency) String 

func (x CrdtWriteConsistency) String() string

func (CrdtWriteConsistency) Type 

func (CrdtWriteConsistency) Type() protoreflect.EnumType

type Crdt_HandleClient 

type Crdt_HandleClient interface {
	Send(*CrdtStreamIn) error
	Recv() (*CrdtStreamOut, error)
	grpc.ClientStream
}

type Crdt_HandleServer 

type Crdt_HandleServer interface {
	Send(*CrdtStreamOut) error
	Recv() (*CrdtStreamIn, error)
	grpc.ServerStream
}

type EventSourcedClient 

type EventSourcedClient interface {
	// The stream. One stream will be established per active entity.
	// Once established, the first message sent will be Init, which contains the entity ID, and,
	// if the entity has previously persisted a snapshot, it will contain that snapshot. It will
	// then send zero to many event messages, one for each event previously persisted. The entity
	// is expected to apply these to its state in a deterministic fashion. Once all the events
	// are sent, one to many commands are sent, with new commands being sent as new requests for
	// the entity come in. The entity is expected to reply to each command with exactly one reply
	// message. The entity should reply in order, and any events that the entity requests to be
	// persisted the entity should handle itself, applying them to its own state, as if they had
	// arrived as events when the event stream was being replayed on load.
	Handle(ctx context.Context, opts ...grpc.CallOption) (EventSourced_HandleClient, error)
}

EventSourcedClient is the client API for EventSourced 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 NewEventSourcedClient 

func NewEventSourcedClient(cc grpc.ClientConnInterface) EventSourcedClient

type EventSourcedEvent 

type EventSourcedEvent struct {

	// The sequence number of the event.
	Sequence int64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// The event payload.
	Payload *any.Any `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

An event. These will be sent to the entity when the entity starts up.

func (*EventSourcedEvent) Descriptor deprecated 

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

Deprecated: Use EventSourcedEvent.ProtoReflect.Descriptor instead.

func (*EventSourcedEvent) GetPayload 

func (x *EventSourcedEvent) GetPayload() *any.Any

func (*EventSourcedEvent) GetSequence 

func (x *EventSourcedEvent) GetSequence() int64

func (*EventSourcedEvent) ProtoMessage 

func (*EventSourcedEvent) ProtoMessage()

func (*EventSourcedEvent) ProtoReflect 

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

func (*EventSourcedEvent) Reset 

func (x *EventSourcedEvent) Reset()

func (*EventSourcedEvent) String 

func (x *EventSourcedEvent) String() string

type EventSourcedInit 

type EventSourcedInit struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The ID of the entity.
	EntityId string `protobuf:"bytes,2,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// If present the entity should initialise its state using this snapshot.
	Snapshot *EventSourcedSnapshot `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

The init message. This will always be the first message sent to the entity when it is loaded.

func (*EventSourcedInit) Descriptor deprecated 

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

Deprecated: Use EventSourcedInit.ProtoReflect.Descriptor instead.

func (*EventSourcedInit) GetEntityId 

func (x *EventSourcedInit) GetEntityId() string

func (*EventSourcedInit) GetServiceName 

func (x *EventSourcedInit) GetServiceName() string

func (*EventSourcedInit) GetSnapshot 

func (x *EventSourcedInit) GetSnapshot() *EventSourcedSnapshot

func (*EventSourcedInit) ProtoMessage 

func (*EventSourcedInit) ProtoMessage()

func (*EventSourcedInit) ProtoReflect 

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

func (*EventSourcedInit) Reset 

func (x *EventSourcedInit) Reset()

func (*EventSourcedInit) String 

func (x *EventSourcedInit) String() string

type EventSourcedReply 

type EventSourcedReply struct {

	// The id of the command being replied to. Must match the input command.
	CommandId int64 `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// The action to take
	ClientAction *protocol.ClientAction `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	// Any side effects to perform
	SideEffects []*protocol.SideEffect `protobuf:"bytes,3,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	// A list of events to persist - these will be persisted before the reply
	// is sent.
	Events []*any.Any `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	// An optional snapshot to persist. It is assumed that this snapshot will have
	// the state of any events in the events field applied to it. It is illegal to
	// send a snapshot without sending any events.
	Snapshot *any.Any `protobuf:"bytes,5,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

A reply to a command.

func (*EventSourcedReply) Descriptor deprecated 

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

Deprecated: Use EventSourcedReply.ProtoReflect.Descriptor instead.

func (*EventSourcedReply) GetClientAction 

func (x *EventSourcedReply) GetClientAction() *protocol.ClientAction

func (*EventSourcedReply) GetCommandId 

func (x *EventSourcedReply) GetCommandId() int64

func (*EventSourcedReply) GetEvents 

func (x *EventSourcedReply) GetEvents() []*any.Any

func (*EventSourcedReply) GetSideEffects 

func (x *EventSourcedReply) GetSideEffects() []*protocol.SideEffect

func (*EventSourcedReply) GetSnapshot 

func (x *EventSourcedReply) GetSnapshot() *any.Any

func (*EventSourcedReply) ProtoMessage 

func (*EventSourcedReply) ProtoMessage()

func (*EventSourcedReply) ProtoReflect 

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

func (*EventSourcedReply) Reset 

func (x *EventSourcedReply) Reset()

func (*EventSourcedReply) String 

func (x *EventSourcedReply) String() string

type EventSourcedServer 

type EventSourcedServer interface {
	// The stream. One stream will be established per active entity.
	// Once established, the first message sent will be Init, which contains the entity ID, and,
	// if the entity has previously persisted a snapshot, it will contain that snapshot. It will
	// then send zero to many event messages, one for each event previously persisted. The entity
	// is expected to apply these to its state in a deterministic fashion. Once all the events
	// are sent, one to many commands are sent, with new commands being sent as new requests for
	// the entity come in. The entity is expected to reply to each command with exactly one reply
	// message. The entity should reply in order, and any events that the entity requests to be
	// persisted the entity should handle itself, applying them to its own state, as if they had
	// arrived as events when the event stream was being replayed on load.
	Handle(EventSourced_HandleServer) error
	// contains filtered or unexported methods
}

EventSourcedServer is the server API for EventSourced service. All implementations must embed UnimplementedEventSourcedServer for forward compatibility

type EventSourcedSnapshot 

type EventSourcedSnapshot struct {

	// The sequence number when the snapshot was taken.
	SnapshotSequence int64 `protobuf:"varint,1,opt,name=snapshot_sequence,json=snapshotSequence,proto3" json:"snapshot_sequence,omitempty"`
	// The snapshot.
	Snapshot *any.Any `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

A snapshot

func (*EventSourcedSnapshot) Descriptor deprecated 

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

Deprecated: Use EventSourcedSnapshot.ProtoReflect.Descriptor instead.

func (*EventSourcedSnapshot) GetSnapshot 

func (x *EventSourcedSnapshot) GetSnapshot() *any.Any

func (*EventSourcedSnapshot) GetSnapshotSequence 

func (x *EventSourcedSnapshot) GetSnapshotSequence() int64

func (*EventSourcedSnapshot) ProtoMessage 

func (*EventSourcedSnapshot) ProtoMessage()

func (*EventSourcedSnapshot) ProtoReflect 

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

func (*EventSourcedSnapshot) Reset 

func (x *EventSourcedSnapshot) Reset()

func (*EventSourcedSnapshot) String 

func (x *EventSourcedSnapshot) String() string

type EventSourcedStreamIn 

type EventSourcedStreamIn struct {

	// Types that are assignable to Message:
	//	*EventSourcedStreamIn_Init
	//	*EventSourcedStreamIn_Event
	//	*EventSourcedStreamIn_Command
	Message isEventSourcedStreamIn_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Input message type for the gRPC stream in.

func (*EventSourcedStreamIn) Descriptor deprecated 

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

Deprecated: Use EventSourcedStreamIn.ProtoReflect.Descriptor instead.

func (*EventSourcedStreamIn) GetCommand 

func (x *EventSourcedStreamIn) GetCommand() *protocol.Command

func (*EventSourcedStreamIn) GetEvent 

func (x *EventSourcedStreamIn) GetEvent() *EventSourcedEvent

func (*EventSourcedStreamIn) GetInit 

func (x *EventSourcedStreamIn) GetInit() *EventSourcedInit

func (*EventSourcedStreamIn) GetMessage 

func (m *EventSourcedStreamIn) GetMessage() isEventSourcedStreamIn_Message

func (*EventSourcedStreamIn) ProtoMessage 

func (*EventSourcedStreamIn) ProtoMessage()

func (*EventSourcedStreamIn) ProtoReflect 

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

func (*EventSourcedStreamIn) Reset 

func (x *EventSourcedStreamIn) Reset()

func (*EventSourcedStreamIn) String 

func (x *EventSourcedStreamIn) String() string

type EventSourcedStreamIn_Command 

type EventSourcedStreamIn_Command struct {
	Command *protocol.Command `protobuf:"bytes,3,opt,name=command,proto3,oneof"`
}

type EventSourcedStreamIn_Event 

type EventSourcedStreamIn_Event struct {
	Event *EventSourcedEvent `protobuf:"bytes,2,opt,name=event,proto3,oneof"`
}

type EventSourcedStreamIn_Init 

type EventSourcedStreamIn_Init struct {
	Init *EventSourcedInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type EventSourcedStreamOut 

type EventSourcedStreamOut struct {

	// Types that are assignable to Message:
	//	*EventSourcedStreamOut_Reply
	//	*EventSourcedStreamOut_Failure
	Message isEventSourcedStreamOut_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Output message type for the gRPC stream out.

func (*EventSourcedStreamOut) Descriptor deprecated 

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

Deprecated: Use EventSourcedStreamOut.ProtoReflect.Descriptor instead.

func (*EventSourcedStreamOut) GetFailure 

func (x *EventSourcedStreamOut) GetFailure() *protocol.Failure

func (*EventSourcedStreamOut) GetMessage 

func (m *EventSourcedStreamOut) GetMessage() isEventSourcedStreamOut_Message

func (*EventSourcedStreamOut) GetReply 

func (x *EventSourcedStreamOut) GetReply() *EventSourcedReply

func (*EventSourcedStreamOut) ProtoMessage 

func (*EventSourcedStreamOut) ProtoMessage()

func (*EventSourcedStreamOut) ProtoReflect 

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

func (*EventSourcedStreamOut) Reset 

func (x *EventSourcedStreamOut) Reset()

func (*EventSourcedStreamOut) String 

func (x *EventSourcedStreamOut) String() string

type EventSourcedStreamOut_Failure 

type EventSourcedStreamOut_Failure struct {
	Failure *protocol.Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type EventSourcedStreamOut_Reply 

type EventSourcedStreamOut_Reply struct {
	Reply *EventSourcedReply `protobuf:"bytes,1,opt,name=reply,proto3,oneof"`
}

type EventSourced_HandleClient 

type EventSourced_HandleClient interface {
	Send(*EventSourcedStreamIn) error
	Recv() (*EventSourcedStreamOut, error)
	grpc.ClientStream
}

type EventSourced_HandleServer 

type EventSourced_HandleServer interface {
	Send(*EventSourcedStreamOut) error
	Recv() (*EventSourcedStreamIn, error)
	grpc.ServerStream
}

type FlagDelta 

type FlagDelta struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FlagDelta) Descriptor deprecated 

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

Deprecated: Use FlagDelta.ProtoReflect.Descriptor instead.

func (*FlagDelta) GetValue 

func (x *FlagDelta) GetValue() bool

func (*FlagDelta) ProtoMessage 

func (*FlagDelta) ProtoMessage()

func (*FlagDelta) ProtoReflect 

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

func (*FlagDelta) Reset 

func (x *FlagDelta) Reset()

func (*FlagDelta) String 

func (x *FlagDelta) String() string

type GCounterDelta 

type GCounterDelta struct {
	Increment uint64 `protobuf:"varint,1,opt,name=increment,proto3" json:"increment,omitempty"`
	// contains filtered or unexported fields
}

func (*GCounterDelta) Descriptor deprecated 

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

Deprecated: Use GCounterDelta.ProtoReflect.Descriptor instead.

func (*GCounterDelta) GetIncrement 

func (x *GCounterDelta) GetIncrement() uint64

func (*GCounterDelta) ProtoMessage 

func (*GCounterDelta) ProtoMessage()

func (*GCounterDelta) ProtoReflect 

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

func (*GCounterDelta) Reset 

func (x *GCounterDelta) Reset()

func (*GCounterDelta) String 

func (x *GCounterDelta) String() string

type GSetDelta 

type GSetDelta struct {
	Added []*any.Any `protobuf:"bytes,1,rep,name=added,proto3" json:"added,omitempty"`
	// contains filtered or unexported fields
}

func (*GSetDelta) Descriptor deprecated 

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

Deprecated: Use GSetDelta.ProtoReflect.Descriptor instead.

func (*GSetDelta) GetAdded 

func (x *GSetDelta) GetAdded() []*any.Any

func (*GSetDelta) ProtoMessage 

func (*GSetDelta) ProtoMessage()

func (*GSetDelta) ProtoReflect 

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

func (*GSetDelta) Reset 

func (x *GSetDelta) Reset()

func (*GSetDelta) String 

func (x *GSetDelta) String() string

type LWWRegisterDelta 

type LWWRegisterDelta struct {
	Value            *any.Any  `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Clock            CrdtClock `protobuf:"varint,2,opt,name=clock,proto3,enum=cloudstate.crdt.CrdtClock" json:"clock,omitempty"`
	CustomClockValue int64     `protobuf:"varint,3,opt,name=custom_clock_value,json=customClockValue,proto3" json:"custom_clock_value,omitempty"`
	// contains filtered or unexported fields
}

func (*LWWRegisterDelta) Descriptor deprecated 

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

Deprecated: Use LWWRegisterDelta.ProtoReflect.Descriptor instead.

func (*LWWRegisterDelta) GetClock 

func (x *LWWRegisterDelta) GetClock() CrdtClock

func (*LWWRegisterDelta) GetCustomClockValue 

func (x *LWWRegisterDelta) GetCustomClockValue() int64

func (*LWWRegisterDelta) GetValue 

func (x *LWWRegisterDelta) GetValue() *any.Any

func (*LWWRegisterDelta) ProtoMessage 

func (*LWWRegisterDelta) ProtoMessage()

func (*LWWRegisterDelta) ProtoReflect 

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

func (*LWWRegisterDelta) Reset 

func (x *LWWRegisterDelta) Reset()

func (*LWWRegisterDelta) String 

func (x *LWWRegisterDelta) String() string

type ORMapDelta 

type ORMapDelta struct {
	Cleared bool               `protobuf:"varint,1,opt,name=cleared,proto3" json:"cleared,omitempty"`
	Removed []*any.Any         `protobuf:"bytes,2,rep,name=removed,proto3" json:"removed,omitempty"`
	Updated []*ORMapEntryDelta `protobuf:"bytes,3,rep,name=updated,proto3" json:"updated,omitempty"`
	Added   []*ORMapEntryDelta `protobuf:"bytes,4,rep,name=added,proto3" json:"added,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapDelta) Descriptor deprecated 

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

Deprecated: Use ORMapDelta.ProtoReflect.Descriptor instead.

func (*ORMapDelta) GetAdded 

func (x *ORMapDelta) GetAdded() []*ORMapEntryDelta

func (*ORMapDelta) GetCleared 

func (x *ORMapDelta) GetCleared() bool

func (*ORMapDelta) GetRemoved 

func (x *ORMapDelta) GetRemoved() []*any.Any

func (*ORMapDelta) GetUpdated 

func (x *ORMapDelta) GetUpdated() []*ORMapEntryDelta

func (*ORMapDelta) ProtoMessage 

func (*ORMapDelta) ProtoMessage()

func (*ORMapDelta) ProtoReflect 

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

func (*ORMapDelta) Reset 

func (x *ORMapDelta) Reset()

func (*ORMapDelta) String 

func (x *ORMapDelta) String() string

type ORMapEntryDelta 

type ORMapEntryDelta struct {

	// The entry key.
	Key   *any.Any   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Delta *CrdtDelta `protobuf:"bytes,2,opt,name=delta,proto3" json:"delta,omitempty"`
	// contains filtered or unexported fields
}

func (*ORMapEntryDelta) Descriptor deprecated 

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

Deprecated: Use ORMapEntryDelta.ProtoReflect.Descriptor instead.

func (*ORMapEntryDelta) GetDelta 

func (x *ORMapEntryDelta) GetDelta() *CrdtDelta

func (*ORMapEntryDelta) GetKey 

func (x *ORMapEntryDelta) GetKey() *any.Any

func (*ORMapEntryDelta) ProtoMessage 

func (*ORMapEntryDelta) ProtoMessage()

func (*ORMapEntryDelta) ProtoReflect 

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

func (*ORMapEntryDelta) Reset 

func (x *ORMapEntryDelta) Reset()

func (*ORMapEntryDelta) String 

func (x *ORMapEntryDelta) String() string

type ORSetDelta 

type ORSetDelta struct {

	// If cleared is set, the set must be cleared before added is processed.
	Cleared bool       `protobuf:"varint,1,opt,name=cleared,proto3" json:"cleared,omitempty"`
	Removed []*any.Any `protobuf:"bytes,2,rep,name=removed,proto3" json:"removed,omitempty"`
	Added   []*any.Any `protobuf:"bytes,3,rep,name=added,proto3" json:"added,omitempty"`
	// contains filtered or unexported fields
}

func (*ORSetDelta) Descriptor deprecated 

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

Deprecated: Use ORSetDelta.ProtoReflect.Descriptor instead.

func (*ORSetDelta) GetAdded 

func (x *ORSetDelta) GetAdded() []*any.Any

func (*ORSetDelta) GetCleared 

func (x *ORSetDelta) GetCleared() bool

func (*ORSetDelta) GetRemoved 

func (x *ORSetDelta) GetRemoved() []*any.Any

func (*ORSetDelta) ProtoMessage 

func (*ORSetDelta) ProtoMessage()

func (*ORSetDelta) ProtoReflect 

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

func (*ORSetDelta) Reset 

func (x *ORSetDelta) Reset()

func (*ORSetDelta) String 

func (x *ORSetDelta) String() string

type PNCounterDelta 

type PNCounterDelta struct {
	Change int64 `protobuf:"zigzag64,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

func (*PNCounterDelta) Descriptor deprecated 

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

Deprecated: Use PNCounterDelta.ProtoReflect.Descriptor instead.

func (*PNCounterDelta) GetChange 

func (x *PNCounterDelta) GetChange() int64

func (*PNCounterDelta) ProtoMessage 

func (*PNCounterDelta) ProtoMessage()

func (*PNCounterDelta) ProtoReflect 

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

func (*PNCounterDelta) Reset 

func (x *PNCounterDelta) Reset()

func (*PNCounterDelta) String 

func (x *PNCounterDelta) String() string

type UnimplementedActionProtocolServer added in v0.3.0 

type UnimplementedActionProtocolServer struct {
}

UnimplementedActionProtocolServer must be embedded to have forward compatible implementations.

func (UnimplementedActionProtocolServer) HandleStreamed added in v0.3.0 

func (UnimplementedActionProtocolServer) HandleStreamed(ActionProtocol_HandleStreamedServer) error

func (UnimplementedActionProtocolServer) HandleStreamedIn added in v0.3.0 

func (UnimplementedActionProtocolServer) HandleStreamedIn(ActionProtocol_HandleStreamedInServer) error

func (UnimplementedActionProtocolServer) HandleStreamedOut added in v0.3.0 

func (UnimplementedActionProtocolServer) HandleStreamedOut(*ActionCommand, ActionProtocol_HandleStreamedOutServer) error

func (UnimplementedActionProtocolServer) HandleUnary added in v0.3.0 

func (UnimplementedActionProtocolServer) HandleUnary(context.Context, *ActionCommand) (*ActionResponse, error)

type UnimplementedCrdtServer 

type UnimplementedCrdtServer struct {
}

UnimplementedCrdtServer must be embedded to have forward compatible implementations.

func (UnimplementedCrdtServer) Handle 

func (UnimplementedCrdtServer) Handle(Crdt_HandleServer) error

type UnimplementedEventSourcedServer 

type UnimplementedEventSourcedServer struct {
}

UnimplementedEventSourcedServer must be embedded to have forward compatible implementations.

func (UnimplementedEventSourcedServer) Handle 

func (UnimplementedEventSourcedServer) Handle(EventSourced_HandleServer) error

type UnimplementedValueEntityServer added in v0.3.0 

type UnimplementedValueEntityServer struct {
}

UnimplementedValueEntityServer must be embedded to have forward compatible implementations.

func (UnimplementedValueEntityServer) Handle added in v0.3.0 

func (UnimplementedValueEntityServer) Handle(ValueEntity_HandleServer) error

type UnsafeActionProtocolServer added in v0.3.0 

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

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

type UnsafeCrdtServer added in v0.3.0 

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

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

type UnsafeEventSourcedServer added in v0.3.0 

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

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

type UnsafeValueEntityServer added in v0.3.0 

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

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

type ValueEntityAction added in v0.3.0 

type ValueEntityAction struct {

	// Types that are assignable to Action:
	//	*ValueEntityAction_Update
	//	*ValueEntityAction_Delete
	Action isValueEntityAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

An action to take for changing the entity state.

func (*ValueEntityAction) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityAction.ProtoReflect.Descriptor instead.

func (*ValueEntityAction) GetAction added in v0.3.0 

func (m *ValueEntityAction) GetAction() isValueEntityAction_Action

func (*ValueEntityAction) GetDelete added in v0.3.0 

func (x *ValueEntityAction) GetDelete() *ValueEntityDelete

func (*ValueEntityAction) GetUpdate added in v0.3.0 

func (x *ValueEntityAction) GetUpdate() *ValueEntityUpdate

func (*ValueEntityAction) ProtoMessage added in v0.3.0 

func (*ValueEntityAction) ProtoMessage()

func (*ValueEntityAction) ProtoReflect added in v0.3.0 

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

func (*ValueEntityAction) Reset added in v0.3.0 

func (x *ValueEntityAction) Reset()

func (*ValueEntityAction) String added in v0.3.0 

func (x *ValueEntityAction) String() string

type ValueEntityAction_Delete added in v0.3.0 

type ValueEntityAction_Delete struct {
	Delete *ValueEntityDelete `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type ValueEntityAction_Update added in v0.3.0 

type ValueEntityAction_Update struct {
	Update *ValueEntityUpdate `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type ValueEntityClient added in v0.3.0 

type ValueEntityClient interface {
	// One stream will be established per active entity.
	// Once established, the first message sent will be Init, which contains the entity ID, and,
	// a state if the entity has previously persisted one. Once the Init message is sent, one to
	// many commands are sent to the entity. Each request coming in leads to a new command being sent
	// to the entity. The entity is expected to reply to each command with exactly one reply message.
	// The entity should process commands and reply to commands in the order they came
	// in. When processing a command the entity can read and persist (update or delete) the state.
	Handle(ctx context.Context, opts ...grpc.CallOption) (ValueEntity_HandleClient, error)
}

ValueEntityClient is the client API for ValueEntity 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 NewValueEntityClient added in v0.3.0 

func NewValueEntityClient(cc grpc.ClientConnInterface) ValueEntityClient

type ValueEntityDelete added in v0.3.0 

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

An action which deletes the persisted value of the Value entity.

func (*ValueEntityDelete) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityDelete.ProtoReflect.Descriptor instead.

func (*ValueEntityDelete) ProtoMessage added in v0.3.0 

func (*ValueEntityDelete) ProtoMessage()

func (*ValueEntityDelete) ProtoReflect added in v0.3.0 

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

func (*ValueEntityDelete) Reset added in v0.3.0 

func (x *ValueEntityDelete) Reset()

func (*ValueEntityDelete) String added in v0.3.0 

func (x *ValueEntityDelete) String() string

type ValueEntityInit added in v0.3.0 

type ValueEntityInit struct {

	// The name of the service that implements this entity.
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The id of the entity.
	EntityId string `protobuf:"bytes,2,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// The initial state of the entity.
	State *ValueEntityInitState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

The init message. This will always be the first message sent to the entity when it is loaded.

func (*ValueEntityInit) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityInit.ProtoReflect.Descriptor instead.

func (*ValueEntityInit) GetEntityId added in v0.3.0 

func (x *ValueEntityInit) GetEntityId() string

func (*ValueEntityInit) GetServiceName added in v0.3.0 

func (x *ValueEntityInit) GetServiceName() string

func (*ValueEntityInit) GetState added in v0.3.0 

func (x *ValueEntityInit) GetState() *ValueEntityInitState

func (*ValueEntityInit) ProtoMessage added in v0.3.0 

func (*ValueEntityInit) ProtoMessage()

func (*ValueEntityInit) ProtoReflect added in v0.3.0 

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

func (*ValueEntityInit) Reset added in v0.3.0 

func (x *ValueEntityInit) Reset()

func (*ValueEntityInit) String added in v0.3.0 

func (x *ValueEntityInit) String() string

type ValueEntityInitState added in v0.3.0 

type ValueEntityInitState struct {

	// The value of the entity state, if the entity has already been created.
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

The state of the entity when it is first activated.

func (*ValueEntityInitState) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityInitState.ProtoReflect.Descriptor instead.

func (*ValueEntityInitState) GetValue added in v0.3.0 

func (x *ValueEntityInitState) GetValue() *any.Any

func (*ValueEntityInitState) ProtoMessage added in v0.3.0 

func (*ValueEntityInitState) ProtoMessage()

func (*ValueEntityInitState) ProtoReflect added in v0.3.0 

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

func (*ValueEntityInitState) Reset added in v0.3.0 

func (x *ValueEntityInitState) Reset()

func (*ValueEntityInitState) String added in v0.3.0 

func (x *ValueEntityInitState) String() string

type ValueEntityReply added in v0.3.0 

type ValueEntityReply struct {

	// The command being replied to
	CommandId int64 `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// The action to take for the client response
	ClientAction *protocol.ClientAction `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	// Any side effects to perform
	SideEffects []*protocol.SideEffect `protobuf:"bytes,3,rep,name=side_effects,json=sideEffects,proto3" json:"side_effects,omitempty"`
	// The action to take on the value entity
	StateAction *ValueEntityAction `protobuf:"bytes,4,opt,name=state_action,json=stateAction,proto3" json:"state_action,omitempty"`
	// contains filtered or unexported fields
}

A reply to a command.

func (*ValueEntityReply) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityReply.ProtoReflect.Descriptor instead.

func (*ValueEntityReply) GetClientAction added in v0.3.0 

func (x *ValueEntityReply) GetClientAction() *protocol.ClientAction

func (*ValueEntityReply) GetCommandId added in v0.3.0 

func (x *ValueEntityReply) GetCommandId() int64

func (*ValueEntityReply) GetSideEffects added in v0.3.0 

func (x *ValueEntityReply) GetSideEffects() []*protocol.SideEffect

func (*ValueEntityReply) GetStateAction added in v0.3.0 

func (x *ValueEntityReply) GetStateAction() *ValueEntityAction

func (*ValueEntityReply) ProtoMessage added in v0.3.0 

func (*ValueEntityReply) ProtoMessage()

func (*ValueEntityReply) ProtoReflect added in v0.3.0 

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

func (*ValueEntityReply) Reset added in v0.3.0 

func (x *ValueEntityReply) Reset()

func (*ValueEntityReply) String added in v0.3.0 

func (x *ValueEntityReply) String() string

type ValueEntityServer added in v0.3.0 

type ValueEntityServer interface {
	// One stream will be established per active entity.
	// Once established, the first message sent will be Init, which contains the entity ID, and,
	// a state if the entity has previously persisted one. Once the Init message is sent, one to
	// many commands are sent to the entity. Each request coming in leads to a new command being sent
	// to the entity. The entity is expected to reply to each command with exactly one reply message.
	// The entity should process commands and reply to commands in the order they came
	// in. When processing a command the entity can read and persist (update or delete) the state.
	Handle(ValueEntity_HandleServer) error
	// contains filtered or unexported methods
}

ValueEntityServer is the server API for ValueEntity service. All implementations must embed UnimplementedValueEntityServer for forward compatibility

type ValueEntityStreamIn added in v0.3.0 

type ValueEntityStreamIn struct {

	// Types that are assignable to Message:
	//	*ValueEntityStreamIn_Init
	//	*ValueEntityStreamIn_Command
	Message isValueEntityStreamIn_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Input message type for the gRPC stream in.

func (*ValueEntityStreamIn) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityStreamIn.ProtoReflect.Descriptor instead.

func (*ValueEntityStreamIn) GetCommand added in v0.3.0 

func (x *ValueEntityStreamIn) GetCommand() *protocol.Command

func (*ValueEntityStreamIn) GetInit added in v0.3.0 

func (x *ValueEntityStreamIn) GetInit() *ValueEntityInit

func (*ValueEntityStreamIn) GetMessage added in v0.3.0 

func (m *ValueEntityStreamIn) GetMessage() isValueEntityStreamIn_Message

func (*ValueEntityStreamIn) ProtoMessage added in v0.3.0 

func (*ValueEntityStreamIn) ProtoMessage()

func (*ValueEntityStreamIn) ProtoReflect added in v0.3.0 

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

func (*ValueEntityStreamIn) Reset added in v0.3.0 

func (x *ValueEntityStreamIn) Reset()

func (*ValueEntityStreamIn) String added in v0.3.0 

func (x *ValueEntityStreamIn) String() string

type ValueEntityStreamIn_Command added in v0.3.0 

type ValueEntityStreamIn_Command struct {
	Command *protocol.Command `protobuf:"bytes,2,opt,name=command,proto3,oneof"`
}

type ValueEntityStreamIn_Init added in v0.3.0 

type ValueEntityStreamIn_Init struct {
	Init *ValueEntityInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type ValueEntityStreamOut added in v0.3.0 

type ValueEntityStreamOut struct {

	// Types that are assignable to Message:
	//	*ValueEntityStreamOut_Reply
	//	*ValueEntityStreamOut_Failure
	Message isValueEntityStreamOut_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Output message type for the gRPC stream out.

func (*ValueEntityStreamOut) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityStreamOut.ProtoReflect.Descriptor instead.

func (*ValueEntityStreamOut) GetFailure added in v0.3.0 

func (x *ValueEntityStreamOut) GetFailure() *protocol.Failure

func (*ValueEntityStreamOut) GetMessage added in v0.3.0 

func (m *ValueEntityStreamOut) GetMessage() isValueEntityStreamOut_Message

func (*ValueEntityStreamOut) GetReply added in v0.3.0 

func (x *ValueEntityStreamOut) GetReply() *ValueEntityReply

func (*ValueEntityStreamOut) ProtoMessage added in v0.3.0 

func (*ValueEntityStreamOut) ProtoMessage()

func (*ValueEntityStreamOut) ProtoReflect added in v0.3.0 

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

func (*ValueEntityStreamOut) Reset added in v0.3.0 

func (x *ValueEntityStreamOut) Reset()

func (*ValueEntityStreamOut) String added in v0.3.0 

func (x *ValueEntityStreamOut) String() string

type ValueEntityStreamOut_Failure added in v0.3.0 

type ValueEntityStreamOut_Failure struct {
	Failure *protocol.Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type ValueEntityStreamOut_Reply added in v0.3.0 

type ValueEntityStreamOut_Reply struct {
	Reply *ValueEntityReply `protobuf:"bytes,1,opt,name=reply,proto3,oneof"`
}

type ValueEntityUpdate added in v0.3.0 

type ValueEntityUpdate struct {

	// The value to set.
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An action which updates the persisted value of the Value entity. If the entity is not yet persisted, it will be created.

func (*ValueEntityUpdate) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ValueEntityUpdate.ProtoReflect.Descriptor instead.

func (*ValueEntityUpdate) GetValue added in v0.3.0 

func (x *ValueEntityUpdate) GetValue() *any.Any

func (*ValueEntityUpdate) ProtoMessage added in v0.3.0 

func (*ValueEntityUpdate) ProtoMessage()

func (*ValueEntityUpdate) ProtoReflect added in v0.3.0 

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

func (*ValueEntityUpdate) Reset added in v0.3.0 

func (x *ValueEntityUpdate) Reset()

func (*ValueEntityUpdate) String added in v0.3.0 

func (x *ValueEntityUpdate) String() string

type ValueEntity_HandleClient added in v0.3.0 

type ValueEntity_HandleClient interface {
	Send(*ValueEntityStreamIn) error
	Recv() (*ValueEntityStreamOut, error)
	grpc.ClientStream
}

type ValueEntity_HandleServer added in v0.3.0 

type ValueEntity_HandleServer interface {
	Send(*ValueEntityStreamOut) error
	Recv() (*ValueEntityStreamIn, error)
	grpc.ServerStream
}

type VoteDelta 

type VoteDelta struct {

	// Set by the proxy initially or when the vote has changed.
	// Only set by the user function to change the node's current vote.
	SelfVote bool `protobuf:"varint,1,opt,name=self_vote,json=selfVote,proto3" json:"self_vote,omitempty"`
	// Only set by the proxy initially or when the vote has changed.
	// Ignored by the proxy when set by the user function.
	VotesFor int32 `protobuf:"varint,2,opt,name=votes_for,json=votesFor,proto3" json:"votes_for,omitempty"`
	// Only set by the proxy initially or when the vote has changed.
	// Ignored by the proxy when set by the user function.
	TotalVoters int32 `protobuf:"varint,3,opt,name=total_voters,json=totalVoters,proto3" json:"total_voters,omitempty"`
	// contains filtered or unexported fields
}

func (*VoteDelta) Descriptor deprecated 

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

Deprecated: Use VoteDelta.ProtoReflect.Descriptor instead.

func (*VoteDelta) GetSelfVote 

func (x *VoteDelta) GetSelfVote() bool

func (*VoteDelta) GetTotalVoters 

func (x *VoteDelta) GetTotalVoters() int32

func (*VoteDelta) GetVotesFor 

func (x *VoteDelta) GetVotesFor() int32

func (*VoteDelta) ProtoMessage 

func (*VoteDelta) ProtoMessage()

func (*VoteDelta) ProtoReflect 

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

func (*VoteDelta) Reset 

func (x *VoteDelta) Reset()

func (*VoteDelta) String 

func (x *VoteDelta) String() string

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.