pb

package
v0.0.0-...-156e0f8 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2021 License: Apache-2.0 Imports: 3 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DatabaseSubscriptionUpdateOperationType_name = map[int32]string{
	0: "UPDATE",
	1: "DELETE",
}
View Source 
var DatabaseSubscriptionUpdateOperationType_value = map[string]int32{
	"UPDATE": 0,
	"DELETE": 1,
}
View Source 
var PbftMembershipMsgType_name = map[int32]string{
	0: "PBFT_MMSG_UNDEFINED",
	1: "PBFT_MMSG_JOIN",
	2: "PBFT_MMSG_JOIN_RESPONSE",
	3: "PBFT_MMSG_LEAVE",
	4: "PBFT_MMSG_GET_STATE",
	5: "PBFT_MMSG_SET_STATE",
}
View Source 
var PbftMembershipMsgType_value = map[string]int32{
	"PBFT_MMSG_UNDEFINED":     0,
	"PBFT_MMSG_JOIN":          1,
	"PBFT_MMSG_JOIN_RESPONSE": 2,
	"PBFT_MMSG_LEAVE":         3,
	"PBFT_MMSG_GET_STATE":     4,
	"PBFT_MMSG_SET_STATE":     5,
}
View Source 
var PbftMsgType_name = map[int32]string{
	0: "PBFT_MSG_UNDEFINED",
	2: "PBFT_MSG_PREPREPARE",
	3: "PBFT_MSG_PREPARE",
	4: "PBFT_MSG_COMMIT",
	5: "PBFT_MSG_CHECKPOINT",
	6: "PBFT_MSG_JOIN",
	7: "PBFT_MSG_LEAVE",
	8: "PBFT_MSG_VIEWCHANGE",
	9: "PBFT_MSG_NEWVIEW",
}
View Source 
var PbftMsgType_value = map[string]int32{
	"PBFT_MSG_UNDEFINED":  0,
	"PBFT_MSG_PREPREPARE": 2,
	"PBFT_MSG_PREPARE":    3,
	"PBFT_MSG_COMMIT":     4,
	"PBFT_MSG_CHECKPOINT": 5,
	"PBFT_MSG_JOIN":       6,
	"PBFT_MSG_LEAVE":      7,
	"PBFT_MSG_VIEWCHANGE": 8,
	"PBFT_MSG_NEWVIEW":    9,
}

Functions

This section is empty.

Types

type AuditMessage 

type AuditMessage struct {
	// Types that are valid to be assigned to Msg:
	//	*AuditMessage_PbftCommit
	//	*AuditMessage_PrimaryStatus
	//	*AuditMessage_FailureDetected
	Msg                  isAuditMessage_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*AuditMessage) Descriptor 

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

func (*AuditMessage) GetFailureDetected 

func (m *AuditMessage) GetFailureDetected() *FailureDetected

func (*AuditMessage) GetMsg 

func (m *AuditMessage) GetMsg() isAuditMessage_Msg

func (*AuditMessage) GetPbftCommit 

func (m *AuditMessage) GetPbftCommit() *PbftCommitNotification

func (*AuditMessage) GetPrimaryStatus 

func (m *AuditMessage) GetPrimaryStatus() *PrimaryStatus

func (*AuditMessage) ProtoMessage 

func (*AuditMessage) ProtoMessage()

func (*AuditMessage) Reset 

func (m *AuditMessage) Reset()

func (*AuditMessage) String 

func (m *AuditMessage) String() string

func (*AuditMessage) XXX_DiscardUnknown 

func (m *AuditMessage) XXX_DiscardUnknown()

func (*AuditMessage) XXX_Marshal 

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

func (*AuditMessage) XXX_Merge 

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

func (*AuditMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*AuditMessage) XXX_Size 

func (m *AuditMessage) XXX_Size() int

func (*AuditMessage) XXX_Unmarshal 

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

type AuditMessage_FailureDetected 

type AuditMessage_FailureDetected struct {
	FailureDetected *FailureDetected `protobuf:"bytes,3,opt,name=failure_detected,json=failureDetected,proto3,oneof"`
}

type AuditMessage_PbftCommit 

type AuditMessage_PbftCommit struct {
	PbftCommit *PbftCommitNotification `protobuf:"bytes,1,opt,name=pbft_commit,json=pbftCommit,proto3,oneof"`
}

type AuditMessage_PrimaryStatus 

type AuditMessage_PrimaryStatus struct {
	PrimaryStatus *PrimaryStatus `protobuf:"bytes,2,opt,name=primary_status,json=primaryStatus,proto3,oneof"`
}

type BznEnvelope 

type BznEnvelope struct {
	Sender    string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*BznEnvelope_DatabaseMsg
	//	*BznEnvelope_PbftInternalRequest
	//	*BznEnvelope_DatabaseResponse
	//	*BznEnvelope_Json
	//	*BznEnvelope_Audit
	//	*BznEnvelope_Pbft
	//	*BznEnvelope_PbftMembership
	//	*BznEnvelope_StatusRequest
	//	*BznEnvelope_StatusResponse
	Payload              isBznEnvelope_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*BznEnvelope) Descriptor 

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

func (*BznEnvelope) GetAudit 

func (m *BznEnvelope) GetAudit() []byte

func (*BznEnvelope) GetDatabaseMsg 

func (m *BznEnvelope) GetDatabaseMsg() []byte

func (*BznEnvelope) GetDatabaseResponse 

func (m *BznEnvelope) GetDatabaseResponse() []byte

func (*BznEnvelope) GetJson 

func (m *BznEnvelope) GetJson() []byte

func (*BznEnvelope) GetPayload 

func (m *BznEnvelope) GetPayload() isBznEnvelope_Payload

func (*BznEnvelope) GetPbft 

func (m *BznEnvelope) GetPbft() []byte

func (*BznEnvelope) GetPbftInternalRequest 

func (m *BznEnvelope) GetPbftInternalRequest() []byte

func (*BznEnvelope) GetPbftMembership 

func (m *BznEnvelope) GetPbftMembership() []byte

func (*BznEnvelope) GetSender 

func (m *BznEnvelope) GetSender() string

func (*BznEnvelope) GetSignature 

func (m *BznEnvelope) GetSignature() []byte

func (*BznEnvelope) GetStatusRequest 

func (m *BznEnvelope) GetStatusRequest() []byte

func (*BznEnvelope) GetStatusResponse 

func (m *BznEnvelope) GetStatusResponse() []byte

func (*BznEnvelope) GetTimestamp 

func (m *BznEnvelope) GetTimestamp() uint64

func (*BznEnvelope) ProtoMessage 

func (*BznEnvelope) ProtoMessage()

func (*BznEnvelope) Reset 

func (m *BznEnvelope) Reset()

func (*BznEnvelope) String 

func (m *BznEnvelope) String() string

func (*BznEnvelope) XXX_DiscardUnknown 

func (m *BznEnvelope) XXX_DiscardUnknown()

func (*BznEnvelope) XXX_Marshal 

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

func (*BznEnvelope) XXX_Merge 

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

func (*BznEnvelope) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*BznEnvelope) XXX_Size 

func (m *BznEnvelope) XXX_Size() int

func (*BznEnvelope) XXX_Unmarshal 

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

type BznEnvelope_Audit 

type BznEnvelope_Audit struct {
	Audit []byte `protobuf:"bytes,14,opt,name=audit,proto3,oneof"`
}

type BznEnvelope_DatabaseMsg 

type BznEnvelope_DatabaseMsg struct {
	DatabaseMsg []byte `protobuf:"bytes,10,opt,name=database_msg,json=databaseMsg,proto3,oneof"`
}

type BznEnvelope_DatabaseResponse 

type BznEnvelope_DatabaseResponse struct {
	DatabaseResponse []byte `protobuf:"bytes,12,opt,name=database_response,json=databaseResponse,proto3,oneof"`
}

type BznEnvelope_Json 

type BznEnvelope_Json struct {
	Json []byte `protobuf:"bytes,13,opt,name=json,proto3,oneof"`
}

type BznEnvelope_Pbft 

type BznEnvelope_Pbft struct {
	Pbft []byte `protobuf:"bytes,15,opt,name=pbft,proto3,oneof"`
}

type BznEnvelope_PbftInternalRequest 

type BznEnvelope_PbftInternalRequest struct {
	PbftInternalRequest []byte `protobuf:"bytes,11,opt,name=pbft_internal_request,json=pbftInternalRequest,proto3,oneof"`
}

type BznEnvelope_PbftMembership 

type BznEnvelope_PbftMembership struct {
	PbftMembership []byte `protobuf:"bytes,16,opt,name=pbft_membership,json=pbftMembership,proto3,oneof"`
}

