protocol

package
v1.2.3 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var CrdtClock_name = map[int32]string{
	0: "DEFAULT",
	1: "REVERSE",
	2: "CUSTOM",
	3: "CUSTOM_AUTO_INCREMENT",
}
View Source
var CrdtClock_value = map[string]int32{
	"DEFAULT":               0,
	"REVERSE":               1,
	"CUSTOM":                2,
	"CUSTOM_AUTO_INCREMENT": 3,
}
View Source
var CrdtWriteConsistency_name = map[int32]string{
	0: "LOCAL",
	1: "MAJORITY",
	2: "ALL",
}
View Source
var CrdtWriteConsistency_value = map[string]int32{
	"LOCAL":    0,
	"MAJORITY": 1,
	"ALL":      2,
}

Functions

func RegisterCrdtServer

func RegisterCrdtServer(s *grpc.Server, srv CrdtServer)

func RegisterEntityDiscoveryServer

func RegisterEntityDiscoveryServer(s *grpc.Server, srv EntityDiscoveryServer)

Types

type ClientAction

type ClientAction struct {
	// Types that are valid to be assigned to Action:
	//	*ClientAction_Reply
	//	*ClientAction_Forward
	//	*ClientAction_Failure
	Action               isClientAction_Action `protobuf_oneof:"action"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

An action for the client

func (*ClientAction) Descriptor

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

func (*ClientAction) GetAction

func (m *ClientAction) GetAction() isClientAction_Action

func (*ClientAction) GetFailure

func (m *ClientAction) GetFailure() *Failure

func (*ClientAction) GetForward

func (m *ClientAction) GetForward() *Forward

func (*ClientAction) GetReply

func (m *ClientAction) GetReply() *Reply

func (*ClientAction) ProtoMessage

func (*ClientAction) ProtoMessage()

func (*ClientAction) Reset

func (m *ClientAction) Reset()

func (*ClientAction) String

func (m *ClientAction) String() string

func (*ClientAction) XXX_DiscardUnknown

func (m *ClientAction) XXX_DiscardUnknown()

func (*ClientAction) XXX_Marshal

func (m *ClientAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAction) XXX_Merge

func (m *ClientAction) XXX_Merge(src proto.Message)

func (*ClientAction) XXX_OneofWrappers

func (*ClientAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientAction) XXX_Size

func (m *ClientAction) XXX_Size() int

func (*ClientAction) XXX_Unmarshal

func (m *ClientAction) XXX_Unmarshal(b []byte) error

type ClientAction_Failure

type ClientAction_Failure struct {
	Failure *Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof"`
}

type ClientAction_Forward

type ClientAction_Forward struct {
	Forward *Forward `protobuf:"bytes,2,opt,name=forward,proto3,oneof"`
}

type ClientAction_Reply

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

type Command

type Command struct {
	// The ID of the entity.
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// A command id.
	Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,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"`
	// Whether the command is streamed or not
	Streamed             bool     `protobuf:"varint,5,opt,name=streamed,proto3" json:"streamed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A command. For each command received, a reply must be sent with a matching command id.

func (*Command) Descriptor

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

func (*Command) GetEntityId

func (m *Command) GetEntityId() string

func (*Command) GetId

func (m *Command) GetId() int64

func (*Command) GetName

func (m *Command) GetName() string

func (*Command) GetPayload

func (m *Command) GetPayload() *any.Any

func (*Command) GetStreamed

func (m *Command) GetStreamed() bool

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) Reset

func (m *Command) Reset()

func (*Command) String

func (m *Command) String() string

func (*Command) XXX_DiscardUnknown

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal

func (m *Command) XXX_Unmarshal(b []byte) error

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, the current state of the entity. After that, one or more commands may be sent,
	// as well as deltas as they arrive, and the entire state if either the entity is created, or the proxy wishes the
	// user function to replace its entire state.
	//
	// 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCrdtClient

func NewCrdtClient(cc *grpc.ClientConn) 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) EnumDescriptor

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

func (CrdtClock) String

func (x CrdtClock) String() string

type CrdtDelete

type CrdtDelete struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrdtDelete) Descriptor

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

func (*CrdtDelete) ProtoMessage

func (*CrdtDelete) ProtoMessage()

func (*CrdtDelete) Reset

func (m *CrdtDelete) Reset()

func (*CrdtDelete) String

func (m *CrdtDelete) String() string

func (*CrdtDelete) XXX_DiscardUnknown

func (m *CrdtDelete) XXX_DiscardUnknown()

func (*CrdtDelete) XXX_Marshal

func (m *CrdtDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtDelete) XXX_Merge

func (m *CrdtDelete) XXX_Merge(src proto.Message)

func (*CrdtDelete) XXX_Size

func (m *CrdtDelete) XXX_Size() int

func (*CrdtDelete) XXX_Unmarshal

func (m *CrdtDelete) XXX_Unmarshal(b []byte) error

type CrdtDelta

type CrdtDelta struct {
	// Types that are valid to be assigned to Delta:
	//	*CrdtDelta_Gcounter
	//	*CrdtDelta_Pncounter
	//	*CrdtDelta_Gset
	//	*CrdtDelta_Orset
	//	*CrdtDelta_Lwwregister
	//	*CrdtDelta_Flag
	//	*CrdtDelta_Ormap
	//	*CrdtDelta_Vote
	Delta                isCrdtDelta_Delta `protobuf_oneof:"delta"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

A CRDT delta

Deltas only carry the change in value, not the full value (unless

func (*CrdtDelta) Descriptor

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

func (*CrdtDelta) GetDelta

func (m *CrdtDelta) GetDelta() isCrdtDelta_Delta

func (*CrdtDelta) GetFlag

func (m *CrdtDelta) GetFlag() *FlagDelta

func (*CrdtDelta) GetGcounter

func (m *CrdtDelta) GetGcounter() *GCounterDelta

func (*CrdtDelta) GetGset

func (m *CrdtDelta) GetGset() *GSetDelta

func (*CrdtDelta) GetLwwregister

func (m *CrdtDelta) GetLwwregister() *LWWRegisterDelta

func (*CrdtDelta) GetOrmap

func (m *CrdtDelta) GetOrmap() *ORMapDelta

func (*CrdtDelta) GetOrset

func (m *CrdtDelta) GetOrset() *ORSetDelta

func (*CrdtDelta) GetPncounter

func (m *CrdtDelta) GetPncounter() *PNCounterDelta

func (*CrdtDelta) GetVote

func (m *CrdtDelta) GetVote() *VoteDelta

func (*CrdtDelta) ProtoMessage

func (*CrdtDelta) ProtoMessage()

func (*CrdtDelta) Reset

func (m *CrdtDelta) Reset()

func (*CrdtDelta) String

func (m *CrdtDelta) String() string

func (*CrdtDelta) XXX_DiscardUnknown

func (m *CrdtDelta) XXX_DiscardUnknown()

func (*CrdtDelta) XXX_Marshal

func (m *CrdtDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtDelta) XXX_Merge

func (m *CrdtDelta) XXX_Merge(src proto.Message)

func (*CrdtDelta) XXX_OneofWrappers

func (*CrdtDelta) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrdtDelta) XXX_Size

func (m *CrdtDelta) XXX_Size() int

func (*CrdtDelta) XXX_Unmarshal

func (m *CrdtDelta) XXX_Unmarshal(b []byte) error

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"`
	State                *CrdtState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CrdtInit) Descriptor

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

func (*CrdtInit) GetEntityId

func (m *CrdtInit) GetEntityId() string

func (*CrdtInit) GetServiceName

func (m *CrdtInit) GetServiceName() string

func (*CrdtInit) GetState

