protocol

package
v1.2.0-rc1 Latest Latest
Warning

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

 Go to latest Published: May 14, 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 Positve-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 

func (*UnimplementedCrdtServer) Handle(srv Crdt_HandleServer) error

type UnimplementedEntityDiscoveryServer 

type UnimplementedEntityDiscoveryServer struct {
}

UnimplementedEntityDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityDiscoveryServer) Discover 

func (*UnimplementedEntityDiscoveryServer) Discover(ctx context.Context, req *ProxyInfo) (*EntitySpec, error)

func (*UnimplementedEntityDiscoveryServer) ReportError 

func (*UnimplementedEntityDiscoveryServer) ReportError(ctx context.Context, req *UserFunctionError) (*empty.Empty, error)

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

Source Files

View all Source files

Directories

Path Synopsis

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.