type BznEnvelope_StatusRequest 

type BznEnvelope_StatusRequest struct {
	StatusRequest []byte `protobuf:"bytes,17,opt,name=status_request,json=statusRequest,proto3,oneof"`
}

type BznEnvelope_StatusResponse 

type BznEnvelope_StatusResponse struct {
	StatusResponse []byte `protobuf:"bytes,18,opt,name=status_response,json=statusResponse,proto3,oneof"`
}

type DatabaseCreate 

type DatabaseCreate struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Expire               uint64   `protobuf:"varint,3,opt,name=expire,proto3" json:"expire,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseCreate) Descriptor 

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

func (*DatabaseCreate) GetExpire 

func (m *DatabaseCreate) GetExpire() uint64

func (*DatabaseCreate) GetKey 

func (m *DatabaseCreate) GetKey() string

func (*DatabaseCreate) GetValue 

func (m *DatabaseCreate) GetValue() []byte

func (*DatabaseCreate) ProtoMessage 

func (*DatabaseCreate) ProtoMessage()

func (*DatabaseCreate) Reset 

func (m *DatabaseCreate) Reset()

func (*DatabaseCreate) String 

func (m *DatabaseCreate) String() string

func (*DatabaseCreate) XXX_DiscardUnknown 

func (m *DatabaseCreate) XXX_DiscardUnknown()

func (*DatabaseCreate) XXX_Marshal 

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

func (*DatabaseCreate) XXX_Merge 

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

func (*DatabaseCreate) XXX_Size 

func (m *DatabaseCreate) XXX_Size() int

func (*DatabaseCreate) XXX_Unmarshal 

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

type DatabaseDelete 

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

func (*DatabaseDelete) Descriptor 

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

func (*DatabaseDelete) GetKey 

func (m *DatabaseDelete) GetKey() string

func (*DatabaseDelete) ProtoMessage 

func (*DatabaseDelete) ProtoMessage()

func (*DatabaseDelete) Reset 

func (m *DatabaseDelete) Reset()

func (*DatabaseDelete) String 

func (m *DatabaseDelete) String() string

func (*DatabaseDelete) XXX_DiscardUnknown 

func (m *DatabaseDelete) XXX_DiscardUnknown()

func (*DatabaseDelete) XXX_Marshal 

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

func (*DatabaseDelete) XXX_Merge 

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

func (*DatabaseDelete) XXX_Size 

func (m *DatabaseDelete) XXX_Size() int

func (*DatabaseDelete) XXX_Unmarshal 

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

type DatabaseError 

type DatabaseError 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 (*DatabaseError) Descriptor 

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

func (*DatabaseError) GetMessage 

func (m *DatabaseError) GetMessage() string

func (*DatabaseError) ProtoMessage 

func (*DatabaseError) ProtoMessage()

func (*DatabaseError) Reset 

func (m *DatabaseError) Reset()

func (*DatabaseError) String 

func (m *DatabaseError) String() string

func (*DatabaseError) XXX_DiscardUnknown 

func (m *DatabaseError) XXX_DiscardUnknown()

func (*DatabaseError) XXX_Marshal 

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

func (*DatabaseError) XXX_Merge 

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

func (*DatabaseError) XXX_Size 

func (m *DatabaseError) XXX_Size() int

func (*DatabaseError) XXX_Unmarshal 

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

type DatabaseExpire 

type DatabaseExpire struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Expire               uint64   `protobuf:"varint,2,opt,name=expire,proto3" json:"expire,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseExpire) Descriptor 

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

func (*DatabaseExpire) GetExpire 

func (m *DatabaseExpire) GetExpire() uint64

func (*DatabaseExpire) GetKey 

func (m *DatabaseExpire) GetKey() string

func (*DatabaseExpire) ProtoMessage 

func (*DatabaseExpire) ProtoMessage()

func (*DatabaseExpire) Reset 

func (m *DatabaseExpire) Reset()

func (*DatabaseExpire) String 

func (m *DatabaseExpire) String() string

func (*DatabaseExpire) XXX_DiscardUnknown 

func (m *DatabaseExpire) XXX_DiscardUnknown()

func (*DatabaseExpire) XXX_Marshal 

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

func (*DatabaseExpire) XXX_Merge 

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

func (*DatabaseExpire) XXX_Size 

func (m *DatabaseExpire) XXX_Size() int

func (*DatabaseExpire) XXX_Unmarshal 

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

type DatabaseHas 

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

func (*DatabaseHas) Descriptor 

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

func (*DatabaseHas) GetKey 

func (m *DatabaseHas) GetKey() string

func (*DatabaseHas) ProtoMessage 

func (*DatabaseHas) ProtoMessage()

func (*DatabaseHas) Reset 

func (m *DatabaseHas) Reset()

func (*DatabaseHas) String 

func (m *DatabaseHas) String() string

func (*DatabaseHas) XXX_DiscardUnknown 

func (m *DatabaseHas) XXX_DiscardUnknown()

func (*DatabaseHas) XXX_Marshal 

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

func (*DatabaseHas) XXX_Merge 

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

func (*DatabaseHas) XXX_Size 

func (m *DatabaseHas) XXX_Size() int

func (*DatabaseHas) XXX_Unmarshal 

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

type DatabaseHasDb 

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

func (*DatabaseHasDb) Descriptor 

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

func (*DatabaseHasDb) ProtoMessage 

func (*DatabaseHasDb) ProtoMessage()

func (*DatabaseHasDb) Reset 

func (m *DatabaseHasDb) Reset()

func (*DatabaseHasDb) String 

func (m *DatabaseHasDb) String() string

func (*DatabaseHasDb) XXX_DiscardUnknown 

func (m *DatabaseHasDb) XXX_DiscardUnknown()

func (*DatabaseHasDb) XXX_Marshal 

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

func (*DatabaseHasDb) XXX_Merge 

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

func (*DatabaseHasDb) XXX_Size 

func (m *DatabaseHasDb) XXX_Size() int

func (*DatabaseHasDb) XXX_Unmarshal 

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

type DatabaseHasDbResponse 

type DatabaseHasDbResponse struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Has                  bool     `protobuf:"varint,2,opt,name=has,proto3" json:"has,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseHasDbResponse) Descriptor 

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

func (*DatabaseHasDbResponse) GetHas 

func (m *DatabaseHasDbResponse) GetHas() bool

func (*DatabaseHasDbResponse) GetUuid 

func (m *DatabaseHasDbResponse) GetUuid() string

func (*DatabaseHasDbResponse) ProtoMessage 

func (*DatabaseHasDbResponse) ProtoMessage()

func (*DatabaseHasDbResponse) Reset 

func (m *DatabaseHasDbResponse) Reset()

func (*DatabaseHasDbResponse) String 

func (m *DatabaseHasDbResponse) String() string

func (*DatabaseHasDbResponse) XXX_DiscardUnknown 

func (m *DatabaseHasDbResponse) XXX_DiscardUnknown()

func (*DatabaseHasDbResponse) XXX_Marshal 

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

func (*DatabaseHasDbResponse) XXX_Merge 

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

func (*DatabaseHasDbResponse) XXX_Size 

func (m *DatabaseHasDbResponse) XXX_Size() int

func (*DatabaseHasDbResponse) XXX_Unmarshal 

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

type DatabaseHasResponse 

type DatabaseHasResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Has                  bool     `protobuf:"varint,2,opt,name=has,proto3" json:"has,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseHasResponse) Descriptor 

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

func (*DatabaseHasResponse) GetHas 

func (m *DatabaseHasResponse) GetHas() bool

func (*DatabaseHasResponse) GetKey 

func (m *DatabaseHasResponse) GetKey() string

func (*DatabaseHasResponse) ProtoMessage 

func (*DatabaseHasResponse) ProtoMessage()

func (*DatabaseHasResponse) Reset 

func (m *DatabaseHasResponse) Reset()

func (*DatabaseHasResponse) String 

func (m *DatabaseHasResponse) String() string

func (*DatabaseHasResponse) XXX_DiscardUnknown 

func (m *DatabaseHasResponse) XXX_DiscardUnknown()

func (*DatabaseHasResponse) XXX_Marshal 

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

func (*DatabaseHasResponse) XXX_Merge 

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

func (*DatabaseHasResponse) XXX_Size 

func (m *DatabaseHasResponse) XXX_Size() int

func (*DatabaseHasResponse) XXX_Unmarshal 

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

type DatabaseHeader 