func (m *CrdtInit) GetState() *CrdtState

func (*CrdtInit) ProtoMessage

func (*CrdtInit) ProtoMessage()

func (*CrdtInit) Reset

func (m *CrdtInit) Reset()

func (*CrdtInit) String

func (m *CrdtInit) String() string

func (*CrdtInit) XXX_DiscardUnknown

func (m *CrdtInit) XXX_DiscardUnknown()

func (*CrdtInit) XXX_Marshal

func (m *CrdtInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtInit) XXX_Merge

func (m *CrdtInit) XXX_Merge(src proto.Message)

func (*CrdtInit) XXX_Size

func (m *CrdtInit) XXX_Size() int

func (*CrdtInit) XXX_Unmarshal

func (m *CrdtInit) XXX_Unmarshal(b []byte) error

type CrdtReply

type CrdtReply struct {
	CommandId    int64            `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	ClientAction *ClientAction    `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	SideEffects  []*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CrdtReply) Descriptor

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

func (*CrdtReply) GetClientAction

func (m *CrdtReply) GetClientAction() *ClientAction

func (*CrdtReply) GetCommandId

func (m *CrdtReply) GetCommandId() int64

func (*CrdtReply) GetSideEffects

func (m *CrdtReply) GetSideEffects() []*SideEffect

func (*CrdtReply) GetStateAction

func (m *CrdtReply) GetStateAction() *CrdtStateAction

func (*CrdtReply) GetStreamed

func (m *CrdtReply) GetStreamed() bool

func (*CrdtReply) ProtoMessage

func (*CrdtReply) ProtoMessage()

func (*CrdtReply) Reset

func (m *CrdtReply) Reset()

func (*CrdtReply) String

func (m *CrdtReply) String() string

func (*CrdtReply) XXX_DiscardUnknown

func (m *CrdtReply) XXX_DiscardUnknown()

func (*CrdtReply) XXX_Marshal

func (m *CrdtReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtReply) XXX_Merge

func (m *CrdtReply) XXX_Merge(src proto.Message)

func (*CrdtReply) XXX_Size

func (m *CrdtReply) XXX_Size() int

func (*CrdtReply) XXX_Unmarshal

func (m *CrdtReply) XXX_Unmarshal(b []byte) error

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, the current state of the entity. After that, one or more commands may be sent,
	// as well as deltas as they arrive, and the entire state if either the entity is created, or the proxy wishes the
	// user function to replace its entire state.
	//
	// 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
}

CrdtServer is the server API for Crdt service.

type CrdtState

type CrdtState struct {
	// Types that are valid to be assigned to State:
	//	*CrdtState_Gcounter
	//	*CrdtState_Pncounter
	//	*CrdtState_Gset
	//	*CrdtState_Orset
	//	*CrdtState_Lwwregister
	//	*CrdtState_Flag
	//	*CrdtState_Ormap
	//	*CrdtState_Vote
	State                isCrdtState_State `protobuf_oneof:"state"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

The CRDT state. This represents the full state of a CRDT. When received, a user function should replace the current state with this, not apply it as a delta. This includes both for the top level CRDT, and embedded CRDTs, such as the values of an ORMap.

func (*CrdtState) Descriptor

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

func (*CrdtState) GetFlag

func (m *CrdtState) GetFlag() *FlagState

func (*CrdtState) GetGcounter

func (m *CrdtState) GetGcounter() *GCounterState

func (*CrdtState) GetGset

func (m *CrdtState) GetGset() *GSetState

func (*CrdtState) GetLwwregister

func (m *CrdtState) GetLwwregister() *LWWRegisterState

func (*CrdtState) GetOrmap

func (m *CrdtState) GetOrmap() *ORMapState

func (*CrdtState) GetOrset

func (m *CrdtState) GetOrset() *ORSetState

func (*CrdtState) GetPncounter

func (m *CrdtState) GetPncounter() *PNCounterState

func (*CrdtState) GetState

func (m *CrdtState) GetState() isCrdtState_State

func (*CrdtState) GetVote

func (m *CrdtState) GetVote() *VoteState

func (*CrdtState) ProtoMessage

func (*CrdtState) ProtoMessage()

func (*CrdtState) Reset

func (m *CrdtState) Reset()

func (*CrdtState) String

func (m *CrdtState) String() string

func (*CrdtState) XXX_DiscardUnknown

func (m *CrdtState) XXX_DiscardUnknown()

func (*CrdtState) XXX_Marshal

func (m *CrdtState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtState) XXX_Merge

func (m *CrdtState) XXX_Merge(src proto.Message)

func (*CrdtState) XXX_OneofWrappers

func (*CrdtState) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrdtState) XXX_Size

func (m *CrdtState) XXX_Size() int

func (*CrdtState) XXX_Unmarshal

func (m *CrdtState) XXX_Unmarshal(b []byte) error

type CrdtStateAction

type CrdtStateAction struct {
	// Types that are valid to be assigned to Action:
	//	*CrdtStateAction_Create
	//	*CrdtStateAction_Update
	//	*CrdtStateAction_Delete
	Action               isCrdtStateAction_Action `protobuf_oneof:"action"`
	WriteConsistency     CrdtWriteConsistency     `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*CrdtStateAction) Descriptor

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

func (*CrdtStateAction) GetAction

func (m *CrdtStateAction) GetAction() isCrdtStateAction_Action

func (*CrdtStateAction) GetCreate

func (m *CrdtStateAction) GetCreate() *CrdtState

func (*CrdtStateAction) GetDelete

func (m *CrdtStateAction) GetDelete() *CrdtDelete

func (*CrdtStateAction) GetUpdate

func (m *CrdtStateAction) GetUpdate() *CrdtDelta

func (*CrdtStateAction) GetWriteConsistency

func (m *CrdtStateAction) GetWriteConsistency() CrdtWriteConsistency

func (*CrdtStateAction) ProtoMessage

func (*CrdtStateAction) ProtoMessage()

func (*CrdtStateAction) Reset

func (m *CrdtStateAction) Reset()

func (*CrdtStateAction) String

func (m *CrdtStateAction) String() string

func (*CrdtStateAction) XXX_DiscardUnknown

func (m *CrdtStateAction) XXX_DiscardUnknown()

func (*CrdtStateAction) XXX_Marshal

func (m *CrdtStateAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtStateAction) XXX_Merge

func (m *CrdtStateAction) XXX_Merge(src proto.Message)

func (*CrdtStateAction) XXX_OneofWrappers

func (*CrdtStateAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrdtStateAction) XXX_Size

func (m *CrdtStateAction) XXX_Size() int

func (*CrdtStateAction) XXX_Unmarshal

func (m *CrdtStateAction) XXX_Unmarshal(b []byte) error

type CrdtStateAction_Create

type CrdtStateAction_Create struct {
	Create *CrdtState `protobuf:"bytes,5,opt,name=create,proto3,oneof"`
}

type CrdtStateAction_Delete

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

type CrdtStateAction_Update

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

type CrdtState_Flag

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

type CrdtState_Gcounter

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

type CrdtState_Gset

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

type CrdtState_Lwwregister

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

type CrdtState_Ormap

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

type CrdtState_Orset

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

type CrdtState_Pncounter

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

type CrdtState_Vote

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

type CrdtStreamCancelledResponse

