Versions in this module Expand all Collapse all v1 v1.3.1 Dec 6, 2016 Changes in this version + type ArchiveStatement struct + func (*ArchiveStatement) Descriptor() ([]byte, []int) + func (*ArchiveStatement) ProtoMessage() + func (m *ArchiveStatement) Reset() + func (m *ArchiveStatement) String() string + type CompoundStatement struct + Body []*SimpleStatement + func (*CompoundStatement) Descriptor() ([]byte, []int) + func (*CompoundStatement) ProtoMessage() + func (m *CompoundStatement) GetBody() []*SimpleStatement + func (m *CompoundStatement) Reset() + func (m *CompoundStatement) String() string + type CompoundValue struct + Body []*KeyValuePair + func (*CompoundValue) Descriptor() ([]byte, []int) + func (*CompoundValue) ProtoMessage() + func (m *CompoundValue) GetBody() []*KeyValuePair + func (m *CompoundValue) Reset() + func (m *CompoundValue) String() string + type DataObject struct + Data []byte + Key string + func (*DataObject) Descriptor() ([]byte, []int) + func (*DataObject) ProtoMessage() + func (m *DataObject) Reset() + func (m *DataObject) String() string + type DataRequest struct + Keys []string + func (*DataRequest) Descriptor() ([]byte, []int) + func (*DataRequest) ProtoMessage() + func (m *DataRequest) Reset() + func (m *DataRequest) String() string + type DataResult struct + Result isDataResult_Result + func (*DataResult) Descriptor() ([]byte, []int) + func (*DataResult) ProtoMessage() + func (*DataResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *DataResult) GetData() *DataObject + func (m *DataResult) GetEnd() *StreamEnd + func (m *DataResult) GetError() *StreamError + func (m *DataResult) GetResult() isDataResult_Result + func (m *DataResult) Reset() + func (m *DataResult) String() string + type DataResult_Data struct + Data *DataObject + type DataResult_End struct + End *StreamEnd + type DataResult_Error struct + Error *StreamError + type EnvelopeStatement struct + Body []*Statement + func (*EnvelopeStatement) Descriptor() ([]byte, []int) + func (*EnvelopeStatement) ProtoMessage() + func (m *EnvelopeStatement) GetBody() []*Statement + func (m *EnvelopeStatement) Reset() + func (m *EnvelopeStatement) String() string + type KeyValuePair struct + Key string + Value *SimpleValue + func (*KeyValuePair) Descriptor() ([]byte, []int) + func (*KeyValuePair) ProtoMessage() + func (m *KeyValuePair) GetValue() *SimpleValue + func (m *KeyValuePair) Reset() + func (m *KeyValuePair) String() string + type ListPeersRequest struct + func (*ListPeersRequest) Descriptor() ([]byte, []int) + func (*ListPeersRequest) ProtoMessage() + func (m *ListPeersRequest) Reset() + func (m *ListPeersRequest) String() string + type ListPeersResponse struct + Peers []string + func (*ListPeersResponse) Descriptor() ([]byte, []int) + func (*ListPeersResponse) ProtoMessage() + func (m *ListPeersResponse) Reset() + func (m *ListPeersResponse) String() string + type LookupPeerRequest struct + Id string + func (*LookupPeerRequest) Descriptor() ([]byte, []int) + func (*LookupPeerRequest) ProtoMessage() + func (m *LookupPeerRequest) Reset() + func (m *LookupPeerRequest) String() string + type LookupPeerResponse struct + Peer *PeerInfo + func (*LookupPeerResponse) Descriptor() ([]byte, []int) + func (*LookupPeerResponse) ProtoMessage() + func (m *LookupPeerResponse) GetPeer() *PeerInfo + func (m *LookupPeerResponse) Reset() + func (m *LookupPeerResponse) String() string + type NodeInfo struct + Info string + Peer string + Publisher string + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (m *NodeInfo) Reset() + func (m *NodeInfo) String() string + type NodeInfoRequest struct + func (*NodeInfoRequest) Descriptor() ([]byte, []int) + func (*NodeInfoRequest) ProtoMessage() + func (m *NodeInfoRequest) Reset() + func (m *NodeInfoRequest) String() string + type PeerInfo struct + Addr [][]byte + Id string + func (*PeerInfo) Descriptor() ([]byte, []int) + func (*PeerInfo) ProtoMessage() + func (m *PeerInfo) Reset() + func (m *PeerInfo) String() string + type Ping struct + func (*Ping) Descriptor() ([]byte, []int) + func (*Ping) ProtoMessage() + func (m *Ping) Reset() + func (m *Ping) String() string + type Pong struct + func (*Pong) Descriptor() ([]byte, []int) + func (*Pong) ProtoMessage() + func (m *Pong) Reset() + func (m *Pong) String() string + type PushAccept struct + func (*PushAccept) Descriptor() ([]byte, []int) + func (*PushAccept) ProtoMessage() + func (m *PushAccept) Reset() + func (m *PushAccept) String() string + type PushEnd struct + Error string + Objects int64 + Statements int64 + func (*PushEnd) Descriptor() ([]byte, []int) + func (*PushEnd) ProtoMessage() + func (m *PushEnd) Reset() + func (m *PushEnd) String() string + type PushReject struct + Error string + func (*PushReject) Descriptor() ([]byte, []int) + func (*PushReject) ProtoMessage() + func (m *PushReject) Reset() + func (m *PushReject) String() string + type PushRequest struct + Namespaces []string + func (*PushRequest) Descriptor() ([]byte, []int) + func (*PushRequest) ProtoMessage() + func (m *PushRequest) Reset() + func (m *PushRequest) String() string + type PushResponse struct + Body isPushResponse_Body + func (*PushResponse) Descriptor() ([]byte, []int) + func (*PushResponse) ProtoMessage() + func (*PushResponse) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *PushResponse) GetAccept() *PushAccept + func (m *PushResponse) GetBody() isPushResponse_Body + func (m *PushResponse) GetReject() *PushReject + func (m *PushResponse) Reset() + func (m *PushResponse) String() string + type PushResponse_Accept struct + Accept *PushAccept + type PushResponse_Reject struct + Reject *PushReject + type PushValue struct + Value isPushValue_Value + func (*PushValue) Descriptor() ([]byte, []int) + func (*PushValue) ProtoMessage() + func (*PushValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *PushValue) GetEnd() *StreamEnd + func (m *PushValue) GetStmt() *Statement + func (m *PushValue) GetValue() isPushValue_Value + func (m *PushValue) Reset() + func (m *PushValue) String() string + type PushValue_End struct + End *StreamEnd + type PushValue_Stmt struct + Stmt *Statement + type QueryRequest struct + Query string + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (m *QueryRequest) Reset() + func (m *QueryRequest) String() string + type QueryResult struct + Result isQueryResult_Result + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (*QueryResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *QueryResult) GetEnd() *StreamEnd + func (m *QueryResult) GetError() *StreamError + func (m *QueryResult) GetResult() isQueryResult_Result + func (m *QueryResult) GetValue() *QueryResultValue + func (m *QueryResult) Reset() + func (m *QueryResult) String() string + type QueryResultValue struct + Value isQueryResultValue_Value + func (*QueryResultValue) Descriptor() ([]byte, []int) + func (*QueryResultValue) ProtoMessage() + func (*QueryResultValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *QueryResultValue) GetCompound() *CompoundValue + func (m *QueryResultValue) GetSimple() *SimpleValue + func (m *QueryResultValue) GetValue() isQueryResultValue_Value + func (m *QueryResultValue) Reset() + func (m *QueryResultValue) String() string + type QueryResultValue_Compound struct + Compound *CompoundValue + type QueryResultValue_Simple struct + Simple *SimpleValue + type QueryResult_End struct + End *StreamEnd + type QueryResult_Error struct + Error *StreamError + type QueryResult_Value struct + Value *QueryResultValue + type RegisterPeer struct + Info *PeerInfo + func (*RegisterPeer) Descriptor() ([]byte, []int) + func (*RegisterPeer) ProtoMessage() + func (m *RegisterPeer) GetInfo() *PeerInfo + func (m *RegisterPeer) Reset() + func (m *RegisterPeer) String() string + type SimpleStatement struct + Deps []string + Object string + Refs []string + Tags []string + func (*SimpleStatement) Descriptor() ([]byte, []int) + func (*SimpleStatement) ProtoMessage() + func (m *SimpleStatement) Reset() + func (m *SimpleStatement) String() string + type SimpleValue struct + Value isSimpleValue_Value + func (*SimpleValue) Descriptor() ([]byte, []int) + func (*SimpleValue) ProtoMessage() + func (*SimpleValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *SimpleValue) GetIntValue() int64 + func (m *SimpleValue) GetStmt() *Statement + func (m *SimpleValue) GetStmtBody() *StatementBody + func (m *SimpleValue) GetStringValue() string + func (m *SimpleValue) GetValue() isSimpleValue_Value + func (m *SimpleValue) Reset() + func (m *SimpleValue) String() string + type SimpleValue_IntValue struct + IntValue int64 + type SimpleValue_Stmt struct + Stmt *Statement + type SimpleValue_StmtBody struct + StmtBody *StatementBody + type SimpleValue_StringValue struct + StringValue string + type Statement struct + Body *StatementBody + Id string + Namespace string + Publisher string + Signature []byte + Timestamp int64 + func (*Statement) Descriptor() ([]byte, []int) + func (*Statement) ProtoMessage() + func (m *Statement) GetBody() *StatementBody + func (m *Statement) Reset() + func (m *Statement) String() string + type StatementBody struct + Body isStatementBody_Body + func (*StatementBody) Descriptor() ([]byte, []int) + func (*StatementBody) ProtoMessage() + func (*StatementBody) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...) + func (m *StatementBody) GetArchive() *ArchiveStatement + func (m *StatementBody) GetBody() isStatementBody_Body + func (m *StatementBody) GetCompound() *CompoundStatement + func (m *StatementBody) GetEnvelope() *EnvelopeStatement + func (m *StatementBody) GetSimple() *SimpleStatement + func (m *StatementBody) Reset() + func (m *StatementBody) String() string + type StatementBody_Archive struct + Archive *ArchiveStatement + type StatementBody_Compound struct + Compound *CompoundStatement + type StatementBody_Envelope struct + Envelope *EnvelopeStatement + type StatementBody_Simple struct + Simple *SimpleStatement + type StreamEnd struct + func (*StreamEnd) Descriptor() ([]byte, []int) + func (*StreamEnd) ProtoMessage() + func (m *StreamEnd) Reset() + func (m *StreamEnd) String() string + type StreamError struct + Error string + func (*StreamError) Descriptor() ([]byte, []int) + func (*StreamError) ProtoMessage() + func (m *StreamError) Reset() + func (m *StreamError) String() string
Go to main page