type DatabaseHeader struct {
	DbUuid               string   `protobuf:"bytes,1,opt,name=db_uuid,json=dbUuid,proto3" json:"db_uuid,omitempty"`
	Nonce                uint64   `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	PointOfContact       string   `protobuf:"bytes,3,opt,name=point_of_contact,json=pointOfContact,proto3" json:"point_of_contact,omitempty"`
	RequestHash          []byte   `protobuf:"bytes,4,opt,name=request_hash,json=requestHash,proto3" json:"request_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseHeader) Descriptor 

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

func (*DatabaseHeader) GetDbUuid 

func (m *DatabaseHeader) GetDbUuid() string

func (*DatabaseHeader) GetNonce 

func (m *DatabaseHeader) GetNonce() uint64

func (*DatabaseHeader) GetPointOfContact 

func (m *DatabaseHeader) GetPointOfContact() string

func (*DatabaseHeader) GetRequestHash 

func (m *DatabaseHeader) GetRequestHash() []byte

func (*DatabaseHeader) ProtoMessage 

func (*DatabaseHeader) ProtoMessage()

func (*DatabaseHeader) Reset 

func (m *DatabaseHeader) Reset()

func (*DatabaseHeader) String 

func (m *DatabaseHeader) String() string

func (*DatabaseHeader) XXX_DiscardUnknown 

func (m *DatabaseHeader) XXX_DiscardUnknown()

func (*DatabaseHeader) XXX_Marshal 

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

func (*DatabaseHeader) XXX_Merge 

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

func (*DatabaseHeader) XXX_Size 

func (m *DatabaseHeader) XXX_Size() int

func (*DatabaseHeader) XXX_Unmarshal 

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

type DatabaseKeysResponse 

type DatabaseKeysResponse struct {
	Keys                 []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseKeysResponse) Descriptor 

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

func (*DatabaseKeysResponse) GetKeys 

func (m *DatabaseKeysResponse) GetKeys() []string

func (*DatabaseKeysResponse) ProtoMessage 

func (*DatabaseKeysResponse) ProtoMessage()

func (*DatabaseKeysResponse) Reset 

func (m *DatabaseKeysResponse) Reset()

func (*DatabaseKeysResponse) String 

func (m *DatabaseKeysResponse) String() string

func (*DatabaseKeysResponse) XXX_DiscardUnknown 

func (m *DatabaseKeysResponse) XXX_DiscardUnknown()

func (*DatabaseKeysResponse) XXX_Marshal 

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

func (*DatabaseKeysResponse) XXX_Merge 

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

func (*DatabaseKeysResponse) XXX_Size 

func (m *DatabaseKeysResponse) XXX_Size() int

func (*DatabaseKeysResponse) XXX_Unmarshal 

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

type DatabaseMsg 

type DatabaseMsg struct {
	Header *DatabaseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*DatabaseMsg_Create
	//	*DatabaseMsg_Read
	//	*DatabaseMsg_Update
	//	*DatabaseMsg_Delete
	//	*DatabaseMsg_Has
	//	*DatabaseMsg_Keys
	//	*DatabaseMsg_Size
	//	*DatabaseMsg_Subscribe
	//	*DatabaseMsg_Unsubscribe
	//	*DatabaseMsg_Nullmsg
	//	*DatabaseMsg_CreateDb
	//	*DatabaseMsg_DeleteDb
	//	*DatabaseMsg_HasDb
	//	*DatabaseMsg_Writers
	//	*DatabaseMsg_AddWriters
	//	*DatabaseMsg_RemoveWriters
	//	*DatabaseMsg_QuickRead
	//	*DatabaseMsg_Expire
	//	*DatabaseMsg_Persist
	//	*DatabaseMsg_Ttl
	Msg                  isDatabaseMsg_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DatabaseMsg) Descriptor 

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

func (*DatabaseMsg) GetAddWriters 

func (m *DatabaseMsg) GetAddWriters() *DatabaseWriters

func (*DatabaseMsg) GetCreate 

func (m *DatabaseMsg) GetCreate() *DatabaseCreate

func (*DatabaseMsg) GetCreateDb 

func (m *DatabaseMsg) GetCreateDb() *DatabaseRequest

func (*DatabaseMsg) GetDelete 

func (m *DatabaseMsg) GetDelete() *DatabaseDelete

func (*DatabaseMsg) GetDeleteDb 

func (m *DatabaseMsg) GetDeleteDb() *DatabaseRequest

func (*DatabaseMsg) GetExpire 

func (m *DatabaseMsg) GetExpire() *DatabaseExpire

func (*DatabaseMsg) GetHas 

func (m *DatabaseMsg) GetHas() *DatabaseHas

func (*DatabaseMsg) GetHasDb 

func (m *DatabaseMsg) GetHasDb() *DatabaseHasDb

func (*DatabaseMsg) GetHeader 

func (m *DatabaseMsg) GetHeader() *DatabaseHeader

func (*DatabaseMsg) GetKeys 

func (m *DatabaseMsg) GetKeys() *DatabaseRequest

func (*DatabaseMsg) GetMsg 

func (m *DatabaseMsg) GetMsg() isDatabaseMsg_Msg

func (*DatabaseMsg) GetNullmsg 

func (m *DatabaseMsg) GetNullmsg() *DatabaseNullmsg

func (*DatabaseMsg) GetPersist 

func (m *DatabaseMsg) GetPersist() *DatabaseRead

func (*DatabaseMsg) GetQuickRead 

func (m *DatabaseMsg) GetQuickRead() *DatabaseRead

func (*DatabaseMsg) GetRead 

func (m *DatabaseMsg) GetRead() *DatabaseRead

func (*DatabaseMsg) GetRemoveWriters 

func (m *DatabaseMsg) GetRemoveWriters() *DatabaseWriters

func (*DatabaseMsg) GetSize 

func (m *DatabaseMsg) GetSize() *DatabaseRequest

func (*DatabaseMsg) GetSubscribe 

func (m *DatabaseMsg) GetSubscribe() *DatabaseSubscribe

func (*DatabaseMsg) GetTtl 

func (m *DatabaseMsg) GetTtl() *DatabaseRead

func (*DatabaseMsg) GetUnsubscribe 

func (m *DatabaseMsg) GetUnsubscribe() *DatabaseUnsubscribe

func (*DatabaseMsg) GetUpdate 

func (m *DatabaseMsg) GetUpdate() *DatabaseUpdate

func (*DatabaseMsg) GetWriters 

func (m *DatabaseMsg) GetWriters() *DatabaseRequest

func (*DatabaseMsg) ProtoMessage 

func (*DatabaseMsg) ProtoMessage()

func (*DatabaseMsg) Reset 

func (m *DatabaseMsg) Reset()

func (*DatabaseMsg) String 

func (m *DatabaseMsg) String() string

func (*DatabaseMsg) XXX_DiscardUnknown 

func (m *DatabaseMsg) XXX_DiscardUnknown()

func (*DatabaseMsg) XXX_Marshal 

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

func (*DatabaseMsg) XXX_Merge 

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

func (*DatabaseMsg) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DatabaseMsg) XXX_Size 

func (m *DatabaseMsg) XXX_Size() int

func (*DatabaseMsg) XXX_Unmarshal 

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

type DatabaseMsg_AddWriters 

type DatabaseMsg_AddWriters struct {
	AddWriters *DatabaseWriters `protobuf:"bytes,17,opt,name=add_writers,json=addWriters,proto3,oneof"`
}

type DatabaseMsg_Create 

type DatabaseMsg_Create struct {
	Create *DatabaseCreate `protobuf:"bytes,2,opt,name=create,proto3,oneof"`
}

type DatabaseMsg_CreateDb 

type DatabaseMsg_CreateDb struct {
	CreateDb *DatabaseRequest `protobuf:"bytes,12,opt,name=create_db,json=createDb,proto3,oneof"`
}

type DatabaseMsg_Delete 

type DatabaseMsg_Delete struct {
	Delete *DatabaseDelete `protobuf:"bytes,5,opt,name=delete,proto3,oneof"`
}

type DatabaseMsg_DeleteDb 

type DatabaseMsg_DeleteDb struct {
	DeleteDb *DatabaseRequest `protobuf:"bytes,13,opt,name=delete_db,json=deleteDb,proto3,oneof"`
}

type DatabaseMsg_Expire 

type DatabaseMsg_Expire struct {
	Expire *DatabaseExpire `protobuf:"bytes,20,opt,name=expire,proto3,oneof"`
}

type DatabaseMsg_Has 

type DatabaseMsg_Has struct {
	Has *DatabaseHas `protobuf:"bytes,6,opt,name=has,proto3,oneof"`
}

type DatabaseMsg_HasDb 

type DatabaseMsg_HasDb struct {
	HasDb *DatabaseHasDb `protobuf:"bytes,14,opt,name=has_db,json=hasDb,proto3,oneof"`
}

type DatabaseMsg_Keys 

type DatabaseMsg_Keys struct {
	Keys *DatabaseRequest `protobuf:"bytes,7,opt,name=keys,proto3,oneof"`
}

