Documentation ¶
Index ¶
- Variables
- type AuditMessage
- func (*AuditMessage) Descriptor() ([]byte, []int)
- func (m *AuditMessage) GetFailureDetected() *FailureDetected
- func (m *AuditMessage) GetMsg() isAuditMessage_Msg
- func (m *AuditMessage) GetPbftCommit() *PbftCommitNotification
- func (m *AuditMessage) GetPrimaryStatus() *PrimaryStatus
- func (*AuditMessage) ProtoMessage()
- func (m *AuditMessage) Reset()
- func (m *AuditMessage) String() string
- func (m *AuditMessage) XXX_DiscardUnknown()
- func (m *AuditMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuditMessage) XXX_Merge(src proto.Message)
- func (*AuditMessage) XXX_OneofWrappers() []interface{}
- func (m *AuditMessage) XXX_Size() int
- func (m *AuditMessage) XXX_Unmarshal(b []byte) error
- type AuditMessage_FailureDetected
- type AuditMessage_PbftCommit
- type AuditMessage_PrimaryStatus
- type BznEnvelope
- func (*BznEnvelope) Descriptor() ([]byte, []int)
- func (m *BznEnvelope) GetAudit() []byte
- func (m *BznEnvelope) GetDatabaseMsg() []byte
- func (m *BznEnvelope) GetDatabaseResponse() []byte
- func (m *BznEnvelope) GetJson() []byte
- func (m *BznEnvelope) GetPayload() isBznEnvelope_Payload
- func (m *BznEnvelope) GetPbft() []byte
- func (m *BznEnvelope) GetPbftInternalRequest() []byte
- func (m *BznEnvelope) GetPbftMembership() []byte
- func (m *BznEnvelope) GetSender() string
- func (m *BznEnvelope) GetSignature() []byte
- func (m *BznEnvelope) GetStatusRequest() []byte
- func (m *BznEnvelope) GetStatusResponse() []byte
- func (m *BznEnvelope) GetTimestamp() uint64
- func (*BznEnvelope) ProtoMessage()
- func (m *BznEnvelope) Reset()
- func (m *BznEnvelope) String() string
- func (m *BznEnvelope) XXX_DiscardUnknown()
- func (m *BznEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BznEnvelope) XXX_Merge(src proto.Message)
- func (*BznEnvelope) XXX_OneofWrappers() []interface{}
- func (m *BznEnvelope) XXX_Size() int
- func (m *BznEnvelope) XXX_Unmarshal(b []byte) error
- type BznEnvelope_Audit
- type BznEnvelope_DatabaseMsg
- type BznEnvelope_DatabaseResponse
- type BznEnvelope_Json
- type BznEnvelope_Pbft
- type BznEnvelope_PbftInternalRequest
- type BznEnvelope_PbftMembership
- type BznEnvelope_StatusRequest
- type BznEnvelope_StatusResponse
- type DatabaseCreate
- func (*DatabaseCreate) Descriptor() ([]byte, []int)
- func (m *DatabaseCreate) GetExpire() uint64
- func (m *DatabaseCreate) GetKey() string
- func (m *DatabaseCreate) GetValue() []byte
- func (*DatabaseCreate) ProtoMessage()
- func (m *DatabaseCreate) Reset()
- func (m *DatabaseCreate) String() string
- func (m *DatabaseCreate) XXX_DiscardUnknown()
- func (m *DatabaseCreate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseCreate) XXX_Merge(src proto.Message)
- func (m *DatabaseCreate) XXX_Size() int
- func (m *DatabaseCreate) XXX_Unmarshal(b []byte) error
- type DatabaseDelete
- func (*DatabaseDelete) Descriptor() ([]byte, []int)
- func (m *DatabaseDelete) GetKey() string
- func (*DatabaseDelete) ProtoMessage()
- func (m *DatabaseDelete) Reset()
- func (m *DatabaseDelete) String() string
- func (m *DatabaseDelete) XXX_DiscardUnknown()
- func (m *DatabaseDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseDelete) XXX_Merge(src proto.Message)
- func (m *DatabaseDelete) XXX_Size() int
- func (m *DatabaseDelete) XXX_Unmarshal(b []byte) error
- type DatabaseError
- func (*DatabaseError) Descriptor() ([]byte, []int)
- func (m *DatabaseError) GetMessage() string
- func (*DatabaseError) ProtoMessage()
- func (m *DatabaseError) Reset()
- func (m *DatabaseError) String() string
- func (m *DatabaseError) XXX_DiscardUnknown()
- func (m *DatabaseError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseError) XXX_Merge(src proto.Message)
- func (m *DatabaseError) XXX_Size() int
- func (m *DatabaseError) XXX_Unmarshal(b []byte) error
- type DatabaseExpire
- func (*DatabaseExpire) Descriptor() ([]byte, []int)
- func (m *DatabaseExpire) GetExpire() uint64
- func (m *DatabaseExpire) GetKey() string
- func (*DatabaseExpire) ProtoMessage()
- func (m *DatabaseExpire) Reset()
- func (m *DatabaseExpire) String() string
- func (m *DatabaseExpire) XXX_DiscardUnknown()
- func (m *DatabaseExpire) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseExpire) XXX_Merge(src proto.Message)
- func (m *DatabaseExpire) XXX_Size() int
- func (m *DatabaseExpire) XXX_Unmarshal(b []byte) error
- type DatabaseHas
- func (*DatabaseHas) Descriptor() ([]byte, []int)
- func (m *DatabaseHas) GetKey() string
- func (*DatabaseHas) ProtoMessage()
- func (m *DatabaseHas) Reset()
- func (m *DatabaseHas) String() string
- func (m *DatabaseHas) XXX_DiscardUnknown()
- func (m *DatabaseHas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseHas) XXX_Merge(src proto.Message)
- func (m *DatabaseHas) XXX_Size() int
- func (m *DatabaseHas) XXX_Unmarshal(b []byte) error
- type DatabaseHasDb
- func (*DatabaseHasDb) Descriptor() ([]byte, []int)
- func (*DatabaseHasDb) ProtoMessage()
- func (m *DatabaseHasDb) Reset()
- func (m *DatabaseHasDb) String() string
- func (m *DatabaseHasDb) XXX_DiscardUnknown()
- func (m *DatabaseHasDb) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseHasDb) XXX_Merge(src proto.Message)
- func (m *DatabaseHasDb) XXX_Size() int
- func (m *DatabaseHasDb) XXX_Unmarshal(b []byte) error
- type DatabaseHasDbResponse
- func (*DatabaseHasDbResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseHasDbResponse) GetHas() bool
- func (m *DatabaseHasDbResponse) GetUuid() string
- func (*DatabaseHasDbResponse) ProtoMessage()
- func (m *DatabaseHasDbResponse) Reset()
- func (m *DatabaseHasDbResponse) String() string
- func (m *DatabaseHasDbResponse) XXX_DiscardUnknown()
- func (m *DatabaseHasDbResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseHasDbResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseHasDbResponse) XXX_Size() int
- func (m *DatabaseHasDbResponse) XXX_Unmarshal(b []byte) error
- type DatabaseHasResponse
- func (*DatabaseHasResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseHasResponse) GetHas() bool
- func (m *DatabaseHasResponse) GetKey() string
- func (*DatabaseHasResponse) ProtoMessage()
- func (m *DatabaseHasResponse) Reset()
- func (m *DatabaseHasResponse) String() string
- func (m *DatabaseHasResponse) XXX_DiscardUnknown()
- func (m *DatabaseHasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseHasResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseHasResponse) XXX_Size() int
- func (m *DatabaseHasResponse) XXX_Unmarshal(b []byte) error
- type DatabaseHeader
- func (*DatabaseHeader) Descriptor() ([]byte, []int)
- func (m *DatabaseHeader) GetDbUuid() string
- func (m *DatabaseHeader) GetNonce() uint64
- func (m *DatabaseHeader) GetPointOfContact() string
- func (m *DatabaseHeader) GetRequestHash() []byte
- func (*DatabaseHeader) ProtoMessage()
- func (m *DatabaseHeader) Reset()
- func (m *DatabaseHeader) String() string
- func (m *DatabaseHeader) XXX_DiscardUnknown()
- func (m *DatabaseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseHeader) XXX_Merge(src proto.Message)
- func (m *DatabaseHeader) XXX_Size() int
- func (m *DatabaseHeader) XXX_Unmarshal(b []byte) error
- type DatabaseKeysResponse
- func (*DatabaseKeysResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseKeysResponse) GetKeys() []string
- func (*DatabaseKeysResponse) ProtoMessage()
- func (m *DatabaseKeysResponse) Reset()
- func (m *DatabaseKeysResponse) String() string
- func (m *DatabaseKeysResponse) XXX_DiscardUnknown()
- func (m *DatabaseKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseKeysResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseKeysResponse) XXX_Size() int
- func (m *DatabaseKeysResponse) XXX_Unmarshal(b []byte) error
- type DatabaseMsg
- func (*DatabaseMsg) Descriptor() ([]byte, []int)
- func (m *DatabaseMsg) GetAddWriters() *DatabaseWriters
- func (m *DatabaseMsg) GetCreate() *DatabaseCreate
- func (m *DatabaseMsg) GetCreateDb() *DatabaseRequest
- func (m *DatabaseMsg) GetDelete() *DatabaseDelete
- func (m *DatabaseMsg) GetDeleteDb() *DatabaseRequest
- func (m *DatabaseMsg) GetExpire() *DatabaseExpire
- func (m *DatabaseMsg) GetHas() *DatabaseHas
- func (m *DatabaseMsg) GetHasDb() *DatabaseHasDb
- func (m *DatabaseMsg) GetHeader() *DatabaseHeader
- func (m *DatabaseMsg) GetKeys() *DatabaseRequest
- func (m *DatabaseMsg) GetMsg() isDatabaseMsg_Msg
- func (m *DatabaseMsg) GetNullmsg() *DatabaseNullmsg
- func (m *DatabaseMsg) GetPersist() *DatabaseRead
- func (m *DatabaseMsg) GetQuickRead() *DatabaseRead
- func (m *DatabaseMsg) GetRead() *DatabaseRead
- func (m *DatabaseMsg) GetRemoveWriters() *DatabaseWriters
- func (m *DatabaseMsg) GetSize() *DatabaseRequest
- func (m *DatabaseMsg) GetSubscribe() *DatabaseSubscribe
- func (m *DatabaseMsg) GetTtl() *DatabaseRead
- func (m *DatabaseMsg) GetUnsubscribe() *DatabaseUnsubscribe
- func (m *DatabaseMsg) GetUpdate() *DatabaseUpdate
- func (m *DatabaseMsg) GetWriters() *DatabaseRequest
- func (*DatabaseMsg) ProtoMessage()
- func (m *DatabaseMsg) Reset()
- func (m *DatabaseMsg) String() string
- func (m *DatabaseMsg) XXX_DiscardUnknown()
- func (m *DatabaseMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseMsg) XXX_Merge(src proto.Message)
- func (*DatabaseMsg) XXX_OneofWrappers() []interface{}
- func (m *DatabaseMsg) XXX_Size() int
- func (m *DatabaseMsg) XXX_Unmarshal(b []byte) error
- type DatabaseMsg_AddWriters
- type DatabaseMsg_Create
- type DatabaseMsg_CreateDb
- type DatabaseMsg_Delete
- type DatabaseMsg_DeleteDb
- type DatabaseMsg_Expire
- type DatabaseMsg_Has
- type DatabaseMsg_HasDb
- type DatabaseMsg_Keys
- type DatabaseMsg_Nullmsg
- type DatabaseMsg_Persist
- type DatabaseMsg_QuickRead
- type DatabaseMsg_Read
- type DatabaseMsg_RemoveWriters
- type DatabaseMsg_Size
- type DatabaseMsg_Subscribe
- type DatabaseMsg_Ttl
- type DatabaseMsg_Unsubscribe
- type DatabaseMsg_Update
- type DatabaseMsg_Writers
- type DatabaseNullmsg
- func (*DatabaseNullmsg) Descriptor() ([]byte, []int)
- func (*DatabaseNullmsg) ProtoMessage()
- func (m *DatabaseNullmsg) Reset()
- func (m *DatabaseNullmsg) String() string
- func (m *DatabaseNullmsg) XXX_DiscardUnknown()
- func (m *DatabaseNullmsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseNullmsg) XXX_Merge(src proto.Message)
- func (m *DatabaseNullmsg) XXX_Size() int
- func (m *DatabaseNullmsg) XXX_Unmarshal(b []byte) error
- type DatabaseQuickReadResponse
- func (*DatabaseQuickReadResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseQuickReadResponse) GetError() string
- func (m *DatabaseQuickReadResponse) GetKey() string
- func (m *DatabaseQuickReadResponse) GetValue() []byte
- func (*DatabaseQuickReadResponse) ProtoMessage()
- func (m *DatabaseQuickReadResponse) Reset()
- func (m *DatabaseQuickReadResponse) String() string
- func (m *DatabaseQuickReadResponse) XXX_DiscardUnknown()
- func (m *DatabaseQuickReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseQuickReadResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseQuickReadResponse) XXX_Size() int
- func (m *DatabaseQuickReadResponse) XXX_Unmarshal(b []byte) error
- type DatabaseRead
- func (*DatabaseRead) Descriptor() ([]byte, []int)
- func (m *DatabaseRead) GetKey() string
- func (*DatabaseRead) ProtoMessage()
- func (m *DatabaseRead) Reset()
- func (m *DatabaseRead) String() string
- func (m *DatabaseRead) XXX_DiscardUnknown()
- func (m *DatabaseRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseRead) XXX_Merge(src proto.Message)
- func (m *DatabaseRead) XXX_Size() int
- func (m *DatabaseRead) XXX_Unmarshal(b []byte) error
- type DatabaseReadResponse
- func (*DatabaseReadResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseReadResponse) GetKey() string
- func (m *DatabaseReadResponse) GetValue() []byte
- func (*DatabaseReadResponse) ProtoMessage()
- func (m *DatabaseReadResponse) Reset()
- func (m *DatabaseReadResponse) String() string
- func (m *DatabaseReadResponse) XXX_DiscardUnknown()
- func (m *DatabaseReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseReadResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseReadResponse) XXX_Size() int
- func (m *DatabaseReadResponse) XXX_Unmarshal(b []byte) error
- type DatabaseRedirectResponse
- func (*DatabaseRedirectResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseRedirectResponse) GetLeaderHost() string
- func (m *DatabaseRedirectResponse) GetLeaderHttpPort() uint32
- func (m *DatabaseRedirectResponse) GetLeaderId() string
- func (m *DatabaseRedirectResponse) GetLeaderName() string
- func (m *DatabaseRedirectResponse) GetLeaderPort() uint32
- func (*DatabaseRedirectResponse) ProtoMessage()
- func (m *DatabaseRedirectResponse) Reset()
- func (m *DatabaseRedirectResponse) String() string
- func (m *DatabaseRedirectResponse) XXX_DiscardUnknown()
- func (m *DatabaseRedirectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseRedirectResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseRedirectResponse) XXX_Size() int
- func (m *DatabaseRedirectResponse) XXX_Unmarshal(b []byte) error
- type DatabaseRequest
- func (*DatabaseRequest) Descriptor() ([]byte, []int)
- func (*DatabaseRequest) ProtoMessage()
- func (m *DatabaseRequest) Reset()
- func (m *DatabaseRequest) String() string
- func (m *DatabaseRequest) XXX_DiscardUnknown()
- func (m *DatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseRequest) XXX_Merge(src proto.Message)
- func (m *DatabaseRequest) XXX_Size() int
- func (m *DatabaseRequest) XXX_Unmarshal(b []byte) error
- type DatabaseResponse
- func (*DatabaseResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseResponse) GetError() *DatabaseError
- func (m *DatabaseResponse) GetHas() *DatabaseHasResponse
- func (m *DatabaseResponse) GetHasDb() *DatabaseHasDbResponse
- func (m *DatabaseResponse) GetHeader() *DatabaseHeader
- func (m *DatabaseResponse) GetKeys() *DatabaseKeysResponse
- func (m *DatabaseResponse) GetQuickRead() *DatabaseQuickReadResponse
- func (m *DatabaseResponse) GetRead() *DatabaseReadResponse
- func (m *DatabaseResponse) GetRedirect() *DatabaseRedirectResponse
- func (m *DatabaseResponse) GetResponse() isDatabaseResponse_Response
- func (m *DatabaseResponse) GetSize() *DatabaseSizeResponse
- func (m *DatabaseResponse) GetSubscriptionUpdate() *DatabaseSubscriptionUpdate
- func (m *DatabaseResponse) GetWriters() *DatabaseWritersResponse
- func (*DatabaseResponse) ProtoMessage()
- func (m *DatabaseResponse) Reset()
- func (m *DatabaseResponse) String() string
- func (m *DatabaseResponse) XXX_DiscardUnknown()
- func (m *DatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseResponse) XXX_Merge(src proto.Message)
- func (*DatabaseResponse) XXX_OneofWrappers() []interface{}
- func (m *DatabaseResponse) XXX_Size() int
- func (m *DatabaseResponse) XXX_Unmarshal(b []byte) error
- type DatabaseResponse_Error
- type DatabaseResponse_Has
- type DatabaseResponse_HasDb
- type DatabaseResponse_Keys
- type DatabaseResponse_QuickRead
- type DatabaseResponse_Read
- type DatabaseResponse_Redirect
- type DatabaseResponse_Size
- type DatabaseResponse_SubscriptionUpdate
- type DatabaseResponse_Writers
- type DatabaseSizeResponse
- func (*DatabaseSizeResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseSizeResponse) GetBytes() int32
- func (m *DatabaseSizeResponse) GetKeys() int32
- func (*DatabaseSizeResponse) ProtoMessage()
- func (m *DatabaseSizeResponse) Reset()
- func (m *DatabaseSizeResponse) String() string
- func (m *DatabaseSizeResponse) XXX_DiscardUnknown()
- func (m *DatabaseSizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseSizeResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseSizeResponse) XXX_Size() int
- func (m *DatabaseSizeResponse) XXX_Unmarshal(b []byte) error
- type DatabaseSubscribe
- func (*DatabaseSubscribe) Descriptor() ([]byte, []int)
- func (m *DatabaseSubscribe) GetKey() string
- func (*DatabaseSubscribe) ProtoMessage()
- func (m *DatabaseSubscribe) Reset()
- func (m *DatabaseSubscribe) String() string
- func (m *DatabaseSubscribe) XXX_DiscardUnknown()
- func (m *DatabaseSubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseSubscribe) XXX_Merge(src proto.Message)
- func (m *DatabaseSubscribe) XXX_Size() int
- func (m *DatabaseSubscribe) XXX_Unmarshal(b []byte) error
- type DatabaseSubscriptionUpdate
- func (*DatabaseSubscriptionUpdate) Descriptor() ([]byte, []int)
- func (m *DatabaseSubscriptionUpdate) GetKey() string
- func (m *DatabaseSubscriptionUpdate) GetOperation() DatabaseSubscriptionUpdateOperationType
- func (m *DatabaseSubscriptionUpdate) GetValue() []byte
- func (*DatabaseSubscriptionUpdate) ProtoMessage()
- func (m *DatabaseSubscriptionUpdate) Reset()
- func (m *DatabaseSubscriptionUpdate) String() string
- func (m *DatabaseSubscriptionUpdate) XXX_DiscardUnknown()
- func (m *DatabaseSubscriptionUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseSubscriptionUpdate) XXX_Merge(src proto.Message)
- func (m *DatabaseSubscriptionUpdate) XXX_Size() int
- func (m *DatabaseSubscriptionUpdate) XXX_Unmarshal(b []byte) error
- type DatabaseSubscriptionUpdateOperationType
- type DatabaseTtlResponse
- func (*DatabaseTtlResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseTtlResponse) GetKey() string
- func (m *DatabaseTtlResponse) GetTtl() uint64
- func (*DatabaseTtlResponse) ProtoMessage()
- func (m *DatabaseTtlResponse) Reset()
- func (m *DatabaseTtlResponse) String() string
- func (m *DatabaseTtlResponse) XXX_DiscardUnknown()
- func (m *DatabaseTtlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseTtlResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseTtlResponse) XXX_Size() int
- func (m *DatabaseTtlResponse) XXX_Unmarshal(b []byte) error
- type DatabaseUnsubscribe
- func (*DatabaseUnsubscribe) Descriptor() ([]byte, []int)
- func (m *DatabaseUnsubscribe) GetKey() string
- func (m *DatabaseUnsubscribe) GetNonce() uint64
- func (*DatabaseUnsubscribe) ProtoMessage()
- func (m *DatabaseUnsubscribe) Reset()
- func (m *DatabaseUnsubscribe) String() string
- func (m *DatabaseUnsubscribe) XXX_DiscardUnknown()
- func (m *DatabaseUnsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseUnsubscribe) XXX_Merge(src proto.Message)
- func (m *DatabaseUnsubscribe) XXX_Size() int
- func (m *DatabaseUnsubscribe) XXX_Unmarshal(b []byte) error
- type DatabaseUpdate
- func (*DatabaseUpdate) Descriptor() ([]byte, []int)
- func (m *DatabaseUpdate) GetExpire() uint64
- func (m *DatabaseUpdate) GetKey() string
- func (m *DatabaseUpdate) GetValue() []byte
- func (*DatabaseUpdate) ProtoMessage()
- func (m *DatabaseUpdate) Reset()
- func (m *DatabaseUpdate) String() string
- func (m *DatabaseUpdate) XXX_DiscardUnknown()
- func (m *DatabaseUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseUpdate) XXX_Merge(src proto.Message)
- func (m *DatabaseUpdate) XXX_Size() int
- func (m *DatabaseUpdate) XXX_Unmarshal(b []byte) error
- type DatabaseWriters
- func (*DatabaseWriters) Descriptor() ([]byte, []int)
- func (m *DatabaseWriters) GetWriters() []string
- func (*DatabaseWriters) ProtoMessage()
- func (m *DatabaseWriters) Reset()
- func (m *DatabaseWriters) String() string
- func (m *DatabaseWriters) XXX_DiscardUnknown()
- func (m *DatabaseWriters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseWriters) XXX_Merge(src proto.Message)
- func (m *DatabaseWriters) XXX_Size() int
- func (m *DatabaseWriters) XXX_Unmarshal(b []byte) error
- type DatabaseWritersResponse
- func (*DatabaseWritersResponse) Descriptor() ([]byte, []int)
- func (m *DatabaseWritersResponse) GetOwner() string
- func (m *DatabaseWritersResponse) GetWriters() []string
- func (*DatabaseWritersResponse) ProtoMessage()
- func (m *DatabaseWritersResponse) Reset()
- func (m *DatabaseWritersResponse) String() string
- func (m *DatabaseWritersResponse) XXX_DiscardUnknown()
- func (m *DatabaseWritersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseWritersResponse) XXX_Merge(src proto.Message)
- func (m *DatabaseWritersResponse) XXX_Size() int
- func (m *DatabaseWritersResponse) XXX_Unmarshal(b []byte) error
- type FailureDetected
- func (*FailureDetected) Descriptor() ([]byte, []int)
- func (m *FailureDetected) GetSenderUuid() string
- func (*FailureDetected) ProtoMessage()
- func (m *FailureDetected) Reset()
- func (m *FailureDetected) String() string
- func (m *FailureDetected) XXX_DiscardUnknown()
- func (m *FailureDetected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FailureDetected) XXX_Merge(src proto.Message)
- func (m *FailureDetected) XXX_Size() int
- func (m *FailureDetected) XXX_Unmarshal(b []byte) error
- type LeaderStatus
- func (*LeaderStatus) Descriptor() ([]byte, []int)
- func (m *LeaderStatus) GetCurrentCommitIndex() uint64
- func (m *LeaderStatus) GetCurrentLogIndex() uint64
- func (m *LeaderStatus) GetLeader() string
- func (m *LeaderStatus) GetTerm() uint64
- func (*LeaderStatus) ProtoMessage()
- func (m *LeaderStatus) Reset()
- func (m *LeaderStatus) String() string
- func (m *LeaderStatus) XXX_DiscardUnknown()
- func (m *LeaderStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaderStatus) XXX_Merge(src proto.Message)
- func (m *LeaderStatus) XXX_Size() int
- func (m *LeaderStatus) XXX_Unmarshal(b []byte) error
- type PbftCommitNotification
- func (*PbftCommitNotification) Descriptor() ([]byte, []int)
- func (m *PbftCommitNotification) GetOperation() []byte
- func (m *PbftCommitNotification) GetSenderUuid() string
- func (m *PbftCommitNotification) GetSequenceNumber() uint64
- func (*PbftCommitNotification) ProtoMessage()
- func (m *PbftCommitNotification) Reset()
- func (m *PbftCommitNotification) String() string
- func (m *PbftCommitNotification) XXX_DiscardUnknown()
- func (m *PbftCommitNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PbftCommitNotification) XXX_Merge(src proto.Message)
- func (m *PbftCommitNotification) XXX_Size() int
- func (m *PbftCommitNotification) XXX_Unmarshal(b []byte) error
- type PbftConfigMsg
- func (*PbftConfigMsg) Descriptor() ([]byte, []int)
- func (m *PbftConfigMsg) GetConfiguration() string
- func (m *PbftConfigMsg) GetJoinRequestHash() []byte
- func (*PbftConfigMsg) ProtoMessage()
- func (m *PbftConfigMsg) Reset()
- func (m *PbftConfigMsg) String() string
- func (m *PbftConfigMsg) XXX_DiscardUnknown()
- func (m *PbftConfigMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PbftConfigMsg) XXX_Merge(src proto.Message)
- func (m *PbftConfigMsg) XXX_Size() int
- func (m *PbftConfigMsg) XXX_Unmarshal(b []byte) error
- type PbftMembershipMsg
- func (*PbftMembershipMsg) Descriptor() ([]byte, []int)
- func (m *PbftMembershipMsg) GetNewviewMsg() *BznEnvelope
- func (m *PbftMembershipMsg) GetPeerInfo() *PbftPeerInfo
- func (m *PbftMembershipMsg) GetSequence() uint64
- func (m *PbftMembershipMsg) GetStateData() string
- func (m *PbftMembershipMsg) GetStateHash() string
- func (m *PbftMembershipMsg) GetType() PbftMembershipMsgType
- func (*PbftMembershipMsg) ProtoMessage()
- func (m *PbftMembershipMsg) Reset()
- func (m *PbftMembershipMsg) String() string
- func (m *PbftMembershipMsg) XXX_DiscardUnknown()
- func (m *PbftMembershipMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PbftMembershipMsg) XXX_Merge(src proto.Message)
- func (m *PbftMembershipMsg) XXX_Size() int
- func (m *PbftMembershipMsg) XXX_Unmarshal(b []byte) error
- type PbftMembershipMsgType
- type PbftMsg
- func (*PbftMsg) Descriptor() ([]byte, []int)
- func (m *PbftMsg) GetCheckpointMessages() []*BznEnvelope
- func (m *PbftMsg) GetConfig() string
- func (m *PbftMsg) GetConfigHash() string
- func (m *PbftMsg) GetPeerInfo() *PbftPeerInfo
- func (m *PbftMsg) GetPrePrepareMessages() []*BznEnvelope
- func (m *PbftMsg) GetPreparedProofs() []*PreparedProof
- func (m *PbftMsg) GetRequest() *BznEnvelope
- func (m *PbftMsg) GetRequestHash() []byte
- func (m *PbftMsg) GetSequence() uint64
- func (m *PbftMsg) GetStateHash() string
- func (m *PbftMsg) GetType() PbftMsgType
- func (m *PbftMsg) GetView() uint64
- func (m *PbftMsg) GetViewchangeMessages() []*BznEnvelope
- func (*PbftMsg) ProtoMessage()
- func (m *PbftMsg) Reset()
- func (m *PbftMsg) String() string
- func (m *PbftMsg) XXX_DiscardUnknown()
- func (m *PbftMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PbftMsg) XXX_Merge(src proto.Message)
- func (m *PbftMsg) XXX_Size() int
- func (m *PbftMsg) XXX_Unmarshal(b []byte) error
- type PbftMsgType
- type PbftPeerInfo
- func (*PbftPeerInfo) Descriptor() ([]byte, []int)
- func (m *PbftPeerInfo) GetHost() string
- func (m *PbftPeerInfo) GetHttpPort() uint32
- func (m *PbftPeerInfo) GetName() string
- func (m *PbftPeerInfo) GetPort() uint32
- func (m *PbftPeerInfo) GetUuid() string
- func (*PbftPeerInfo) ProtoMessage()
- func (m *PbftPeerInfo) Reset()
- func (m *PbftPeerInfo) String() string
- func (m *PbftPeerInfo) XXX_DiscardUnknown()
- func (m *PbftPeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PbftPeerInfo) XXX_Merge(src proto.Message)
- func (m *PbftPeerInfo) XXX_Size() int
- func (m *PbftPeerInfo) XXX_Unmarshal(b []byte) error
- type PreparedProof
- func (*PreparedProof) Descriptor() ([]byte, []int)
- func (m *PreparedProof) GetPrePrepare() *BznEnvelope
- func (m *PreparedProof) GetPrepare() []*BznEnvelope
- func (*PreparedProof) ProtoMessage()
- func (m *PreparedProof) Reset()
- func (m *PreparedProof) String() string
- func (m *PreparedProof) XXX_DiscardUnknown()
- func (m *PreparedProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PreparedProof) XXX_Merge(src proto.Message)
- func (m *PreparedProof) XXX_Size() int
- func (m *PreparedProof) XXX_Unmarshal(b []byte) error
- type PrimaryStatus
- func (*PrimaryStatus) Descriptor() ([]byte, []int)
- func (m *PrimaryStatus) GetPrimary() string
- func (m *PrimaryStatus) GetView() uint64
- func (*PrimaryStatus) ProtoMessage()
- func (m *PrimaryStatus) Reset()
- func (m *PrimaryStatus) String() string
- func (m *PrimaryStatus) XXX_DiscardUnknown()
- func (m *PrimaryStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimaryStatus) XXX_Merge(src proto.Message)
- func (m *PrimaryStatus) XXX_Size() int
- func (m *PrimaryStatus) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) String() string
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- func (m *StatusResponse) GetModuleStatusJson() string
- func (m *StatusResponse) GetPbftEnabled() bool
- func (m *StatusResponse) GetSwarmGitCommit() string
- func (m *StatusResponse) GetSwarmVersion() string
- func (m *StatusResponse) GetUptime() string
- func (*StatusResponse) ProtoMessage()
- func (m *StatusResponse) Reset()
- func (m *StatusResponse) String() string
- func (m *StatusResponse) XXX_DiscardUnknown()
- func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusResponse) XXX_Merge(src proto.Message)
- func (m *StatusResponse) XXX_Size() int
- func (m *StatusResponse) XXX_Unmarshal(b []byte) error
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) GetCheckpointMessages ¶
func (m *PbftMsg) GetCheckpointMessages() []*BznEnvelope
func (*PbftMsg) GetConfigHash ¶
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 (*PbftMsg) GetSequence ¶
func (*PbftMsg) GetStateHash ¶
func (*PbftMsg) GetType ¶
func (m *PbftMsg) GetType() PbftMsgType
func (*PbftMsg) GetViewchangeMessages ¶
func (m *PbftMsg) GetViewchangeMessages() []*BznEnvelope
func (*PbftMsg) ProtoMessage ¶
func (*PbftMsg) ProtoMessage()
func (*PbftMsg) XXX_DiscardUnknown ¶
func (m *PbftMsg) XXX_DiscardUnknown()
func (*PbftMsg) XXX_Marshal ¶
func (*PbftMsg) XXX_Unmarshal ¶
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
Click to show internal directories.
Click to hide internal directories.