Documentation
¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
dir.proto node.proto stmt.proto
It has these top-level messages:
PeerInfo RegisterPeer LookupPeerRequest LookupPeerResponse ListPeersRequest ListPeersResponse StreamEnd StreamError NodeInfoRequest NodeInfo Ping Pong QueryRequest QueryResult QueryResultValue SimpleValue CompoundValue KeyValuePair DataRequest DataResult DataObject PushRequest PushResponse PushAccept PushReject PushValue PushEnd Statement StatementBody SimpleStatement CompoundStatement EnvelopeStatement ArchiveStatement
Index ¶
- type ArchiveStatement
- type CompoundStatement
- type CompoundValue
- type DataObject
- type DataRequest
- type DataResult
- func (*DataResult) Descriptor() ([]byte, []int)
- func (m *DataResult) GetData() *DataObject
- func (m *DataResult) GetEnd() *StreamEnd
- func (m *DataResult) GetError() *StreamError
- func (m *DataResult) GetResult() isDataResult_Result
- func (*DataResult) ProtoMessage()
- func (m *DataResult) Reset()
- func (m *DataResult) String() string
- func (*DataResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type DataResult_Data
- type DataResult_End
- type DataResult_Error
- type EnvelopeStatement
- type KeyValuePair
- type ListPeersRequest
- type ListPeersResponse
- type LookupPeerRequest
- type LookupPeerResponse
- type NodeInfo
- type NodeInfoRequest
- type PeerInfo
- type Ping
- type Pong
- type PushAccept
- type PushEnd
- type PushReject
- type PushRequest
- type PushResponse
- func (*PushResponse) Descriptor() ([]byte, []int)
- func (m *PushResponse) GetAccept() *PushAccept
- func (m *PushResponse) GetBody() isPushResponse_Body
- func (m *PushResponse) GetReject() *PushReject
- func (*PushResponse) ProtoMessage()
- func (m *PushResponse) Reset()
- func (m *PushResponse) String() string
- func (*PushResponse) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type PushResponse_Accept
- type PushResponse_Reject
- type PushValue
- func (*PushValue) Descriptor() ([]byte, []int)
- func (m *PushValue) GetEnd() *StreamEnd
- func (m *PushValue) GetStmt() *Statement
- func (m *PushValue) GetValue() isPushValue_Value
- func (*PushValue) ProtoMessage()
- func (m *PushValue) Reset()
- func (m *PushValue) String() string
- func (*PushValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type PushValue_End
- type PushValue_Stmt
- type QueryRequest
- type QueryResult
- func (*QueryResult) Descriptor() ([]byte, []int)
- func (m *QueryResult) GetEnd() *StreamEnd
- func (m *QueryResult) GetError() *StreamError
- func (m *QueryResult) GetResult() isQueryResult_Result
- func (m *QueryResult) GetValue() *QueryResultValue
- func (*QueryResult) ProtoMessage()
- func (m *QueryResult) Reset()
- func (m *QueryResult) String() string
- func (*QueryResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type QueryResultValue
- func (*QueryResultValue) Descriptor() ([]byte, []int)
- func (m *QueryResultValue) GetCompound() *CompoundValue
- func (m *QueryResultValue) GetSimple() *SimpleValue
- func (m *QueryResultValue) GetValue() isQueryResultValue_Value
- func (*QueryResultValue) ProtoMessage()
- func (m *QueryResultValue) Reset()
- func (m *QueryResultValue) String() string
- func (*QueryResultValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type QueryResultValue_Compound
- type QueryResultValue_Simple
- type QueryResult_End
- type QueryResult_Error
- type QueryResult_Value
- type RegisterPeer
- type SimpleStatement
- type SimpleValue
- func (*SimpleValue) Descriptor() ([]byte, []int)
- 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 (*SimpleValue) ProtoMessage()
- func (m *SimpleValue) Reset()
- func (m *SimpleValue) String() string
- func (*SimpleValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type SimpleValue_IntValue
- type SimpleValue_Stmt
- type SimpleValue_StmtBody
- type SimpleValue_StringValue
- type Statement
- type StatementBody
- func (*StatementBody) Descriptor() ([]byte, []int)
- 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 (*StatementBody) ProtoMessage()
- func (m *StatementBody) Reset()
- func (m *StatementBody) String() string
- func (*StatementBody) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, ...)
- type StatementBody_Archive
- type StatementBody_Compound
- type StatementBody_Envelope
- type StatementBody_Simple
- type StreamEnd
- type StreamError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchiveStatement ¶
type ArchiveStatement struct { }
func (*ArchiveStatement) Descriptor ¶
func (*ArchiveStatement) Descriptor() ([]byte, []int)
func (*ArchiveStatement) ProtoMessage ¶
func (*ArchiveStatement) ProtoMessage()
func (*ArchiveStatement) Reset ¶
func (m *ArchiveStatement) Reset()
func (*ArchiveStatement) String ¶
func (m *ArchiveStatement) String() string
type CompoundStatement ¶
type CompoundStatement struct {
Body []*SimpleStatement `protobuf:"bytes,1,rep,name=body" json:"body,omitempty"`
}
func (*CompoundStatement) Descriptor ¶
func (*CompoundStatement) Descriptor() ([]byte, []int)
func (*CompoundStatement) GetBody ¶
func (m *CompoundStatement) GetBody() []*SimpleStatement
func (*CompoundStatement) ProtoMessage ¶
func (*CompoundStatement) ProtoMessage()
func (*CompoundStatement) Reset ¶
func (m *CompoundStatement) Reset()
func (*CompoundStatement) String ¶
func (m *CompoundStatement) String() string
type CompoundValue ¶
type CompoundValue struct {
Body []*KeyValuePair `protobuf:"bytes,1,rep,name=body" json:"body,omitempty"`
}
func (*CompoundValue) Descriptor ¶
func (*CompoundValue) Descriptor() ([]byte, []int)
func (*CompoundValue) GetBody ¶
func (m *CompoundValue) GetBody() []*KeyValuePair
func (*CompoundValue) ProtoMessage ¶
func (*CompoundValue) ProtoMessage()
func (*CompoundValue) Reset ¶
func (m *CompoundValue) Reset()
func (*CompoundValue) String ¶
func (m *CompoundValue) String() string
type DataObject ¶
type DataObject struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
func (*DataObject) Descriptor ¶
func (*DataObject) Descriptor() ([]byte, []int)
func (*DataObject) ProtoMessage ¶
func (*DataObject) ProtoMessage()
func (*DataObject) Reset ¶
func (m *DataObject) Reset()
func (*DataObject) String ¶
func (m *DataObject) String() string
type DataRequest ¶
type DataRequest struct {
Keys []string `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}
/mediachain/node/data
func (*DataRequest) Descriptor ¶
func (*DataRequest) Descriptor() ([]byte, []int)
func (*DataRequest) ProtoMessage ¶
func (*DataRequest) ProtoMessage()
func (*DataRequest) Reset ¶
func (m *DataRequest) Reset()
func (*DataRequest) String ¶
func (m *DataRequest) String() string
type DataResult ¶
type DataResult struct { // Types that are valid to be assigned to Result: // *DataResult_Data // *DataResult_End // *DataResult_Error Result isDataResult_Result `protobuf_oneof:"result"` }
func (*DataResult) Descriptor ¶
func (*DataResult) Descriptor() ([]byte, []int)
func (*DataResult) GetData ¶
func (m *DataResult) GetData() *DataObject
func (*DataResult) GetEnd ¶
func (m *DataResult) GetEnd() *StreamEnd
func (*DataResult) GetError ¶
func (m *DataResult) GetError() *StreamError
func (*DataResult) GetResult ¶
func (m *DataResult) GetResult() isDataResult_Result
func (*DataResult) ProtoMessage ¶
func (*DataResult) ProtoMessage()
func (*DataResult) Reset ¶
func (m *DataResult) Reset()
func (*DataResult) String ¶
func (m *DataResult) String() string
func (*DataResult) XXX_OneofFuncs ¶
func (*DataResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type DataResult_Data ¶
type DataResult_Data struct {
Data *DataObject `protobuf:"bytes,1,opt,name=data,oneof"`
}
type DataResult_End ¶
type DataResult_End struct {
End *StreamEnd `protobuf:"bytes,2,opt,name=end,oneof"`
}
type DataResult_Error ¶
type DataResult_Error struct {
Error *StreamError `protobuf:"bytes,3,opt,name=error,oneof"`
}
type EnvelopeStatement ¶
type EnvelopeStatement struct {
Body []*Statement `protobuf:"bytes,1,rep,name=body" json:"body,omitempty"`
}
func (*EnvelopeStatement) Descriptor ¶
func (*EnvelopeStatement) Descriptor() ([]byte, []int)
func (*EnvelopeStatement) GetBody ¶
func (m *EnvelopeStatement) GetBody() []*Statement
func (*EnvelopeStatement) ProtoMessage ¶
func (*EnvelopeStatement) ProtoMessage()
func (*EnvelopeStatement) Reset ¶
func (m *EnvelopeStatement) Reset()
func (*EnvelopeStatement) String ¶
func (m *EnvelopeStatement) String() string
type KeyValuePair ¶
type KeyValuePair struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *SimpleValue `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` }
func (*KeyValuePair) Descriptor ¶
func (*KeyValuePair) Descriptor() ([]byte, []int)
func (*KeyValuePair) GetValue ¶
func (m *KeyValuePair) GetValue() *SimpleValue
func (*KeyValuePair) ProtoMessage ¶
func (*KeyValuePair) ProtoMessage()
func (*KeyValuePair) Reset ¶
func (m *KeyValuePair) Reset()
func (*KeyValuePair) String ¶
func (m *KeyValuePair) String() string
type ListPeersRequest ¶
type ListPeersRequest struct { }
/mediachain/dir/list
func (*ListPeersRequest) Descriptor ¶
func (*ListPeersRequest) Descriptor() ([]byte, []int)
func (*ListPeersRequest) ProtoMessage ¶
func (*ListPeersRequest) ProtoMessage()
func (*ListPeersRequest) Reset ¶
func (m *ListPeersRequest) Reset()
func (*ListPeersRequest) String ¶
func (m *ListPeersRequest) String() string
type ListPeersResponse ¶
type ListPeersResponse struct {
Peers []string `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
}
func (*ListPeersResponse) Descriptor ¶
func (*ListPeersResponse) Descriptor() ([]byte, []int)
func (*ListPeersResponse) ProtoMessage ¶
func (*ListPeersResponse) ProtoMessage()
func (*ListPeersResponse) Reset ¶
func (m *ListPeersResponse) Reset()
func (*ListPeersResponse) String ¶
func (m *ListPeersResponse) String() string
type LookupPeerRequest ¶
type LookupPeerRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
/mediachain/dir/lookup
func (*LookupPeerRequest) Descriptor ¶
func (*LookupPeerRequest) Descriptor() ([]byte, []int)
func (*LookupPeerRequest) ProtoMessage ¶
func (*LookupPeerRequest) ProtoMessage()
func (*LookupPeerRequest) Reset ¶
func (m *LookupPeerRequest) Reset()
func (*LookupPeerRequest) String ¶
func (m *LookupPeerRequest) String() string
type LookupPeerResponse ¶
type LookupPeerResponse struct {
Peer *PeerInfo `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}
func (*LookupPeerResponse) Descriptor ¶
func (*LookupPeerResponse) Descriptor() ([]byte, []int)
func (*LookupPeerResponse) GetPeer ¶
func (m *LookupPeerResponse) GetPeer() *PeerInfo
func (*LookupPeerResponse) ProtoMessage ¶
func (*LookupPeerResponse) ProtoMessage()
func (*LookupPeerResponse) Reset ¶
func (m *LookupPeerResponse) Reset()
func (*LookupPeerResponse) String ¶
func (m *LookupPeerResponse) String() string
type NodeInfo ¶
type NodeInfo struct { Peer string `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` Publisher string `protobuf:"bytes,2,opt,name=publisher,proto3" json:"publisher,omitempty"` Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` }
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
type NodeInfoRequest ¶
type NodeInfoRequest struct { }
/mediachain/node/id
func (*NodeInfoRequest) Descriptor ¶
func (*NodeInfoRequest) Descriptor() ([]byte, []int)
func (*NodeInfoRequest) ProtoMessage ¶
func (*NodeInfoRequest) ProtoMessage()
func (*NodeInfoRequest) Reset ¶
func (m *NodeInfoRequest) Reset()
func (*NodeInfoRequest) String ¶
func (m *NodeInfoRequest) String() string
type PeerInfo ¶
type PeerInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Addr [][]byte `protobuf:"bytes,2,rep,name=addr" json:"addr,omitempty"` }
func (*PeerInfo) Descriptor ¶
func (*PeerInfo) ProtoMessage ¶
func (*PeerInfo) ProtoMessage()
type Ping ¶
type Ping struct { }
/mediachain/node/ping
func (*Ping) Descriptor ¶
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
type Pong ¶
type Pong struct { }
func (*Pong) Descriptor ¶
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
type PushAccept ¶
type PushAccept struct { }
func (*PushAccept) Descriptor ¶
func (*PushAccept) Descriptor() ([]byte, []int)
func (*PushAccept) ProtoMessage ¶
func (*PushAccept) ProtoMessage()
func (*PushAccept) Reset ¶
func (m *PushAccept) Reset()
func (*PushAccept) String ¶
func (m *PushAccept) String() string
type PushEnd ¶
type PushEnd struct { Statements int64 `protobuf:"varint,1,opt,name=statements,proto3" json:"statements,omitempty"` Objects int64 `protobuf:"varint,2,opt,name=objects,proto3" json:"objects,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` }
func (*PushEnd) Descriptor ¶
func (*PushEnd) ProtoMessage ¶
func (*PushEnd) ProtoMessage()
type PushReject ¶
type PushReject struct {
Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}
func (*PushReject) Descriptor ¶
func (*PushReject) Descriptor() ([]byte, []int)
func (*PushReject) ProtoMessage ¶
func (*PushReject) ProtoMessage()
func (*PushReject) Reset ¶
func (m *PushReject) Reset()
func (*PushReject) String ¶
func (m *PushReject) String() string
type PushRequest ¶
type PushRequest struct {
Namespaces []string `protobuf:"bytes,1,rep,name=namespaces" json:"namespaces,omitempty"`
}
/mediachain/node/push
func (*PushRequest) Descriptor ¶
func (*PushRequest) Descriptor() ([]byte, []int)
func (*PushRequest) ProtoMessage ¶
func (*PushRequest) ProtoMessage()
func (*PushRequest) Reset ¶
func (m *PushRequest) Reset()
func (*PushRequest) String ¶
func (m *PushRequest) String() string
type PushResponse ¶
type PushResponse struct { // Types that are valid to be assigned to Body: // *PushResponse_Accept // *PushResponse_Reject Body isPushResponse_Body `protobuf_oneof:"body"` }
func (*PushResponse) Descriptor ¶
func (*PushResponse) Descriptor() ([]byte, []int)
func (*PushResponse) GetAccept ¶
func (m *PushResponse) GetAccept() *PushAccept
func (*PushResponse) GetBody ¶
func (m *PushResponse) GetBody() isPushResponse_Body
func (*PushResponse) GetReject ¶
func (m *PushResponse) GetReject() *PushReject
func (*PushResponse) ProtoMessage ¶
func (*PushResponse) ProtoMessage()
func (*PushResponse) Reset ¶
func (m *PushResponse) Reset()
func (*PushResponse) String ¶
func (m *PushResponse) String() string
func (*PushResponse) XXX_OneofFuncs ¶
func (*PushResponse) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type PushResponse_Accept ¶
type PushResponse_Accept struct {
Accept *PushAccept `protobuf:"bytes,1,opt,name=accept,oneof"`
}
type PushResponse_Reject ¶
type PushResponse_Reject struct {
Reject *PushReject `protobuf:"bytes,2,opt,name=reject,oneof"`
}
type PushValue ¶
type PushValue struct { // Types that are valid to be assigned to Value: // *PushValue_Stmt // *PushValue_End Value isPushValue_Value `protobuf_oneof:"value"` }
func (*PushValue) Descriptor ¶
func (*PushValue) ProtoMessage ¶
func (*PushValue) ProtoMessage()
func (*PushValue) XXX_OneofFuncs ¶
func (*PushValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type PushValue_End ¶
type PushValue_End struct {
End *StreamEnd `protobuf:"bytes,2,opt,name=end,oneof"`
}
type PushValue_Stmt ¶
type PushValue_Stmt struct {
Stmt *Statement `protobuf:"bytes,1,opt,name=stmt,oneof"`
}
type QueryRequest ¶
type QueryRequest struct {
Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
}
/mediachain/node/query
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
type QueryResult ¶
type QueryResult struct { // Types that are valid to be assigned to Result: // *QueryResult_Value // *QueryResult_End // *QueryResult_Error Result isQueryResult_Result `protobuf_oneof:"result"` }
func (*QueryResult) Descriptor ¶
func (*QueryResult) Descriptor() ([]byte, []int)
func (*QueryResult) GetEnd ¶
func (m *QueryResult) GetEnd() *StreamEnd
func (*QueryResult) GetError ¶
func (m *QueryResult) GetError() *StreamError
func (*QueryResult) GetResult ¶
func (m *QueryResult) GetResult() isQueryResult_Result
func (*QueryResult) GetValue ¶
func (m *QueryResult) GetValue() *QueryResultValue
func (*QueryResult) ProtoMessage ¶
func (*QueryResult) ProtoMessage()
func (*QueryResult) Reset ¶
func (m *QueryResult) Reset()
func (*QueryResult) String ¶
func (m *QueryResult) String() string
func (*QueryResult) XXX_OneofFuncs ¶
func (*QueryResult) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type QueryResultValue ¶
type QueryResultValue struct { // Types that are valid to be assigned to Value: // *QueryResultValue_Simple // *QueryResultValue_Compound Value isQueryResultValue_Value `protobuf_oneof:"value"` }
func (*QueryResultValue) Descriptor ¶
func (*QueryResultValue) Descriptor() ([]byte, []int)
func (*QueryResultValue) GetCompound ¶
func (m *QueryResultValue) GetCompound() *CompoundValue
func (*QueryResultValue) GetSimple ¶
func (m *QueryResultValue) GetSimple() *SimpleValue
func (*QueryResultValue) GetValue ¶
func (m *QueryResultValue) GetValue() isQueryResultValue_Value
func (*QueryResultValue) ProtoMessage ¶
func (*QueryResultValue) ProtoMessage()
func (*QueryResultValue) Reset ¶
func (m *QueryResultValue) Reset()
func (*QueryResultValue) String ¶
func (m *QueryResultValue) String() string
func (*QueryResultValue) XXX_OneofFuncs ¶
func (*QueryResultValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type QueryResultValue_Compound ¶
type QueryResultValue_Compound struct {
Compound *CompoundValue `protobuf:"bytes,2,opt,name=compound,oneof"`
}
type QueryResultValue_Simple ¶
type QueryResultValue_Simple struct {
Simple *SimpleValue `protobuf:"bytes,1,opt,name=simple,oneof"`
}
type QueryResult_End ¶
type QueryResult_End struct {
End *StreamEnd `protobuf:"bytes,2,opt,name=end,oneof"`
}
type QueryResult_Error ¶
type QueryResult_Error struct {
Error *StreamError `protobuf:"bytes,3,opt,name=error,oneof"`
}
type QueryResult_Value ¶
type QueryResult_Value struct {
Value *QueryResultValue `protobuf:"bytes,1,opt,name=value,oneof"`
}
type RegisterPeer ¶
type RegisterPeer struct {
Info *PeerInfo `protobuf:"bytes,1,opt,name=info" json:"info,omitempty"`
}
/mediachain/dir/register
func (*RegisterPeer) Descriptor ¶
func (*RegisterPeer) Descriptor() ([]byte, []int)
func (*RegisterPeer) GetInfo ¶
func (m *RegisterPeer) GetInfo() *PeerInfo
func (*RegisterPeer) ProtoMessage ¶
func (*RegisterPeer) ProtoMessage()
func (*RegisterPeer) Reset ¶
func (m *RegisterPeer) Reset()
func (*RegisterPeer) String ¶
func (m *RegisterPeer) String() string
type SimpleStatement ¶
type SimpleStatement struct { Object string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"` Refs []string `protobuf:"bytes,2,rep,name=refs" json:"refs,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"` Deps []string `protobuf:"bytes,4,rep,name=deps" json:"deps,omitempty"` }
func (*SimpleStatement) Descriptor ¶
func (*SimpleStatement) Descriptor() ([]byte, []int)
func (*SimpleStatement) ProtoMessage ¶
func (*SimpleStatement) ProtoMessage()
func (*SimpleStatement) Reset ¶
func (m *SimpleStatement) Reset()
func (*SimpleStatement) String ¶
func (m *SimpleStatement) String() string
type SimpleValue ¶
type SimpleValue struct { // Types that are valid to be assigned to Value: // *SimpleValue_IntValue // *SimpleValue_StringValue // *SimpleValue_Stmt // *SimpleValue_StmtBody Value isSimpleValue_Value `protobuf_oneof:"value"` }
func (*SimpleValue) Descriptor ¶
func (*SimpleValue) Descriptor() ([]byte, []int)
func (*SimpleValue) GetIntValue ¶
func (m *SimpleValue) GetIntValue() int64
func (*SimpleValue) GetStmt ¶
func (m *SimpleValue) GetStmt() *Statement
func (*SimpleValue) GetStmtBody ¶
func (m *SimpleValue) GetStmtBody() *StatementBody
func (*SimpleValue) GetStringValue ¶
func (m *SimpleValue) GetStringValue() string
func (*SimpleValue) GetValue ¶
func (m *SimpleValue) GetValue() isSimpleValue_Value
func (*SimpleValue) ProtoMessage ¶
func (*SimpleValue) ProtoMessage()
func (*SimpleValue) Reset ¶
func (m *SimpleValue) Reset()
func (*SimpleValue) String ¶
func (m *SimpleValue) String() string
func (*SimpleValue) XXX_OneofFuncs ¶
func (*SimpleValue) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type SimpleValue_IntValue ¶
type SimpleValue_IntValue struct {
IntValue int64 `protobuf:"varint,1,opt,name=intValue,proto3,oneof"`
}
type SimpleValue_Stmt ¶
type SimpleValue_Stmt struct {
Stmt *Statement `protobuf:"bytes,3,opt,name=stmt,oneof"`
}
type SimpleValue_StmtBody ¶
type SimpleValue_StmtBody struct {
StmtBody *StatementBody `protobuf:"bytes,4,opt,name=stmtBody,oneof"`
}
type SimpleValue_StringValue ¶
type SimpleValue_StringValue struct {
StringValue string `protobuf:"bytes,2,opt,name=stringValue,proto3,oneof"`
}
type Statement ¶
type Statement struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Publisher string `protobuf:"bytes,2,opt,name=publisher,proto3" json:"publisher,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` Body *StatementBody `protobuf:"bytes,4,opt,name=body" json:"body,omitempty"` Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Signature []byte `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"` }
func (*Statement) Descriptor ¶
func (*Statement) GetBody ¶
func (m *Statement) GetBody() *StatementBody
func (*Statement) ProtoMessage ¶
func (*Statement) ProtoMessage()
type StatementBody ¶
type StatementBody struct { // Types that are valid to be assigned to Body: // *StatementBody_Simple // *StatementBody_Compound // *StatementBody_Envelope // *StatementBody_Archive Body isStatementBody_Body `protobuf_oneof:"body"` }
func (*StatementBody) Descriptor ¶
func (*StatementBody) Descriptor() ([]byte, []int)
func (*StatementBody) GetArchive ¶
func (m *StatementBody) GetArchive() *ArchiveStatement
func (*StatementBody) GetBody ¶
func (m *StatementBody) GetBody() isStatementBody_Body
func (*StatementBody) GetCompound ¶
func (m *StatementBody) GetCompound() *CompoundStatement
func (*StatementBody) GetEnvelope ¶
func (m *StatementBody) GetEnvelope() *EnvelopeStatement
func (*StatementBody) GetSimple ¶
func (m *StatementBody) GetSimple() *SimpleStatement
func (*StatementBody) ProtoMessage ¶
func (*StatementBody) ProtoMessage()
func (*StatementBody) Reset ¶
func (m *StatementBody) Reset()
func (*StatementBody) String ¶
func (m *StatementBody) String() string
func (*StatementBody) XXX_OneofFuncs ¶
func (*StatementBody) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type StatementBody_Archive ¶
type StatementBody_Archive struct {
Archive *ArchiveStatement `protobuf:"bytes,4,opt,name=archive,oneof"`
}
type StatementBody_Compound ¶
type StatementBody_Compound struct {
Compound *CompoundStatement `protobuf:"bytes,2,opt,name=compound,oneof"`
}
type StatementBody_Envelope ¶
type StatementBody_Envelope struct {
Envelope *EnvelopeStatement `protobuf:"bytes,3,opt,name=envelope,oneof"`
}
type StatementBody_Simple ¶
type StatementBody_Simple struct {
Simple *SimpleStatement `protobuf:"bytes,1,opt,name=simple,oneof"`
}
type StreamEnd ¶
type StreamEnd struct { }
end of result stream marker
func (*StreamEnd) Descriptor ¶
func (*StreamEnd) ProtoMessage ¶
func (*StreamEnd) ProtoMessage()
type StreamError ¶
type StreamError struct {
Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}
stream errors
func (*StreamError) Descriptor ¶
func (*StreamError) Descriptor() ([]byte, []int)
func (*StreamError) ProtoMessage ¶
func (*StreamError) ProtoMessage()
func (*StreamError) Reset ¶
func (m *StreamError) Reset()
func (*StreamError) String ¶
func (m *StreamError) String() string