type DatabaseMsg_Nullmsg 

type DatabaseMsg_Nullmsg struct {
	Nullmsg *DatabaseNullmsg `protobuf:"bytes,11,opt,name=nullmsg,proto3,oneof"`
}

type DatabaseMsg_Persist 

type DatabaseMsg_Persist struct {
	Persist *DatabaseRead `protobuf:"bytes,21,opt,name=persist,proto3,oneof"`
}

type DatabaseMsg_QuickRead 

type DatabaseMsg_QuickRead struct {
	QuickRead *DatabaseRead `protobuf:"bytes,19,opt,name=quick_read,json=quickRead,proto3,oneof"`
}

type DatabaseMsg_Read 

type DatabaseMsg_Read struct {
	Read *DatabaseRead `protobuf:"bytes,3,opt,name=read,proto3,oneof"`
}

type DatabaseMsg_RemoveWriters 

type DatabaseMsg_RemoveWriters struct {
	RemoveWriters *DatabaseWriters `protobuf:"bytes,18,opt,name=remove_writers,json=removeWriters,proto3,oneof"`
}

type DatabaseMsg_Size 

type DatabaseMsg_Size struct {
	Size *DatabaseRequest `protobuf:"bytes,8,opt,name=size,proto3,oneof"`
}

type DatabaseMsg_Subscribe 

type DatabaseMsg_Subscribe struct {
	Subscribe *DatabaseSubscribe `protobuf:"bytes,9,opt,name=subscribe,proto3,oneof"`
}

type DatabaseMsg_Ttl 

type DatabaseMsg_Ttl struct {
	Ttl *DatabaseRead `protobuf:"bytes,22,opt,name=ttl,proto3,oneof"`
}

type DatabaseMsg_Unsubscribe 

type DatabaseMsg_Unsubscribe struct {
	Unsubscribe *DatabaseUnsubscribe `protobuf:"bytes,10,opt,name=unsubscribe,proto3,oneof"`
}

type DatabaseMsg_Update 

type DatabaseMsg_Update struct {
	Update *DatabaseUpdate `protobuf:"bytes,4,opt,name=update,proto3,oneof"`
}

type DatabaseMsg_Writers 

type DatabaseMsg_Writers struct {
	Writers *DatabaseRequest `protobuf:"bytes,16,opt,name=writers,proto3,oneof"`
}

type DatabaseNullmsg 

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

func (*DatabaseNullmsg) Descriptor 

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

func (*DatabaseNullmsg) ProtoMessage 

func (*DatabaseNullmsg) ProtoMessage()

func (*DatabaseNullmsg) Reset 

func (m *DatabaseNullmsg) Reset()

func (*DatabaseNullmsg) String 

func (m *DatabaseNullmsg) String() string

func (*DatabaseNullmsg) XXX_DiscardUnknown 

func (m *DatabaseNullmsg) XXX_DiscardUnknown()

func (*DatabaseNullmsg) XXX_Marshal 

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

func (*DatabaseNullmsg) XXX_Merge 

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

func (*DatabaseNullmsg) XXX_Size 

func (m *DatabaseNullmsg) XXX_Size() int

func (*DatabaseNullmsg) XXX_Unmarshal 

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

type DatabaseQuickReadResponse 

type DatabaseQuickReadResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseQuickReadResponse) Descriptor 

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

func (*DatabaseQuickReadResponse) GetError 

func (m *DatabaseQuickReadResponse) GetError() string

func (*DatabaseQuickReadResponse) GetKey 

func (m *DatabaseQuickReadResponse) GetKey() string

func (*DatabaseQuickReadResponse) GetValue 

func (m *DatabaseQuickReadResponse) GetValue() []byte

func (*DatabaseQuickReadResponse) ProtoMessage 

func (*DatabaseQuickReadResponse) ProtoMessage()

func (*DatabaseQuickReadResponse) Reset 

func (m *DatabaseQuickReadResponse) Reset()

func (*DatabaseQuickReadResponse) String 

func (m *DatabaseQuickReadResponse) String() string

func (*DatabaseQuickReadResponse) XXX_DiscardUnknown 

func (m *DatabaseQuickReadResponse) XXX_DiscardUnknown()

func (*DatabaseQuickReadResponse) XXX_Marshal 

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

func (*DatabaseQuickReadResponse) XXX_Merge 

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

func (*DatabaseQuickReadResponse) XXX_Size 

func (m *DatabaseQuickReadResponse) XXX_Size() int

func (*DatabaseQuickReadResponse) XXX_Unmarshal 

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

type DatabaseRead 

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

func (*DatabaseRead) Descriptor 

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

func (*DatabaseRead) GetKey 

func (m *DatabaseRead) GetKey() string

func (*DatabaseRead) ProtoMessage 

func (*DatabaseRead) ProtoMessage()

func (*DatabaseRead) Reset 

func (m *DatabaseRead) Reset()

func (*DatabaseRead) String 

func (m *DatabaseRead) String() string

func (*DatabaseRead) XXX_DiscardUnknown 

func (m *DatabaseRead) XXX_DiscardUnknown()

func (*DatabaseRead) XXX_Marshal 

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

func (*DatabaseRead) XXX_Merge 

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

func (*DatabaseRead) XXX_Size 

func (m *DatabaseRead) XXX_Size() int

func (*DatabaseRead) XXX_Unmarshal 

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

type DatabaseReadResponse 

type DatabaseReadResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseReadResponse) Descriptor 

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

func (*DatabaseReadResponse) GetKey 

func (m *DatabaseReadResponse) GetKey() string

func (*DatabaseReadResponse) GetValue 

func (m *DatabaseReadResponse) GetValue() []byte

func (*DatabaseReadResponse) ProtoMessage 

func (*DatabaseReadResponse) ProtoMessage()

func (*DatabaseReadResponse) Reset 

func (m *DatabaseReadResponse) Reset()

func (*DatabaseReadResponse) String 

func (m *DatabaseReadResponse) String() string

func (*DatabaseReadResponse) XXX_DiscardUnknown 

func (m *DatabaseReadResponse) XXX_DiscardUnknown()

func (*DatabaseReadResponse) XXX_Marshal 

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

func (*DatabaseReadResponse) XXX_Merge 

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

func (*DatabaseReadResponse) XXX_Size 

func (m *DatabaseReadResponse) XXX_Size() int

func (*DatabaseReadResponse) XXX_Unmarshal 

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

type DatabaseRedirectResponse 