type CrdtStreamCancelledResponse struct {
	CommandId            int64            `protobuf:"varint,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	SideEffects          []*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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CrdtStreamCancelledResponse) Descriptor

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

func (*CrdtStreamCancelledResponse) GetCommandId

func (m *CrdtStreamCancelledResponse) GetCommandId() int64

func (*CrdtStreamCancelledResponse) GetSideEffects

func (m *CrdtStreamCancelledResponse) GetSideEffects() []*SideEffect

func (*CrdtStreamCancelledResponse) GetStateAction

func (m *CrdtStreamCancelledResponse) GetStateAction() *CrdtStateAction

func (*CrdtStreamCancelledResponse) ProtoMessage

func (*CrdtStreamCancelledResponse) ProtoMessage()

func (*CrdtStreamCancelledResponse) Reset

func (m *CrdtStreamCancelledResponse) Reset()

func (*CrdtStreamCancelledResponse) String

func (m *CrdtStreamCancelledResponse) String() string

func (*CrdtStreamCancelledResponse) XXX_DiscardUnknown

func (m *CrdtStreamCancelledResponse) XXX_DiscardUnknown()

func (*CrdtStreamCancelledResponse) XXX_Marshal

func (m *CrdtStreamCancelledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtStreamCancelledResponse) XXX_Merge

func (m *CrdtStreamCancelledResponse) XXX_Merge(src proto.Message)

func (*CrdtStreamCancelledResponse) XXX_Size

func (m *CrdtStreamCancelledResponse) XXX_Size() int

func (*CrdtStreamCancelledResponse) XXX_Unmarshal

func (m *CrdtStreamCancelledResponse) XXX_Unmarshal(b []byte) error

type CrdtStreamIn

type CrdtStreamIn struct {
	// Types that are valid to be assigned to Message:
	//	*CrdtStreamIn_Init
	//	*CrdtStreamIn_State
	//	*CrdtStreamIn_Changed
	//	*CrdtStreamIn_Deleted
	//	*CrdtStreamIn_Command
	//	*CrdtStreamIn_StreamCancelled
	Message              isCrdtStreamIn_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Message for the Crdt handle stream in.

func (*CrdtStreamIn) Descriptor

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

func (*CrdtStreamIn) GetChanged

func (m *CrdtStreamIn) GetChanged() *CrdtDelta

func (*CrdtStreamIn) GetCommand

func (m *CrdtStreamIn) GetCommand() *Command

func (*CrdtStreamIn) GetDeleted

func (m *CrdtStreamIn) GetDeleted() *CrdtDelete

func (*CrdtStreamIn) GetInit

func (m *CrdtStreamIn) GetInit() *CrdtInit

func (*CrdtStreamIn) GetMessage

func (m *CrdtStreamIn) GetMessage() isCrdtStreamIn_Message

func (*CrdtStreamIn) GetState

func (m *CrdtStreamIn) GetState() *CrdtState

func (*CrdtStreamIn) GetStreamCancelled

func (m *CrdtStreamIn) GetStreamCancelled() *StreamCancelled

func (*CrdtStreamIn) ProtoMessage

func (*CrdtStreamIn) ProtoMessage()

func (*CrdtStreamIn) Reset

func (m *CrdtStreamIn) Reset()

func (*CrdtStreamIn) String

func (m *CrdtStreamIn) String() string

func (*CrdtStreamIn) XXX_DiscardUnknown

func (m *CrdtStreamIn) XXX_DiscardUnknown()

func (*CrdtStreamIn) XXX_Marshal

func (m *CrdtStreamIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtStreamIn) XXX_Merge

func (m *CrdtStreamIn) XXX_Merge(src proto.Message)

func (*CrdtStreamIn) XXX_OneofWrappers

func (*CrdtStreamIn) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrdtStreamIn) XXX_Size

func (m *CrdtStreamIn) XXX_Size() int

func (*CrdtStreamIn) XXX_Unmarshal

func (m *CrdtStreamIn) XXX_Unmarshal(b []byte) error

type CrdtStreamIn_Changed

type CrdtStreamIn_Changed struct {
	Changed *CrdtDelta `protobuf:"bytes,3,opt,name=changed,proto3,oneof"`
}

type CrdtStreamIn_Command

type CrdtStreamIn_Command struct {
	Command *Command `protobuf:"bytes,5,opt,name=command,proto3,oneof"`
}

type CrdtStreamIn_Deleted

type CrdtStreamIn_Deleted struct {
	Deleted *CrdtDelete `protobuf:"bytes,4,opt,name=deleted,proto3,oneof"`
}

type CrdtStreamIn_Init

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

type CrdtStreamIn_State

type CrdtStreamIn_State struct {
	State *CrdtState `protobuf:"bytes,2,opt,name=state,proto3,oneof"`
}

type CrdtStreamIn_StreamCancelled

type CrdtStreamIn_StreamCancelled struct {
	StreamCancelled *StreamCancelled `protobuf:"bytes,6,opt,name=stream_cancelled,json=streamCancelled,proto3,oneof"`
}

type CrdtStreamOut

type CrdtStreamOut struct {
	// Types that are valid to be assigned to Message:
	//	*CrdtStreamOut_Reply
	//	*CrdtStreamOut_StreamedMessage
	//	*CrdtStreamOut_StreamCancelledResponse
	//	*CrdtStreamOut_Failure
	Message              isCrdtStreamOut_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Message for the Crdt handle stream out.

func (*CrdtStreamOut) Descriptor

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

func (*CrdtStreamOut) GetFailure

func (m *CrdtStreamOut) GetFailure() *Failure

func (*CrdtStreamOut) GetMessage

func (m *CrdtStreamOut) GetMessage() isCrdtStreamOut_Message

func (*CrdtStreamOut) GetReply

func (m *CrdtStreamOut) GetReply() *CrdtReply

func (*CrdtStreamOut) GetStreamCancelledResponse

func (m *CrdtStreamOut) GetStreamCancelledResponse() *CrdtStreamCancelledResponse

func (*CrdtStreamOut) GetStreamedMessage

func (m *CrdtStreamOut) GetStreamedMessage() *CrdtStreamedMessage

func (*CrdtStreamOut) ProtoMessage

func (*CrdtStreamOut) ProtoMessage()

func (*CrdtStreamOut) Reset

func (m *CrdtStreamOut) Reset()

func (*CrdtStreamOut) String

func (m *CrdtStreamOut) String() string

func (*CrdtStreamOut) XXX_DiscardUnknown

func (m *CrdtStreamOut) XXX_DiscardUnknown()

func (*CrdtStreamOut) XXX_Marshal

func (m *CrdtStreamOut) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtStreamOut) XXX_Merge

func (m *CrdtStreamOut) XXX_Merge(src proto.Message)

func (*CrdtStreamOut) XXX_OneofWrappers

func (*CrdtStreamOut) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CrdtStreamOut) XXX_Size

func (m *CrdtStreamOut) XXX_Size() int

func (*CrdtStreamOut) XXX_Unmarshal

func (m *CrdtStreamOut) XXX_Unmarshal(b []byte) error

type CrdtStreamOut_Failure

type CrdtStreamOut_Failure struct {
	Failure *Failure `protobuf:"bytes,4,opt,name=failure,proto3,oneof"`
}

type CrdtStreamOut_Reply

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

type CrdtStreamOut_StreamCancelledResponse

type CrdtStreamOut_StreamCancelledResponse struct {
	StreamCancelledResponse *CrdtStreamCancelledResponse `protobuf:"bytes,3,opt,name=stream_cancelled_response,json=streamCancelledResponse,proto3,oneof"`
}

type CrdtStreamOut_StreamedMessage

type CrdtStreamOut_StreamedMessage struct {
	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 *ClientAction `protobuf:"bytes,2,opt,name=client_action,json=clientAction,proto3" json:"client_action,omitempty"`
	SideEffects  []*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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*CrdtStreamedMessage) Descriptor

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

func (*CrdtStreamedMessage) GetClientAction

func (m *CrdtStreamedMessage) GetClientAction() *ClientAction

func (*CrdtStreamedMessage) GetCommandId

func (m *CrdtStreamedMessage) GetCommandId() int64

func (*CrdtStreamedMessage) GetEndStream

func (m *CrdtStreamedMessage) GetEndStream() bool

func (*CrdtStreamedMessage) GetSideEffects

func (m *CrdtStreamedMessage) GetSideEffects() []*SideEffect

func (*CrdtStreamedMessage) ProtoMessage

func (*CrdtStreamedMessage) ProtoMessage()

func (*CrdtStreamedMessage) Reset

func (m *CrdtStreamedMessage) Reset()

func (*CrdtStreamedMessage) String

func (m *CrdtStreamedMessage) String() string

func (*CrdtStreamedMessage) XXX_DiscardUnknown

func (m *CrdtStreamedMessage) XXX_DiscardUnknown()

func (*CrdtStreamedMessage) XXX_Marshal

func (m *CrdtStreamedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrdtStreamedMessage) XXX_Merge

func (m *CrdtStreamedMessage) XXX_Merge(src proto.Message)

func (*CrdtStreamedMessage) XXX_Size

func (m *CrdtStreamedMessage) XXX_Size() int

func (*CrdtStreamedMessage) XXX_Unmarshal

func (m *CrdtStreamedMessage) XXX_Unmarshal(b []byte) error

type CrdtWriteConsistency

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

func (CrdtWriteConsistency) EnumDescriptor

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

func (CrdtWriteConsistency) String

func (x CrdtWriteConsistency) String() string

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 Entity

type Entity struct {
	// The type of entity. By convention, this should be a fully qualified entity protocol grpc
	// service name, for example, cloudstate.eventsourced.EventSourced.
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// The name of the service to load from the protobuf file.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The ID to namespace state by. How this is used depends on the type of entity, for example,
	// event sourced entities will prefix this to the persistence id.
	PersistenceId        string   `protobuf:"bytes,3,opt,name=persistence_id,json=persistenceId,proto3" json:"persistence_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Entity) Descriptor

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

func (*Entity) GetEntityType

func (m *Entity) GetEntityType() string

func (*Entity) GetPersistenceId

func (m *Entity) GetPersistenceId() string

func (*Entity) GetServiceName

func (m *Entity) GetServiceName() string

func (*Entity) ProtoMessage

func (*Entity) ProtoMessage()

func (*Entity) Reset

func (m *Entity) Reset()

func (*Entity) String

func (m *Entity) String() string

func (*Entity) XXX_DiscardUnknown

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge

func (m *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_Size

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal

func (m *Entity) XXX_Unmarshal(b []byte) error

type EntityDiscoveryClient

type EntityDiscoveryClient interface {
	// Discover what entities the user function wishes to serve.
	Discover(ctx context.Context, in *ProxyInfo, opts ...grpc.CallOption) (*EntitySpec, error)
	// Report an error back to the user function. This will only be invoked to tell the user function
	// that it has done something wrong, eg, violated the protocol, tried to use an entity type that
	// isn't supported, or attempted to forward to an entity that doesn't exist, etc. These messages
	// should be logged clearly for debugging purposes.
	ReportError(ctx context.Context, in *UserFunctionError, opts ...grpc.CallOption) (*empty.Empty, error)
}

EntityDiscoveryClient is the client API for EntityDiscovery service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEntityDiscoveryClient

func NewEntityDiscoveryClient(cc *grpc.ClientConn) EntityDiscoveryClient

type EntityDiscoveryServer

type EntityDiscoveryServer interface {
	// Discover what entities the user function wishes to serve.
	Discover(context.Context, *ProxyInfo) (*EntitySpec, error)
	// Report an error back to the user function. This will only be invoked to tell the user function
	// that it has done something wrong, eg, violated the protocol, tried to use an entity type that
	// isn't supported, or attempted to forward to an entity that doesn't exist, etc. These messages
	// should be logged clearly for debugging purposes.
	ReportError(context.Context, *UserFunctionError) (*empty.Empty, error)
}

EntityDiscoveryServer is the server API for EntityDiscovery service.

type EntitySpec

type EntitySpec struct {
	// This should be the Descriptors.FileDescriptorSet in proto serialized from as generated by:
	// protoc --include_imports \
	// --proto_path=<proto file directory> \
	// --descriptor_set_out=user-function.desc \
	// <path to .proto files>
	Proto []byte `protobuf:"bytes,1,opt,name=proto,proto3" json:"proto,omitempty"`
	// The entities being served.
	Entities []*Entity `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	// Optional information about the service.
	ServiceInfo          *ServiceInfo `protobuf:"bytes,3,opt,name=service_info,json=serviceInfo,proto3" json:"service_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*EntitySpec) Descriptor

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

func (*EntitySpec) GetEntities

func (m *EntitySpec) GetEntities() []*Entity

func (*EntitySpec) GetProto

func (m *EntitySpec) GetProto() []byte

func (*EntitySpec) GetServiceInfo

func (m *EntitySpec) GetServiceInfo() *ServiceInfo

func (*EntitySpec) ProtoMessage

func (*EntitySpec) ProtoMessage()

func (*EntitySpec) Reset

func (m *EntitySpec) Reset()

func (*EntitySpec) String

func (m *EntitySpec) String() string

func (*EntitySpec) XXX_DiscardUnknown

func (m *EntitySpec) XXX_DiscardUnknown()

func (*EntitySpec) XXX_Marshal

func (m *EntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EntitySpec) XXX_Merge

func (m *EntitySpec) XXX_Merge(src proto.Message)

func (*EntitySpec) XXX_Size

func (m *EntitySpec) XXX_Size() int

func (*EntitySpec) XXX_Unmarshal

func (m *EntitySpec) XXX_Unmarshal(b []byte) error

type Failure

type Failure 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"`
	// A description of the error.
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A failure reply. If this is returned, it will be translated into a gRPC unknown error with the corresponding description if supplied.

func (*Failure) Descriptor

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

func (*Failure) GetCommandId

func (m *Failure) GetCommandId() int64

func (*Failure) GetDescription

func (m *Failure) GetDescription() string

func (*Failure) ProtoMessage

func (*Failure) ProtoMessage()

func (*Failure) Reset

func (m *Failure) Reset()

func (*Failure) String

func (m *Failure) String() string

func (*Failure) XXX_DiscardUnknown

func (m *Failure) XXX_DiscardUnknown()

func (*Failure) XXX_Marshal

func (m *Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Failure) XXX_Merge

func (m *Failure) XXX_Merge(src proto.Message)

func (*Failure) XXX_Size

func (m *Failure) XXX_Size() int

func (*Failure) XXX_Unmarshal

func (m *Failure) XXX_Unmarshal(b []byte) error

type FlagDelta

type FlagDelta struct {
	Value                bool     `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlagDelta) Descriptor

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

func (*FlagDelta) GetValue

func (m *FlagDelta) GetValue() bool

func (*FlagDelta) ProtoMessage

func (*FlagDelta) ProtoMessage()

func (*FlagDelta) Reset

func (m *FlagDelta) Reset()

func (*FlagDelta) String

func (m *FlagDelta) String() string

func (*FlagDelta) XXX_DiscardUnknown

func (m *FlagDelta) XXX_DiscardUnknown()

func (*FlagDelta) XXX_Marshal

func (m *FlagDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlagDelta) XXX_Merge

func (m *FlagDelta) XXX_Merge(src proto.Message)

func (*FlagDelta) XXX_Size

func (m *FlagDelta) XXX_Size() int

func (*FlagDelta) XXX_Unmarshal

func (m *FlagDelta) XXX_Unmarshal(b []byte) error

type FlagState

type FlagState struct {
	// The current value of the flag.
	Value                bool     `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Flag

A Flag is a boolean value, that once set to true, stays true.

func (*FlagState) Descriptor

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

func (*FlagState) GetValue

func (m *FlagState) GetValue() bool

func (*FlagState) ProtoMessage

func (*FlagState) ProtoMessage()

func (*FlagState) Reset

func (m *FlagState) Reset()

func (*FlagState) String

func (m *FlagState) String() string

func (*FlagState) XXX_DiscardUnknown

func (m *FlagState) XXX_DiscardUnknown()

func (*FlagState) XXX_Marshal

func (m *FlagState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlagState) XXX_Merge

func (m *FlagState) XXX_Merge(src proto.Message)

func (*FlagState) XXX_Size

func (m *FlagState) XXX_Size() int

func (*FlagState) XXX_Unmarshal

func (m *FlagState) XXX_Unmarshal(b []byte) error

type Forward

type Forward struct {
	// The name of the service to forward to.
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The name of the command.
	CommandName string `protobuf:"bytes,2,opt,name=command_name,json=commandName,proto3" json:"command_name,omitempty"`
	// The payload.
	Payload              *any.Any `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Forwards handling of this request to another entity.

func (*Forward) Descriptor

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

func (*Forward) GetCommandName

func (m *Forward) GetCommandName() string

func (*Forward) GetPayload

func (m *Forward) GetPayload() *any.Any

func (*Forward) GetServiceName

func (m *Forward) GetServiceName() string

func (*Forward) ProtoMessage

func (*Forward) ProtoMessage()

func (*Forward) Reset

func (m *Forward) Reset()

func (*Forward) String

func (m *Forward) String() string

func (*Forward) XXX_DiscardUnknown

func (m *Forward) XXX_DiscardUnknown()

func (*Forward) XXX_Marshal

func (m *Forward) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Forward) XXX_Merge

func (m *Forward) XXX_Merge(src proto.Message)

func (*Forward) XXX_Size

func (m *Forward) XXX_Size() int

func (*Forward) XXX_Unmarshal

func (m *Forward) XXX_Unmarshal(b []byte) error

type GCounterDelta

type GCounterDelta struct {
	Increment            uint64   `protobuf:"varint,1,opt,name=increment,proto3" json:"increment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCounterDelta) Descriptor

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

func (*GCounterDelta) GetIncrement

func (m *GCounterDelta) GetIncrement() uint64

func (*GCounterDelta) ProtoMessage

func (*GCounterDelta) ProtoMessage()

func (*GCounterDelta) Reset

func (m *GCounterDelta) Reset()

func (*GCounterDelta) String

func (m *GCounterDelta) String() string

func (*GCounterDelta) XXX_DiscardUnknown

func (m *GCounterDelta) XXX_DiscardUnknown()

func (*GCounterDelta) XXX_Marshal

func (m *GCounterDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCounterDelta) XXX_Merge

func (m *GCounterDelta) XXX_Merge(src proto.Message)

func (*GCounterDelta) XXX_Size

func (m *GCounterDelta) XXX_Size() int

func (*GCounterDelta) XXX_Unmarshal

func (m *GCounterDelta) XXX_Unmarshal(b []byte) error

type GCounterState

type GCounterState struct {
	// The current value of the counter.
	Value                uint64   `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Grow-only counter

A G-Counter can only be incremented, it can't be decremented.

func (*GCounterState) Descriptor

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

func (*GCounterState) GetValue

func (m *GCounterState) GetValue() uint64

func (*GCounterState) ProtoMessage

func (*GCounterState) ProtoMessage()

func (*GCounterState) Reset

func (m *GCounterState) Reset()

func (*GCounterState) String

func (m *GCounterState) String() string

func (*GCounterState) XXX_DiscardUnknown

func (m *GCounterState) XXX_DiscardUnknown()

func (*GCounterState) XXX_Marshal

func (m *GCounterState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCounterState) XXX_Merge

func (m *GCounterState) XXX_Merge(src proto.Message)

func (*GCounterState) XXX_Size

func (m *GCounterState) XXX_Size() int

func (*GCounterState) XXX_Unmarshal

func (m *GCounterState) XXX_Unmarshal(b []byte) error

type GSetDelta

type GSetDelta struct {
	Added                []*any.Any `protobuf:"bytes,1,rep,name=added,proto3" json:"added,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GSetDelta) Descriptor

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

func (*GSetDelta) GetAdded

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

func (*GSetDelta) ProtoMessage

func (*GSetDelta) ProtoMessage()

func (*GSetDelta) Reset

func (m *GSetDelta) Reset()

func (*GSetDelta) String

func (m *GSetDelta) String() string

func (*GSetDelta) XXX_DiscardUnknown

func (m *GSetDelta) XXX_DiscardUnknown()

func (*GSetDelta) XXX_Marshal

func (m *GSetDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GSetDelta) XXX_Merge

func (m *GSetDelta) XXX_Merge(src proto.Message)

func (*GSetDelta) XXX_Size

func (m *GSetDelta) XXX_Size() int

func (*GSetDelta) XXX_Unmarshal

func (m *GSetDelta) XXX_Unmarshal(b []byte) error

type GSetState

type GSetState struct {
	// The current items in the set.
	Items                []*any.Any `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

A Grow-only Set

A G-Set can only have items added, items cannot be removed.

func (*GSetState) Descriptor

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

func (*GSetState) GetItems

func (m *GSetState) GetItems() []*any.Any

func (*GSetState) ProtoMessage

func (*GSetState) ProtoMessage()

func (*GSetState) Reset

func (m *GSetState) Reset()

func (*GSetState) String

func (m *GSetState) String() string

func (*GSetState) XXX_DiscardUnknown

func (m *GSetState) XXX_DiscardUnknown()

func (*GSetState) XXX_Marshal

func (m *GSetState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GSetState) XXX_Merge

func (m *GSetState) XXX_Merge(src proto.Message)

func (*GSetState) XXX_Size

func (m *GSetState) XXX_Size() int

func (*GSetState) XXX_Unmarshal

func (m *GSetState) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*LWWRegisterDelta) Descriptor

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

func (*LWWRegisterDelta) GetClock

func (m *LWWRegisterDelta) GetClock() CrdtClock

func (*LWWRegisterDelta) GetCustomClockValue

func (m *LWWRegisterDelta) GetCustomClockValue() int64

func (*LWWRegisterDelta) GetValue

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

func (*LWWRegisterDelta) ProtoMessage

func (*LWWRegisterDelta) ProtoMessage()

func (*LWWRegisterDelta) Reset

func (m *LWWRegisterDelta) Reset()

func (*LWWRegisterDelta) String

func (m *LWWRegisterDelta) String() string

func (*LWWRegisterDelta) XXX_DiscardUnknown

func (m *LWWRegisterDelta) XXX_DiscardUnknown()

func (*LWWRegisterDelta) XXX_Marshal

func (m *LWWRegisterDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LWWRegisterDelta) XXX_Merge

func (m *LWWRegisterDelta) XXX_Merge(src proto.Message)

func (*LWWRegisterDelta) XXX_Size

func (m *LWWRegisterDelta) XXX_Size() int

func (*LWWRegisterDelta) XXX_Unmarshal

func (m *LWWRegisterDelta) XXX_Unmarshal(b []byte) error

type LWWRegisterState

type LWWRegisterState struct {
	// The current value of the register.
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// The clock to use if this state needs to be merged with another one.
	Clock CrdtClock `protobuf:"varint,2,opt,name=clock,proto3,enum=cloudstate.crdt.CrdtClock" json:"clock,omitempty"`
	// The clock value if the clock in use is a custom clock.
	CustomClockValue     int64    `protobuf:"varint,3,opt,name=custom_clock_value,json=customClockValue,proto3" json:"custom_clock_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Last-Write-Wins Register

A LWW-Register holds a single value, with the current value being selected based on when it was last written. The time of the last write may either be determined using the proxies clock, or may be based on a custom, domain specific value.

func (*LWWRegisterState) Descriptor

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

func (*LWWRegisterState) GetClock

func (m *LWWRegisterState) GetClock() CrdtClock

func (*LWWRegisterState) GetCustomClockValue

func (m *LWWRegisterState) GetCustomClockValue() int64

func (*LWWRegisterState) GetValue

func (m *LWWRegisterState) GetValue() *any.Any

func (*LWWRegisterState) ProtoMessage

func (*LWWRegisterState) ProtoMessage()

func (*LWWRegisterState) Reset

func (m *LWWRegisterState) Reset()

func (*LWWRegisterState) String

func (m *LWWRegisterState) String() string

func (*LWWRegisterState) XXX_DiscardUnknown

func (m *LWWRegisterState) XXX_DiscardUnknown()

func (*LWWRegisterState) XXX_Marshal

func (m *LWWRegisterState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LWWRegisterState) XXX_Merge

func (m *LWWRegisterState) XXX_Merge(src proto.Message)

func (*LWWRegisterState) XXX_Size

func (m *LWWRegisterState) XXX_Size() int

func (*LWWRegisterState) XXX_Unmarshal

func (m *LWWRegisterState) XXX_Unmarshal(b []byte) error

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                []*ORMapEntry      `protobuf:"bytes,4,rep,name=added,proto3" json:"added,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ORMapDelta) Descriptor

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

func (*ORMapDelta) GetAdded

func (m *ORMapDelta) GetAdded() []*ORMapEntry

func (*ORMapDelta) GetCleared

func (m *ORMapDelta) GetCleared() bool

func (*ORMapDelta) GetRemoved

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

func (*ORMapDelta) GetUpdated

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

func (*ORMapDelta) ProtoMessage

func (*ORMapDelta) ProtoMessage()

func (*ORMapDelta) Reset

func (m *ORMapDelta) Reset()

func (*ORMapDelta) String

func (m *ORMapDelta) String() string

func (*ORMapDelta) XXX_DiscardUnknown

func (m *ORMapDelta) XXX_DiscardUnknown()

func (*ORMapDelta) XXX_Marshal

func (m *ORMapDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORMapDelta) XXX_Merge

func (m *ORMapDelta) XXX_Merge(src proto.Message)

func (*ORMapDelta) XXX_Size

func (m *ORMapDelta) XXX_Size() int

func (*ORMapDelta) XXX_Unmarshal

func (m *ORMapDelta) XXX_Unmarshal(b []byte) error

type ORMapEntry

type ORMapEntry struct {
	// The entry key.
	Key *any.Any `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry, a CRDT itself.
	Value                *CrdtState `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

An OR-Map entry.

func (*ORMapEntry) Descriptor

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

func (*ORMapEntry) GetKey

func (m *ORMapEntry) GetKey() *any.Any

func (*ORMapEntry) GetValue

func (m *ORMapEntry) GetValue() *CrdtState

func (*ORMapEntry) ProtoMessage

func (*ORMapEntry) ProtoMessage()

func (*ORMapEntry) Reset

func (m *ORMapEntry) Reset()

func (*ORMapEntry) String

func (m *ORMapEntry) String() string

func (*ORMapEntry) XXX_DiscardUnknown

func (m *ORMapEntry) XXX_DiscardUnknown()

func (*ORMapEntry) XXX_Marshal

func (m *ORMapEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORMapEntry) XXX_Merge

func (m *ORMapEntry) XXX_Merge(src proto.Message)

func (*ORMapEntry) XXX_Size

func (m *ORMapEntry) XXX_Size() int

func (*ORMapEntry) XXX_Unmarshal

func (m *ORMapEntry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ORMapEntryDelta) Descriptor

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

func (*ORMapEntryDelta) GetDelta

func (m *ORMapEntryDelta) GetDelta() *CrdtDelta

func (*ORMapEntryDelta) GetKey

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

func (*ORMapEntryDelta) ProtoMessage

func (*ORMapEntryDelta) ProtoMessage()

func (*ORMapEntryDelta) Reset

func (m *ORMapEntryDelta) Reset()

func (*ORMapEntryDelta) String

func (m *ORMapEntryDelta) String() string

func (*ORMapEntryDelta) XXX_DiscardUnknown

func (m *ORMapEntryDelta) XXX_DiscardUnknown()

func (*ORMapEntryDelta) XXX_Marshal

func (m *ORMapEntryDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORMapEntryDelta) XXX_Merge

func (m *ORMapEntryDelta) XXX_Merge(src proto.Message)

func (*ORMapEntryDelta) XXX_Size

func (m *ORMapEntryDelta) XXX_Size() int

func (*ORMapEntryDelta) XXX_Unmarshal

func (m *ORMapEntryDelta) XXX_Unmarshal(b []byte) error

type ORMapState

type ORMapState struct {
	// The entries of the map.
	Entries              []*ORMapEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

An Observed-Removed Map

Like an OR-Set, an OR-Map may have items added and removed, with the condition that an item must be observed to be in the map before it is removed. The values of the map are CRDTs themselves. Different keys are allowed to use different CRDTs, and if an item is removed, and then replaced, the new value may be a different CRDT.

func (*ORMapState) Descriptor

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

func (*ORMapState) GetEntries

func (m *ORMapState) GetEntries() []*ORMapEntry

func (*ORMapState) ProtoMessage

func (*ORMapState) ProtoMessage()

func (*ORMapState) Reset

func (m *ORMapState) Reset()

func (*ORMapState) String

func (m *ORMapState) String() string

func (*ORMapState) XXX_DiscardUnknown

func (m *ORMapState) XXX_DiscardUnknown()

func (*ORMapState) XXX_Marshal

func (m *ORMapState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORMapState) XXX_Merge

func (m *ORMapState) XXX_Merge(src proto.Message)

func (*ORMapState) XXX_Size

func (m *ORMapState) XXX_Size() int

func (*ORMapState) XXX_Unmarshal

func (m *ORMapState) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ORSetDelta) Descriptor

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

func (*ORSetDelta) GetAdded

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

func (*ORSetDelta) GetCleared

func (m *ORSetDelta) GetCleared() bool

func (*ORSetDelta) GetRemoved

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

func (*ORSetDelta) ProtoMessage

func (*ORSetDelta) ProtoMessage()

func (*ORSetDelta) Reset

func (m *ORSetDelta) Reset()

func (*ORSetDelta) String

func (m *ORSetDelta) String() string

func (*ORSetDelta) XXX_DiscardUnknown

func (m *ORSetDelta) XXX_DiscardUnknown()

func (*ORSetDelta) XXX_Marshal

func (m *ORSetDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORSetDelta) XXX_Merge

func (m *ORSetDelta) XXX_Merge(src proto.Message)

func (*ORSetDelta) XXX_Size

func (m *ORSetDelta) XXX_Size() int

func (*ORSetDelta) XXX_Unmarshal

func (m *ORSetDelta) XXX_Unmarshal(b []byte) error

type ORSetState

type ORSetState struct {
	// The current items in the set.
	Items                []*any.Any `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

An Observed-Removed Set

An OR-Set may have items added and removed, with the condition that an item must be observed to be in the set before it is removed.

func (*ORSetState) Descriptor

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

func (*ORSetState) GetItems

func (m *ORSetState) GetItems() []*any.Any

func (*ORSetState) ProtoMessage

func (*ORSetState) ProtoMessage()

func (*ORSetState) Reset

func (m *ORSetState) Reset()

func (*ORSetState) String

func (m *ORSetState) String() string

func (*ORSetState) XXX_DiscardUnknown

func (m *ORSetState) XXX_DiscardUnknown()

func (*ORSetState) XXX_Marshal

func (m *ORSetState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ORSetState) XXX_Merge

func (m *ORSetState) XXX_Merge(src proto.Message)

func (*ORSetState) XXX_Size

func (m *ORSetState) XXX_Size() int

func (*ORSetState) XXX_Unmarshal

func (m *ORSetState) XXX_Unmarshal(b []byte) error

type PNCounterDelta

type PNCounterDelta struct {
	Change               int64    `protobuf:"zigzag64,1,opt,name=change,proto3" json:"change,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PNCounterDelta) Descriptor

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

func (*PNCounterDelta) GetChange

func (m *PNCounterDelta) GetChange() int64

func (*PNCounterDelta) ProtoMessage

func (*PNCounterDelta) ProtoMessage()

func (*PNCounterDelta) Reset

func (m *PNCounterDelta) Reset()

func (*PNCounterDelta) String

func (m *PNCounterDelta) String() string

func (*PNCounterDelta) XXX_DiscardUnknown

func (m *PNCounterDelta) XXX_DiscardUnknown()

func (*PNCounterDelta) XXX_Marshal

func (m *PNCounterDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PNCounterDelta) XXX_Merge

func (m *PNCounterDelta) XXX_Merge(src proto.Message)

func (*PNCounterDelta) XXX_Size

func (m *PNCounterDelta) XXX_Size() int

func (*PNCounterDelta) XXX_Unmarshal

func (m *PNCounterDelta) XXX_Unmarshal(b []byte) error

type PNCounterState

type PNCounterState struct {
	// The current value of the counter.
	Value                int64    `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Positive-Negative Counter

A PN-Counter can be both incremented and decremented.

func (*PNCounterState) Descriptor

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

func (*PNCounterState) GetValue

func (m *PNCounterState) GetValue() int64

func (*PNCounterState) ProtoMessage

func (*PNCounterState) ProtoMessage()

func (*PNCounterState) Reset

func (m *PNCounterState) Reset()

func (*PNCounterState) String

func (m *PNCounterState) String() string

func (*PNCounterState) XXX_DiscardUnknown

func (m *PNCounterState) XXX_DiscardUnknown()

func (*PNCounterState) XXX_Marshal

func (m *PNCounterState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PNCounterState) XXX_Merge

func (m *PNCounterState) XXX_Merge(src proto.Message)

func (*PNCounterState) XXX_Size

func (m *PNCounterState) XXX_Size() int

func (*PNCounterState) XXX_Unmarshal

func (m *PNCounterState) XXX_Unmarshal(b []byte) error

type ProxyInfo

type ProxyInfo struct {
	ProtocolMajorVersion int32    `protobuf:"varint,1,opt,name=protocol_major_version,json=protocolMajorVersion,proto3" json:"protocol_major_version,omitempty"`
	ProtocolMinorVersion int32    `protobuf:"varint,2,opt,name=protocol_minor_version,json=protocolMinorVersion,proto3" json:"protocol_minor_version,omitempty"`
	ProxyName            string   `protobuf:"bytes,3,opt,name=proxy_name,json=proxyName,proto3" json:"proxy_name,omitempty"`
	ProxyVersion         string   `protobuf:"bytes,4,opt,name=proxy_version,json=proxyVersion,proto3" json:"proxy_version,omitempty"`
	SupportedEntityTypes []string `protobuf:"bytes,5,rep,name=supported_entity_types,json=supportedEntityTypes,proto3" json:"supported_entity_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyInfo) Descriptor

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

func (*ProxyInfo) GetProtocolMajorVersion

func (m *ProxyInfo) GetProtocolMajorVersion() int32

func (*ProxyInfo) GetProtocolMinorVersion

func (m *ProxyInfo) GetProtocolMinorVersion() int32

func (*ProxyInfo) GetProxyName

func (m *ProxyInfo) GetProxyName() string

func (*ProxyInfo) GetProxyVersion

func (m *ProxyInfo) GetProxyVersion() string

func (*ProxyInfo) GetSupportedEntityTypes

func (m *ProxyInfo) GetSupportedEntityTypes() []string

func (*ProxyInfo) ProtoMessage

func (*ProxyInfo) ProtoMessage()

func (*ProxyInfo) Reset

func (m *ProxyInfo) Reset()

func (*ProxyInfo) String

func (m *ProxyInfo) String() string

func (*ProxyInfo) XXX_DiscardUnknown

func (m *ProxyInfo) XXX_DiscardUnknown()

func (*ProxyInfo) XXX_Marshal

func (m *ProxyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyInfo) XXX_Merge

func (m *ProxyInfo) XXX_Merge(src proto.Message)

func (*ProxyInfo) XXX_Size

func (m *ProxyInfo) XXX_Size() int

func (*ProxyInfo) XXX_Unmarshal

func (m *ProxyInfo) XXX_Unmarshal(b []byte) error

type Reply

type Reply struct {
	// The reply payload
	Payload              *any.Any `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reply to the sender.

func (*Reply) Descriptor

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

func (*Reply) GetPayload

func (m *Reply) GetPayload() *any.Any

func (*Reply) ProtoMessage

func (*Reply) ProtoMessage()

func (*Reply) Reset

func (m *Reply) Reset()

func (*Reply) String

func (m *Reply) String() string

func (*Reply) XXX_DiscardUnknown

func (m *Reply) XXX_DiscardUnknown()

func (*Reply) XXX_Marshal

func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reply) XXX_Merge

func (m *Reply) XXX_Merge(src proto.Message)

func (*Reply) XXX_Size

func (m *Reply) XXX_Size() int

func (*Reply) XXX_Unmarshal

func (m *Reply) XXX_Unmarshal(b []byte) error

type ServiceInfo

type ServiceInfo struct {
	// The name of the service, eg, "shopping-cart".
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The version of the service.
	ServiceVersion string `protobuf:"bytes,2,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"`
	// A description of the runtime for the service. Can be anything, but examples might be:
	// - node v10.15.2
	// - OpenJDK Runtime Environment 1.8.0_192-b12
	ServiceRuntime string `protobuf:"bytes,3,opt,name=service_runtime,json=serviceRuntime,proto3" json:"service_runtime,omitempty"`
	// If using a support library, the name of that library, eg "cloudstate"
	SupportLibraryName string `protobuf:"bytes,4,opt,name=support_library_name,json=supportLibraryName,proto3" json:"support_library_name,omitempty"`
	// The version of the support library being used.
	SupportLibraryVersion string   `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

Information about the service that proxy is proxying to. All of the information in here is optional. It may be useful for debug purposes.

func (*ServiceInfo) Descriptor

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

func (*ServiceInfo) GetServiceName

func (m *ServiceInfo) GetServiceName() string

func (*ServiceInfo) GetServiceRuntime

func (m *ServiceInfo) GetServiceRuntime() string

func (*ServiceInfo) GetServiceVersion

func (m *ServiceInfo) GetServiceVersion() string

func (*ServiceInfo) GetSupportLibraryName

func (m *ServiceInfo) GetSupportLibraryName() string

func (*ServiceInfo) GetSupportLibraryVersion

func (m *ServiceInfo) GetSupportLibraryVersion() string

func (*ServiceInfo) ProtoMessage

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String

func (m *ServiceInfo) String() string

func (*ServiceInfo) XXX_DiscardUnknown

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal

func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInfo) XXX_Merge

func (m *ServiceInfo) XXX_Merge(src proto.Message)

func (*ServiceInfo) XXX_Size

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal

func (m *ServiceInfo) XXX_Unmarshal(b []byte) error

type SideEffect

type SideEffect struct {
	// The name of the service to perform the side effect on.
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The name of the command.
	CommandName string `protobuf:"bytes,2,opt,name=command_name,json=commandName,proto3" json:"command_name,omitempty"`
	// The payload of the command.
	Payload *any.Any `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Whether this side effect should be performed synchronously, ie, before the reply is eventually
	// sent, or not.
	Synchronous          bool     `protobuf:"varint,4,opt,name=synchronous,proto3" json:"synchronous,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A side effect to be done after this command is handled.

func (*SideEffect) Descriptor

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

func (*SideEffect) GetCommandName

func (m *SideEffect) GetCommandName() string

func (*SideEffect) GetPayload

func (m *SideEffect) GetPayload() *any.Any

func (*SideEffect) GetServiceName

func (m *SideEffect) GetServiceName() string

func (*SideEffect) GetSynchronous

func (m *SideEffect) GetSynchronous() bool

func (*SideEffect) ProtoMessage

func (*SideEffect) ProtoMessage()

func (*SideEffect) Reset

func (m *SideEffect) Reset()

func (*SideEffect) String

func (m *SideEffect) String() string

func (*SideEffect) XXX_DiscardUnknown

func (m *SideEffect) XXX_DiscardUnknown()

func (*SideEffect) XXX_Marshal

func (m *SideEffect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SideEffect) XXX_Merge

func (m *SideEffect) XXX_Merge(src proto.Message)

func (*SideEffect) XXX_Size

func (m *SideEffect) XXX_Size() int

func (*SideEffect) XXX_Unmarshal

func (m *SideEffect) XXX_Unmarshal(b []byte) error

type StreamCancelled

type StreamCancelled struct {
	// The ID of the entity
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// The command id
	Id                   int64    `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCancelled) Descriptor

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

func (*StreamCancelled) GetEntityId

func (m *StreamCancelled) GetEntityId() string

func (*StreamCancelled) GetId

func (m *StreamCancelled) GetId() int64

func (*StreamCancelled) ProtoMessage

func (*StreamCancelled) ProtoMessage()

func (*StreamCancelled) Reset

func (m *StreamCancelled) Reset()

func (*StreamCancelled) String

func (m *StreamCancelled) String() string

func (*StreamCancelled) XXX_DiscardUnknown

func (m *StreamCancelled) XXX_DiscardUnknown()

func (*StreamCancelled) XXX_Marshal

func (m *StreamCancelled) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCancelled) XXX_Merge

func (m *StreamCancelled) XXX_Merge(src proto.Message)

func (*StreamCancelled) XXX_Size

func (m *StreamCancelled) XXX_Size() int

func (*StreamCancelled) XXX_Unmarshal

func (m *StreamCancelled) XXX_Unmarshal(b []byte) error

type UnimplementedCrdtServer

type UnimplementedCrdtServer struct {
}

UnimplementedCrdtServer can be embedded to have forward compatible implementations.

func (*UnimplementedCrdtServer) Handle

type UnimplementedEntityDiscoveryServer

type UnimplementedEntityDiscoveryServer struct {
}

UnimplementedEntityDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityDiscoveryServer) Discover

func (*UnimplementedEntityDiscoveryServer) ReportError

type UserFunctionError

type UserFunctionError struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserFunctionError) Descriptor

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

func (*UserFunctionError) GetMessage

func (m *UserFunctionError) GetMessage() string

func (*UserFunctionError) ProtoMessage

func (*UserFunctionError) ProtoMessage()

func (*UserFunctionError) Reset

func (m *UserFunctionError) Reset()

func (*UserFunctionError) String

func (m *UserFunctionError) String() string

func (*UserFunctionError) XXX_DiscardUnknown

func (m *UserFunctionError) XXX_DiscardUnknown()

func (*UserFunctionError) XXX_Marshal

func (m *UserFunctionError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserFunctionError) XXX_Merge

func (m *UserFunctionError) XXX_Merge(src proto.Message)

func (*UserFunctionError) XXX_Size

func (m *UserFunctionError) XXX_Size() int

func (*UserFunctionError) XXX_Unmarshal

func (m *UserFunctionError) XXX_Unmarshal(b []byte) error

type VoteDelta

type VoteDelta struct {
	// Only set by the user function to change the nodes current vote.
	SelfVote bool `protobuf:"varint,1,opt,name=self_vote,json=selfVote,proto3" json:"self_vote,omitempty"`
	// Only set by the proxy to change the votes for and total voters.
	VotesFor             int32    `protobuf:"varint,2,opt,name=votes_for,json=votesFor,proto3" json:"votes_for,omitempty"`
	TotalVoters          int32    `protobuf:"varint,3,opt,name=total_voters,json=totalVoters,proto3" json:"total_voters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VoteDelta) Descriptor

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

func (*VoteDelta) GetSelfVote

func (m *VoteDelta) GetSelfVote() bool

func (*VoteDelta) GetTotalVoters

func (m *VoteDelta) GetTotalVoters() int32

func (*VoteDelta) GetVotesFor

func (m *VoteDelta) GetVotesFor() int32

func (*VoteDelta) ProtoMessage

func (*VoteDelta) ProtoMessage()

func (*VoteDelta) Reset

func (m *VoteDelta) Reset()

func (*VoteDelta) String

func (m *VoteDelta) String() string

func (*VoteDelta) XXX_DiscardUnknown

func (m *VoteDelta) XXX_DiscardUnknown()

func (*VoteDelta) XXX_Marshal

func (m *VoteDelta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VoteDelta) XXX_Merge

func (m *VoteDelta) XXX_Merge(src proto.Message)

func (*VoteDelta) XXX_Size

func (m *VoteDelta) XXX_Size() int

func (*VoteDelta) XXX_Unmarshal

func (m *VoteDelta) XXX_Unmarshal(b []byte) error

type VoteState

type VoteState struct {
	// The number of votes for
	VotesFor uint32 `protobuf:"varint,1,opt,name=votes_for,json=votesFor,proto3" json:"votes_for,omitempty"`
	// The total number of voters
	TotalVoters uint32 `protobuf:"varint,2,opt,name=total_voters,json=totalVoters,proto3" json:"total_voters,omitempty"`
	// The vote of the current node, which is included in the above two numbers
	SelfVote             bool     `protobuf:"varint,3,opt,name=self_vote,json=selfVote,proto3" json:"self_vote,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Vote. This allows nodes to vote on something.

func (*VoteState) Descriptor

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

func (*VoteState) GetSelfVote

func (m *VoteState) GetSelfVote() bool

func (*VoteState) GetTotalVoters

func (m *VoteState) GetTotalVoters() uint32

func (*VoteState) GetVotesFor

func (m *VoteState) GetVotesFor() uint32

func (*VoteState) ProtoMessage

func (*VoteState) ProtoMessage()

func (*VoteState) Reset

func (m *VoteState) Reset()

func (*VoteState) String

func (m *VoteState) String() string

func (*VoteState) XXX_DiscardUnknown

func (m *VoteState) XXX_DiscardUnknown()

func (*VoteState) XXX_Marshal

func (m *VoteState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VoteState) XXX_Merge

func (m *VoteState) XXX_Merge(src proto.Message)

func (*VoteState) XXX_Size

func (m *VoteState) XXX_Size() int

func (*VoteState) XXX_Unmarshal

func (m *VoteState) XXX_Unmarshal(b []byte) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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