type DatabaseRedirectResponse struct {
	LeaderId             string   `protobuf:"bytes,1,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LeaderName           string   `protobuf:"bytes,2,opt,name=leader_name,json=leaderName,proto3" json:"leader_name,omitempty"`
	LeaderHost           string   `protobuf:"bytes,3,opt,name=leader_host,json=leaderHost,proto3" json:"leader_host,omitempty"`
	LeaderPort           uint32   `protobuf:"varint,4,opt,name=leader_port,json=leaderPort,proto3" json:"leader_port,omitempty"`
	LeaderHttpPort       uint32   `protobuf:"varint,5,opt,name=leader_http_port,json=leaderHttpPort,proto3" json:"leader_http_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseRedirectResponse) Descriptor 

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

func (*DatabaseRedirectResponse) GetLeaderHost 

func (m *DatabaseRedirectResponse) GetLeaderHost() string

func (*DatabaseRedirectResponse) GetLeaderHttpPort 

func (m *DatabaseRedirectResponse) GetLeaderHttpPort() uint32

func (*DatabaseRedirectResponse) GetLeaderId 

func (m *DatabaseRedirectResponse) GetLeaderId() string

func (*DatabaseRedirectResponse) GetLeaderName 

func (m *DatabaseRedirectResponse) GetLeaderName() string

func (*DatabaseRedirectResponse) GetLeaderPort 

func (m *DatabaseRedirectResponse) GetLeaderPort() uint32

func (*DatabaseRedirectResponse) ProtoMessage 

func (*DatabaseRedirectResponse) ProtoMessage()

func (*DatabaseRedirectResponse) Reset 

func (m *DatabaseRedirectResponse) Reset()

func (*DatabaseRedirectResponse) String 

func (m *DatabaseRedirectResponse) String() string

func (*DatabaseRedirectResponse) XXX_DiscardUnknown 

func (m *DatabaseRedirectResponse) XXX_DiscardUnknown()

func (*DatabaseRedirectResponse) XXX_Marshal 

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

func (*DatabaseRedirectResponse) XXX_Merge 

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

func (*DatabaseRedirectResponse) XXX_Size 

func (m *DatabaseRedirectResponse) XXX_Size() int

func (*DatabaseRedirectResponse) XXX_Unmarshal 

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

type DatabaseRequest 

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

func (*DatabaseRequest) Descriptor 

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

func (*DatabaseRequest) ProtoMessage 

func (*DatabaseRequest) ProtoMessage()

func (*DatabaseRequest) Reset 

func (m *DatabaseRequest) Reset()

func (*DatabaseRequest) String 

func (m *DatabaseRequest) String() string

func (*DatabaseRequest) XXX_DiscardUnknown 

func (m *DatabaseRequest) XXX_DiscardUnknown()

func (*DatabaseRequest) XXX_Marshal 

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

func (*DatabaseRequest) XXX_Merge 

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

func (*DatabaseRequest) XXX_Size 

func (m *DatabaseRequest) XXX_Size() int

func (*DatabaseRequest) XXX_Unmarshal 

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

type DatabaseResponse 

type DatabaseResponse struct {
	Header *DatabaseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*DatabaseResponse_Redirect
	//	*DatabaseResponse_SubscriptionUpdate
	//	*DatabaseResponse_Read
	//	*DatabaseResponse_QuickRead
	//	*DatabaseResponse_Has
	//	*DatabaseResponse_Keys
	//	*DatabaseResponse_Size
	//	*DatabaseResponse_Error
	//	*DatabaseResponse_HasDb
	//	*DatabaseResponse_Writers
	Response             isDatabaseResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*DatabaseResponse) Descriptor 

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

func (*DatabaseResponse) GetError 

func (m *DatabaseResponse) GetError() *DatabaseError

func (*DatabaseResponse) GetHas 

func (m *DatabaseResponse) GetHas() *DatabaseHasResponse

func (*DatabaseResponse) GetHasDb 

func (m *DatabaseResponse) GetHasDb() *DatabaseHasDbResponse

func (*DatabaseResponse) GetHeader 

func (m *DatabaseResponse) GetHeader() *DatabaseHeader

func (*DatabaseResponse) GetKeys 

func (m *DatabaseResponse) GetKeys() *DatabaseKeysResponse

func (*DatabaseResponse) GetQuickRead 

func (m *DatabaseResponse) GetQuickRead() *DatabaseQuickReadResponse

func (*DatabaseResponse) GetRead 

func (m *DatabaseResponse) GetRead() *DatabaseReadResponse

func (*DatabaseResponse) GetRedirect 

func (m *DatabaseResponse) GetRedirect() *DatabaseRedirectResponse

func (*DatabaseResponse) GetResponse 

func (m *DatabaseResponse) GetResponse() isDatabaseResponse_Response

func (*DatabaseResponse) GetSize 

func (m *DatabaseResponse) GetSize() *DatabaseSizeResponse

func (*DatabaseResponse) GetSubscriptionUpdate 

func (m *DatabaseResponse) GetSubscriptionUpdate() *DatabaseSubscriptionUpdate

func (*DatabaseResponse) GetWriters 

func (m *DatabaseResponse) GetWriters() *DatabaseWritersResponse

func (*DatabaseResponse) ProtoMessage 

func (*DatabaseResponse) ProtoMessage()

func (*DatabaseResponse) Reset 

func (m *DatabaseResponse) Reset()

func (*DatabaseResponse) String 

func (m *DatabaseResponse) String() string

func (*DatabaseResponse) XXX_DiscardUnknown 

func (m *DatabaseResponse) XXX_DiscardUnknown()

func (*DatabaseResponse) XXX_Marshal 

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

func (*DatabaseResponse) XXX_Merge 

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

func (*DatabaseResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DatabaseResponse) XXX_Size 

func (m *DatabaseResponse) XXX_Size() int

func (*DatabaseResponse) XXX_Unmarshal 

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

type DatabaseResponse_Error 

type DatabaseResponse_Error struct {
	Error *DatabaseError `protobuf:"bytes,9,opt,name=error,proto3,oneof"`
}

type DatabaseResponse_Has 

type DatabaseResponse_Has struct {
	Has *DatabaseHasResponse `protobuf:"bytes,6,opt,name=has,proto3,oneof"`
}

type DatabaseResponse_HasDb 

type DatabaseResponse_HasDb struct {
	HasDb *DatabaseHasDbResponse `protobuf:"bytes,10,opt,name=has_db,json=hasDb,proto3,oneof"`
}

type DatabaseResponse_Keys 

type DatabaseResponse_Keys struct {
	Keys *DatabaseKeysResponse `protobuf:"bytes,7,opt,name=keys,proto3,oneof"`
}

type DatabaseResponse_QuickRead 

type DatabaseResponse_QuickRead struct {
	QuickRead *DatabaseQuickReadResponse `protobuf:"bytes,5,opt,name=quick_read,json=quickRead,proto3,oneof"`
}

type DatabaseResponse_Read 

type DatabaseResponse_Read struct {
	Read *DatabaseReadResponse `protobuf:"bytes,4,opt,name=read,proto3,oneof"`
}

type DatabaseResponse_Redirect 

type DatabaseResponse_Redirect struct {
	Redirect *DatabaseRedirectResponse `protobuf:"bytes,2,opt,name=redirect,proto3,oneof"`
}

type DatabaseResponse_Size 

type DatabaseResponse_Size struct {
	Size *DatabaseSizeResponse `protobuf:"bytes,8,opt,name=size,proto3,oneof"`
}

type DatabaseResponse_SubscriptionUpdate 

type DatabaseResponse_SubscriptionUpdate struct {
	SubscriptionUpdate *DatabaseSubscriptionUpdate `protobuf:"bytes,3,opt,name=subscription_update,json=subscriptionUpdate,proto3,oneof"`
}

type DatabaseResponse_Writers 

type DatabaseResponse_Writers struct {
	Writers *DatabaseWritersResponse `protobuf:"bytes,11,opt,name=writers,proto3,oneof"`
}

type DatabaseSizeResponse 

type DatabaseSizeResponse struct {
	Bytes                int32    `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Keys                 int32    `protobuf:"varint,2,opt,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseSizeResponse) Descriptor 

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

func (*DatabaseSizeResponse) GetBytes 

func (m *DatabaseSizeResponse) GetBytes() int32

func (*DatabaseSizeResponse) GetKeys 

func (m *DatabaseSizeResponse) GetKeys() int32

func (*DatabaseSizeResponse) ProtoMessage 

func (*DatabaseSizeResponse) ProtoMessage()

func (*DatabaseSizeResponse) Reset 

func (m *DatabaseSizeResponse) Reset()

func (*DatabaseSizeResponse) String 

func (m *DatabaseSizeResponse) String() string

func (*DatabaseSizeResponse) XXX_DiscardUnknown 

func (m *DatabaseSizeResponse) XXX_DiscardUnknown()

func (*DatabaseSizeResponse) XXX_Marshal 

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

func (*DatabaseSizeResponse) XXX_Merge 

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

func (*DatabaseSizeResponse) XXX_Size 

func (m *DatabaseSizeResponse) XXX_Size() int

func (*DatabaseSizeResponse) XXX_Unmarshal 

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

type DatabaseSubscribe 

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

func (*DatabaseSubscribe) Descriptor 

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

func (*DatabaseSubscribe) GetKey 

func (m *DatabaseSubscribe) GetKey() string

func (*DatabaseSubscribe) ProtoMessage 

func (*DatabaseSubscribe) ProtoMessage()

func (*DatabaseSubscribe) Reset 

func (m *DatabaseSubscribe) Reset()

func (*DatabaseSubscribe) String 

func (m *DatabaseSubscribe) String() string

func (*DatabaseSubscribe) XXX_DiscardUnknown 

func (m *DatabaseSubscribe) XXX_DiscardUnknown()

func (*DatabaseSubscribe) XXX_Marshal 

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

func (*DatabaseSubscribe) XXX_Merge 

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

func (*DatabaseSubscribe) XXX_Size 

func (m *DatabaseSubscribe) XXX_Size() int

func (*DatabaseSubscribe) XXX_Unmarshal 

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

type DatabaseSubscriptionUpdate 

type DatabaseSubscriptionUpdate struct {
	Key                  string                                  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte                                  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Operation            DatabaseSubscriptionUpdateOperationType `protobuf:"varint,3,opt,name=operation,proto3,enum=pb.DatabaseSubscriptionUpdateOperationType" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*DatabaseSubscriptionUpdate) Descriptor 

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

func (*DatabaseSubscriptionUpdate) GetKey 

func (m *DatabaseSubscriptionUpdate) GetKey() string

func (*DatabaseSubscriptionUpdate) GetOperation 

func (m *DatabaseSubscriptionUpdate) GetOperation() DatabaseSubscriptionUpdateOperationType

func (*DatabaseSubscriptionUpdate) GetValue 

func (m *DatabaseSubscriptionUpdate) GetValue() []byte

func (*DatabaseSubscriptionUpdate) ProtoMessage 

func (*DatabaseSubscriptionUpdate) ProtoMessage()

func (*DatabaseSubscriptionUpdate) Reset 

func (m *DatabaseSubscriptionUpdate) Reset()

func (*DatabaseSubscriptionUpdate) String 

func (m *DatabaseSubscriptionUpdate) String() string

func (*DatabaseSubscriptionUpdate) XXX_DiscardUnknown 

func (m *DatabaseSubscriptionUpdate) XXX_DiscardUnknown()

func (*DatabaseSubscriptionUpdate) XXX_Marshal 

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

func (*DatabaseSubscriptionUpdate) XXX_Merge 

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

func (*DatabaseSubscriptionUpdate) XXX_Size 

func (m *DatabaseSubscriptionUpdate) XXX_Size() int

func (*DatabaseSubscriptionUpdate) XXX_Unmarshal 

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

type DatabaseSubscriptionUpdateOperationType 

type DatabaseSubscriptionUpdateOperationType int32
const (
	DatabaseSubscriptionUpdate_UPDATE DatabaseSubscriptionUpdateOperationType = 0
	DatabaseSubscriptionUpdate_DELETE DatabaseSubscriptionUpdateOperationType = 1
)

func (DatabaseSubscriptionUpdateOperationType) EnumDescriptor 

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

func (DatabaseSubscriptionUpdateOperationType) String 

func (x DatabaseSubscriptionUpdateOperationType) String() string

type DatabaseTtlResponse 

type DatabaseTtlResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ttl                  uint64   `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseTtlResponse) Descriptor 

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

func (*DatabaseTtlResponse) GetKey 

func (m *DatabaseTtlResponse) GetKey() string

func (*DatabaseTtlResponse) GetTtl 

func (m *DatabaseTtlResponse) GetTtl() uint64

func (*DatabaseTtlResponse) ProtoMessage 

func (*DatabaseTtlResponse) ProtoMessage()

func (*DatabaseTtlResponse) Reset 

func (m *DatabaseTtlResponse) Reset()

func (*DatabaseTtlResponse) String 

func (m *DatabaseTtlResponse) String() string

func (*DatabaseTtlResponse) XXX_DiscardUnknown 

func (m *DatabaseTtlResponse) XXX_DiscardUnknown()

func (*DatabaseTtlResponse) XXX_Marshal 

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

func (*DatabaseTtlResponse) XXX_Merge 

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

func (*DatabaseTtlResponse) XXX_Size 

func (m *DatabaseTtlResponse) XXX_Size() int

func (*DatabaseTtlResponse) XXX_Unmarshal 

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

type DatabaseUnsubscribe 

type DatabaseUnsubscribe struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Nonce                uint64   `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseUnsubscribe) Descriptor 

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

func (*DatabaseUnsubscribe) GetKey 

func (m *DatabaseUnsubscribe) GetKey() string

func (*DatabaseUnsubscribe) GetNonce 

func (m *DatabaseUnsubscribe) GetNonce() uint64

func (*DatabaseUnsubscribe) ProtoMessage 

func (*DatabaseUnsubscribe) ProtoMessage()

func (*DatabaseUnsubscribe) Reset 

func (m *DatabaseUnsubscribe) Reset()

func (*DatabaseUnsubscribe) String 

func (m *DatabaseUnsubscribe) String() string

func (*DatabaseUnsubscribe) XXX_DiscardUnknown 

func (m *DatabaseUnsubscribe) XXX_DiscardUnknown()

func (*DatabaseUnsubscribe) XXX_Marshal 

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

func (*DatabaseUnsubscribe) XXX_Merge 

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

func (*DatabaseUnsubscribe) XXX_Size 

func (m *DatabaseUnsubscribe) XXX_Size() int

func (*DatabaseUnsubscribe) XXX_Unmarshal 

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

type DatabaseUpdate 

type DatabaseUpdate struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Expire               uint64   `protobuf:"varint,3,opt,name=expire,proto3" json:"expire,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseUpdate) Descriptor 

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

func (*DatabaseUpdate) GetExpire 

func (m *DatabaseUpdate) GetExpire() uint64

func (*DatabaseUpdate) GetKey 

func (m *DatabaseUpdate) GetKey() string

func (*DatabaseUpdate) GetValue 

func (m *DatabaseUpdate) GetValue() []byte

func (*DatabaseUpdate) ProtoMessage 

func (*DatabaseUpdate) ProtoMessage()

func (*DatabaseUpdate) Reset 

func (m *DatabaseUpdate) Reset()

func (*DatabaseUpdate) String 

func (m *DatabaseUpdate) String() string

func (*DatabaseUpdate) XXX_DiscardUnknown 

func (m *DatabaseUpdate) XXX_DiscardUnknown()

func (*DatabaseUpdate) XXX_Marshal 

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

func (*DatabaseUpdate) XXX_Merge 

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

func (*DatabaseUpdate) XXX_Size 

func (m *DatabaseUpdate) XXX_Size() int

func (*DatabaseUpdate) XXX_Unmarshal 

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

type DatabaseWriters 

type DatabaseWriters struct {
	Writers              []string `protobuf:"bytes,1,rep,name=writers,proto3" json:"writers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseWriters) Descriptor 

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

func (*DatabaseWriters) GetWriters 

func (m *DatabaseWriters) GetWriters() []string

func (*DatabaseWriters) ProtoMessage 

func (*DatabaseWriters) ProtoMessage()

func (*DatabaseWriters) Reset 

func (m *DatabaseWriters) Reset()

func (*DatabaseWriters) String 

func (m *DatabaseWriters) String() string

func (*DatabaseWriters) XXX_DiscardUnknown 

func (m *DatabaseWriters) XXX_DiscardUnknown()

func (*DatabaseWriters) XXX_Marshal 

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

func (*DatabaseWriters) XXX_Merge 

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

func (*DatabaseWriters) XXX_Size 

func (m *DatabaseWriters) XXX_Size() int

func (*DatabaseWriters) XXX_Unmarshal 

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

type DatabaseWritersResponse 

type DatabaseWritersResponse struct {
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Writers              []string `protobuf:"bytes,2,rep,name=writers,proto3" json:"writers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseWritersResponse) Descriptor 

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

func (*DatabaseWritersResponse) GetOwner 

func (m *DatabaseWritersResponse) GetOwner() string

func (*DatabaseWritersResponse) GetWriters 

func (m *DatabaseWritersResponse) GetWriters() []string

func (*DatabaseWritersResponse) ProtoMessage 

func (*DatabaseWritersResponse) ProtoMessage()

func (*DatabaseWritersResponse) Reset 

func (m *DatabaseWritersResponse) Reset()

func (*DatabaseWritersResponse) String 

func (m *DatabaseWritersResponse) String() string

func (*DatabaseWritersResponse) XXX_DiscardUnknown 

func (m *DatabaseWritersResponse) XXX_DiscardUnknown()

func (*DatabaseWritersResponse) XXX_Marshal 

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

func (*DatabaseWritersResponse) XXX_Merge 

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

func (*DatabaseWritersResponse) XXX_Size 

func (m *DatabaseWritersResponse) XXX_Size() int

func (*DatabaseWritersResponse) XXX_Unmarshal 

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

type FailureDetected 

type FailureDetected struct {
	SenderUuid           string   `protobuf:"bytes,1,opt,name=sender_uuid,json=senderUuid,proto3" json:"sender_uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FailureDetected) Descriptor 

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

func (*FailureDetected) GetSenderUuid 

func (m *FailureDetected) GetSenderUuid() string

func (*FailureDetected) ProtoMessage 

func (*FailureDetected) ProtoMessage()

func (*FailureDetected) Reset 

func (m *FailureDetected) Reset()

func (*FailureDetected) String 

func (m *FailureDetected) String() string

func (*FailureDetected) XXX_DiscardUnknown 

func (m *FailureDetected) XXX_DiscardUnknown()

func (*FailureDetected) XXX_Marshal 

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

func (*FailureDetected) XXX_Merge 

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

func (*FailureDetected) XXX_Size 

func (m *FailureDetected) XXX_Size() int

func (*FailureDetected) XXX_Unmarshal 

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

type LeaderStatus 

type LeaderStatus struct {
	Term                 uint64   `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Leader               string   `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	CurrentLogIndex      uint64   `protobuf:"varint,3,opt,name=current_log_index,json=currentLogIndex,proto3" json:"current_log_index,omitempty"`
	CurrentCommitIndex   uint64   `protobuf:"varint,4,opt,name=current_commit_index,json=currentCommitIndex,proto3" json:"current_commit_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaderStatus) Descriptor 

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

func (*LeaderStatus) GetCurrentCommitIndex 

func (m *LeaderStatus) GetCurrentCommitIndex() uint64

func (*LeaderStatus) GetCurrentLogIndex 

func (m *LeaderStatus) GetCurrentLogIndex() uint64

func (*LeaderStatus) GetLeader 

func (m *LeaderStatus) GetLeader() string

func (*LeaderStatus) GetTerm 

func (m *LeaderStatus) GetTerm() uint64

func (*LeaderStatus) ProtoMessage 

func (*LeaderStatus) ProtoMessage()

func (*LeaderStatus) Reset 

func (m *LeaderStatus) Reset()

func (*LeaderStatus) String 

func (m *LeaderStatus) String() string

func (*LeaderStatus) XXX_DiscardUnknown 

func (m *LeaderStatus) XXX_DiscardUnknown()

func (*LeaderStatus) XXX_Marshal 

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

func (*LeaderStatus) XXX_Merge 

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

func (*LeaderStatus) XXX_Size 

func (m *LeaderStatus) XXX_Size() int

func (*LeaderStatus) XXX_Unmarshal 

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

type PbftCommitNotification 

type PbftCommitNotification struct {
	SenderUuid           string   `protobuf:"bytes,1,opt,name=sender_uuid,json=senderUuid,proto3" json:"sender_uuid,omitempty"`
	SequenceNumber       uint64   `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	Operation            []byte   `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PbftCommitNotification) Descriptor 

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

func (*PbftCommitNotification) GetOperation 

func (m *PbftCommitNotification) GetOperation() []byte

func (*PbftCommitNotification) GetSenderUuid 

func (m *PbftCommitNotification) GetSenderUuid() string

func (*PbftCommitNotification) GetSequenceNumber 

func (m *PbftCommitNotification) GetSequenceNumber() uint64

func (*PbftCommitNotification) ProtoMessage 

func (*PbftCommitNotification) ProtoMessage()

func (*PbftCommitNotification) Reset 

func (m *PbftCommitNotification) Reset()

func (*PbftCommitNotification) String 

func (m *PbftCommitNotification) String() string

func (*PbftCommitNotification) XXX_DiscardUnknown 

func (m *PbftCommitNotification) XXX_DiscardUnknown()

func (*PbftCommitNotification) XXX_Marshal 

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

func (*PbftCommitNotification) XXX_Merge 

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

func (*PbftCommitNotification) XXX_Size 

func (m *PbftCommitNotification) XXX_Size() int

func (*PbftCommitNotification) XXX_Unmarshal 

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

type PbftConfigMsg 

type PbftConfigMsg struct {
	// for new_config
	Configuration        string   `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	JoinRequestHash      []byte   `protobuf:"bytes,2,opt,name=join_request_hash,json=joinRequestHash,proto3" json:"join_request_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PbftConfigMsg) Descriptor 

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

func (*PbftConfigMsg) GetConfiguration 

func (m *PbftConfigMsg) GetConfiguration() string

func (*PbftConfigMsg) GetJoinRequestHash 

func (m *PbftConfigMsg) GetJoinRequestHash() []byte

func (*PbftConfigMsg) ProtoMessage 

func (*PbftConfigMsg) ProtoMessage()

func (*PbftConfigMsg) Reset 

func (m *PbftConfigMsg) Reset()

func (*PbftConfigMsg) String 

func (m *PbftConfigMsg) String() string

func (*PbftConfigMsg) XXX_DiscardUnknown 

func (m *PbftConfigMsg) XXX_DiscardUnknown()

func (*PbftConfigMsg) XXX_Marshal 

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

func (*PbftConfigMsg) XXX_Merge 

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

func (*PbftConfigMsg) XXX_Size 

func (m *PbftConfigMsg) XXX_Size() int

func (*PbftConfigMsg) XXX_Unmarshal 

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

type PbftMembershipMsg 

type PbftMembershipMsg struct {
	Type PbftMembershipMsgType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.PbftMembershipMsgType" json:"type,omitempty"`
	// for join/leave requests
	PeerInfo *PbftPeerInfo `protobuf:"bytes,2,opt,name=peer_info,json=peerInfo,proto3" json:"peer_info,omitempty"`
	// for get_state, set_state
	Sequence  uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	StateHash string `protobuf:"bytes,4,opt,name=state_hash,json=stateHash,proto3" json:"state_hash,omitempty"`
	// for set_state
	StateData            string       `protobuf:"bytes,5,opt,name=state_data,json=stateData,proto3" json:"state_data,omitempty"`
	NewviewMsg           *BznEnvelope `protobuf:"bytes,6,opt,name=newview_msg,json=newviewMsg,proto3" json:"newview_msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PbftMembershipMsg) Descriptor 

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

func (*PbftMembershipMsg) GetNewviewMsg 

func (m *PbftMembershipMsg) GetNewviewMsg() *BznEnvelope

func (*PbftMembershipMsg) GetPeerInfo 

func (m *PbftMembershipMsg) GetPeerInfo() *PbftPeerInfo

func (*PbftMembershipMsg) GetSequence 

func (m *PbftMembershipMsg) GetSequence() uint64

func (*PbftMembershipMsg) GetStateData 

func (m *PbftMembershipMsg) GetStateData() string

func (*PbftMembershipMsg) GetStateHash 

func (m *PbftMembershipMsg) GetStateHash() string

func (*PbftMembershipMsg) GetType 

func (m *PbftMembershipMsg) GetType() PbftMembershipMsgType

func (*PbftMembershipMsg) ProtoMessage 

func (*PbftMembershipMsg) ProtoMessage()

func (*PbftMembershipMsg) Reset 

func (m *PbftMembershipMsg) Reset()

func (*PbftMembershipMsg) String 

func (m *PbftMembershipMsg) String() string

func (*PbftMembershipMsg) XXX_DiscardUnknown 

func (m *PbftMembershipMsg) XXX_DiscardUnknown()

func (*PbftMembershipMsg) XXX_Marshal 

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

func (*PbftMembershipMsg) XXX_Merge 

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

func (*PbftMembershipMsg) XXX_Size 

func (m *PbftMembershipMsg) XXX_Size() int

func (*PbftMembershipMsg) XXX_Unmarshal 

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

type PbftMembershipMsgType 

type PbftMembershipMsgType int32
const (
	PbftMembershipMsgType_PBFT_MMSG_UNDEFINED     PbftMembershipMsgType = 0
	PbftMembershipMsgType_PBFT_MMSG_JOIN          PbftMembershipMsgType = 1
	PbftMembershipMsgType_PBFT_MMSG_JOIN_RESPONSE PbftMembershipMsgType = 2
	PbftMembershipMsgType_PBFT_MMSG_LEAVE         PbftMembershipMsgType = 3
	PbftMembershipMsgType_PBFT_MMSG_GET_STATE     PbftMembershipMsgType = 4
	PbftMembershipMsgType_PBFT_MMSG_SET_STATE     PbftMembershipMsgType = 5
)

func (PbftMembershipMsgType) EnumDescriptor 

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

func (PbftMembershipMsgType) String 

func (x PbftMembershipMsgType) String() string

type PbftMsg 

type PbftMsg struct {
	Type PbftMsgType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.PbftMsgType" json:"type,omitempty"`
	// used for preprepare, prepare, commit, viewchange(v+1)
	View uint64 `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	// used for preprepare, prepare, commit, checkpoint, viewchange (last valid checkpoint sequence)
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// used for preprepare, prepare, commit
	RequestHash []byte `protobuf:"bytes,5,opt,name=request_hash,json=requestHash,proto3" json:"request_hash,omitempty"`
	// most messages should only have the hash, not the original request
	Request *BznEnvelope `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// for checkpoints
	StateHash string `protobuf:"bytes,6,opt,name=state_hash,json=stateHash,proto3" json:"state_hash,omitempty"`
	// for join/leave requests
	PeerInfo *PbftPeerInfo `protobuf:"bytes,7,opt,name=peer_info,json=peerInfo,proto3" json:"peer_info,omitempty"`
	// for viewchange
	CheckpointMessages []*BznEnvelope `protobuf:"bytes,8,rep,name=checkpoint_messages,json=checkpointMessages,proto3" json:"checkpoint_messages,omitempty"`
	// for viewchange, and newview (O)
	// P, p_m, O
	PreparedProofs []*PreparedProof `protobuf:"bytes,9,rep,name=prepared_proofs,json=preparedProofs,proto3" json:"prepared_proofs,omitempty"`
	// for newview
	// V valid view change messages
	ViewchangeMessages []*BznEnvelope `protobuf:"bytes,11,rep,name=viewchange_messages,json=viewchangeMessages,proto3" json:"viewchange_messages,omitempty"`
	PrePrepareMessages []*BznEnvelope `protobuf:"bytes,12,rep,name=pre_prepare_messages,json=prePrepareMessages,proto3" json:"pre_prepare_messages,omitempty"`
	// for newview
	ConfigHash string `protobuf:"bytes,13,opt,name=config_hash,json=configHash,proto3" json:"config_hash,omitempty"`
	// for newview
	Config               string   `protobuf:"bytes,14,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PbftMsg) Descriptor 

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

func (*PbftMsg) GetCheckpointMessages 

func (m *PbftMsg) GetCheckpointMessages() []*BznEnvelope

func (*PbftMsg) GetConfig 

func (m *PbftMsg) GetConfig() string

func (*PbftMsg) GetConfigHash 

func (m *PbftMsg) GetConfigHash() string

func (*PbftMsg) GetPeerInfo 

func (m *PbftMsg) GetPeerInfo() *PbftPeerInfo

func (*PbftMsg) GetPrePrepareMessages 

func (m *PbftMsg) GetPrePrepareMessages() []*BznEnvelope

func (*PbftMsg) GetPreparedProofs 

func (m *PbftMsg) GetPreparedProofs() []*PreparedProof

func (*PbftMsg) GetRequest 

func (m *PbftMsg) GetRequest() *BznEnvelope

func (*PbftMsg) GetRequestHash 

func (m *PbftMsg) GetRequestHash() []byte

func (*PbftMsg) GetSequence 

func (m *PbftMsg) GetSequence() uint64

func (*PbftMsg) GetStateHash 

func (m *PbftMsg) GetStateHash() string

func (*PbftMsg) GetType 

func (m *PbftMsg) GetType() PbftMsgType

func (*PbftMsg) GetView 

func (m *PbftMsg) GetView() uint64

func (*PbftMsg) GetViewchangeMessages 

func (m *PbftMsg) GetViewchangeMessages() []*BznEnvelope

func (*PbftMsg) ProtoMessage 

func (*PbftMsg) ProtoMessage()

func (*PbftMsg) Reset 

func (m *PbftMsg) Reset()

func (*PbftMsg) String 

func (m *PbftMsg) String() string

func (*PbftMsg) XXX_DiscardUnknown 

func (m *PbftMsg) XXX_DiscardUnknown()

func (*PbftMsg) XXX_Marshal 

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

func (*PbftMsg) XXX_Merge 

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

func (*PbftMsg) XXX_Size 

func (m *PbftMsg) XXX_Size() int

func (*PbftMsg) XXX_Unmarshal 

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

type PbftMsgType 

type PbftMsgType int32
const (
	PbftMsgType_PBFT_MSG_UNDEFINED  PbftMsgType = 0
	PbftMsgType_PBFT_MSG_PREPREPARE PbftMsgType = 2
	PbftMsgType_PBFT_MSG_PREPARE    PbftMsgType = 3
	PbftMsgType_PBFT_MSG_COMMIT     PbftMsgType = 4
	PbftMsgType_PBFT_MSG_CHECKPOINT PbftMsgType = 5
	PbftMsgType_PBFT_MSG_JOIN       PbftMsgType = 6
	PbftMsgType_PBFT_MSG_LEAVE      PbftMsgType = 7
	PbftMsgType_PBFT_MSG_VIEWCHANGE PbftMsgType = 8
	PbftMsgType_PBFT_MSG_NEWVIEW    PbftMsgType = 9
)

func (PbftMsgType) EnumDescriptor 

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

func (PbftMsgType) String 

func (x PbftMsgType) String() string

type PbftPeerInfo 

type PbftPeerInfo struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	HttpPort             uint32   `protobuf:"varint,3,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Uuid                 string   `protobuf:"bytes,5,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PbftPeerInfo) Descriptor 

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

func (*PbftPeerInfo) GetHost 

func (m *PbftPeerInfo) GetHost() string

func (*PbftPeerInfo) GetHttpPort 

func (m *PbftPeerInfo) GetHttpPort() uint32

func (*PbftPeerInfo) GetName 

func (m *PbftPeerInfo) GetName() string

func (*PbftPeerInfo) GetPort 

func (m *PbftPeerInfo) GetPort() uint32

func (*PbftPeerInfo) GetUuid 

func (m *PbftPeerInfo) GetUuid() string

func (*PbftPeerInfo) ProtoMessage 

func (*PbftPeerInfo) ProtoMessage()

func (*PbftPeerInfo) Reset 

func (m *PbftPeerInfo) Reset()

func (*PbftPeerInfo) String 

func (m *PbftPeerInfo) String() string

func (*PbftPeerInfo) XXX_DiscardUnknown 

func (m *PbftPeerInfo) XXX_DiscardUnknown()

func (*PbftPeerInfo) XXX_Marshal 

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

func (*PbftPeerInfo) XXX_Merge 

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

func (*PbftPeerInfo) XXX_Size 

func (m *PbftPeerInfo) XXX_Size() int

func (*PbftPeerInfo) XXX_Unmarshal 

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

type PreparedProof 

type PreparedProof struct {
	PrePrepare           *BznEnvelope   `protobuf:"bytes,1,opt,name=pre_prepare,json=prePrepare,proto3" json:"pre_prepare,omitempty"`
	Prepare              []*BznEnvelope `protobuf:"bytes,2,rep,name=prepare,proto3" json:"prepare,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PreparedProof) Descriptor 

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

func (*PreparedProof) GetPrePrepare 

func (m *PreparedProof) GetPrePrepare() *BznEnvelope

func (*PreparedProof) GetPrepare 

func (m *PreparedProof) GetPrepare() []*BznEnvelope

func (*PreparedProof) ProtoMessage 

func (*PreparedProof) ProtoMessage()

func (*PreparedProof) Reset 

func (m *PreparedProof) Reset()

func (*PreparedProof) String 

func (m *PreparedProof) String() string

func (*PreparedProof) XXX_DiscardUnknown 

func (m *PreparedProof) XXX_DiscardUnknown()

func (*PreparedProof) XXX_Marshal 

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

func (*PreparedProof) XXX_Merge 

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

func (*PreparedProof) XXX_Size 

func (m *PreparedProof) XXX_Size() int

func (*PreparedProof) XXX_Unmarshal 

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

type PrimaryStatus 

type PrimaryStatus struct {
	View                 uint64   `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"`
	Primary              string   `protobuf:"bytes,2,opt,name=primary,proto3" json:"primary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrimaryStatus) Descriptor 

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

func (*PrimaryStatus) GetPrimary 

func (m *PrimaryStatus) GetPrimary() string

func (*PrimaryStatus) GetView 

func (m *PrimaryStatus) GetView() uint64

func (*PrimaryStatus) ProtoMessage 

func (*PrimaryStatus) ProtoMessage()

func (*PrimaryStatus) Reset 

func (m *PrimaryStatus) Reset()

func (*PrimaryStatus) String 

func (m *PrimaryStatus) String() string

func (*PrimaryStatus) XXX_DiscardUnknown 

func (m *PrimaryStatus) XXX_DiscardUnknown()

func (*PrimaryStatus) XXX_Marshal 

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

func (*PrimaryStatus) XXX_Merge 

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

func (*PrimaryStatus) XXX_Size 

func (m *PrimaryStatus) XXX_Size() int

func (*PrimaryStatus) XXX_Unmarshal 

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

type StatusRequest 

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

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	SwarmVersion         string   `protobuf:"bytes,1,opt,name=swarm_version,json=swarmVersion,proto3" json:"swarm_version,omitempty"`
	SwarmGitCommit       string   `protobuf:"bytes,2,opt,name=swarm_git_commit,json=swarmGitCommit,proto3" json:"swarm_git_commit,omitempty"`
	Uptime               string   `protobuf:"bytes,3,opt,name=uptime,proto3" json:"uptime,omitempty"`
	ModuleStatusJson     string   `protobuf:"bytes,4,opt,name=module_status_json,json=moduleStatusJson,proto3" json:"module_status_json,omitempty"`
	PbftEnabled          bool     `protobuf:"varint,5,opt,name=pbft_enabled,json=pbftEnabled,proto3" json:"pbft_enabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetModuleStatusJson 

func (m *StatusResponse) GetModuleStatusJson() string

func (*StatusResponse) GetPbftEnabled 

func (m *StatusResponse) GetPbftEnabled() bool

func (*StatusResponse) GetSwarmGitCommit 

func (m *StatusResponse) GetSwarmGitCommit() string

func (*StatusResponse) GetSwarmVersion 

func (m *StatusResponse) GetSwarmVersion() string

func (*StatusResponse) GetUptime 

func (m *StatusResponse) GetUptime() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.