net_pb

package
v0.1.27 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLstore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLstore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLstore = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNet        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNet          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNet = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterServiceServer 

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type AddrBookRecord 

type AddrBookRecord struct {
	// Thread ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// The peer ID.
	PeerID *ProtoPeerID `protobuf:"bytes,2,opt,name=peerID,proto3,customtype=ProtoPeerID" json:"peerID,omitempty"`
	// The multiaddresses. This is a sorted list where element 0 expires the soonest.
	Addrs []*AddrBookRecord_AddrEntry `protobuf:"bytes,3,rep,name=addrs,proto3" json:"addrs,omitempty"`
}

AddrBookRecord represents a record for a log in the address book.

func NewPopulatedAddrBookRecord 

func NewPopulatedAddrBookRecord(r randyLstore, easy bool) *AddrBookRecord

func (*AddrBookRecord) Descriptor 

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

func (*AddrBookRecord) GetAddrs 

func (m *AddrBookRecord) GetAddrs() []*AddrBookRecord_AddrEntry

func (*AddrBookRecord) Marshal 

func (m *AddrBookRecord) Marshal() (dAtA []byte, err error)

func (*AddrBookRecord) MarshalTo 

func (m *AddrBookRecord) MarshalTo(dAtA []byte) (int, error)

func (*AddrBookRecord) MarshalToSizedBuffer 

func (m *AddrBookRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddrBookRecord) ProtoMessage 

func (*AddrBookRecord) ProtoMessage()

func (*AddrBookRecord) Reset 

func (m *AddrBookRecord) Reset()

func (*AddrBookRecord) Size 

func (m *AddrBookRecord) Size() (n int)

func (*AddrBookRecord) String 

func (m *AddrBookRecord) String() string

func (*AddrBookRecord) Unmarshal 

func (m *AddrBookRecord) Unmarshal(dAtA []byte) error

func (*AddrBookRecord) XXX_DiscardUnknown 

func (m *AddrBookRecord) XXX_DiscardUnknown()

func (*AddrBookRecord) XXX_Marshal 

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

func (*AddrBookRecord) XXX_Merge 

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

func (*AddrBookRecord) XXX_Size 

func (m *AddrBookRecord) XXX_Size() int

func (*AddrBookRecord) XXX_Unmarshal 

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

type AddrBookRecord_AddrEntry 

type AddrBookRecord_AddrEntry struct {
	Addr *ProtoAddr `protobuf:"bytes,1,opt,name=addr,proto3,customtype=ProtoAddr" json:"addr,omitempty"`
	// The point in time when this address expires.
	Expiry int64 `protobuf:"varint,2,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// The original TTL of this address.
	Ttl int64 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
}

AddrEntry represents a single multiaddress.

func NewPopulatedAddrBookRecord_AddrEntry 

func NewPopulatedAddrBookRecord_AddrEntry(r randyLstore, easy bool) *AddrBookRecord_AddrEntry

func (*AddrBookRecord_AddrEntry) Descriptor 

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

func (*AddrBookRecord_AddrEntry) GetExpiry 

func (m *AddrBookRecord_AddrEntry) GetExpiry() int64

func (*AddrBookRecord_AddrEntry) GetTtl 

func (m *AddrBookRecord_AddrEntry) GetTtl() int64

func (*AddrBookRecord_AddrEntry) Marshal 

func (m *AddrBookRecord_AddrEntry) Marshal() (dAtA []byte, err error)

func (*AddrBookRecord_AddrEntry) MarshalTo 

func (m *AddrBookRecord_AddrEntry) MarshalTo(dAtA []byte) (int, error)

func (*AddrBookRecord_AddrEntry) MarshalToSizedBuffer 

func (m *AddrBookRecord_AddrEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddrBookRecord_AddrEntry) ProtoMessage 

func (*AddrBookRecord_AddrEntry) ProtoMessage()

func (*AddrBookRecord_AddrEntry) Reset 

func (m *AddrBookRecord_AddrEntry) Reset()

func (*AddrBookRecord_AddrEntry) Size 

func (m *AddrBookRecord_AddrEntry) Size() (n int)

func (*AddrBookRecord_AddrEntry) String 

func (m *AddrBookRecord_AddrEntry) String() string

func (*AddrBookRecord_AddrEntry) Unmarshal 

func (m *AddrBookRecord_AddrEntry) Unmarshal(dAtA []byte) error

func (*AddrBookRecord_AddrEntry) XXX_DiscardUnknown 

func (m *AddrBookRecord_AddrEntry) XXX_DiscardUnknown()

func (*AddrBookRecord_AddrEntry) XXX_Marshal 

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

func (*AddrBookRecord_AddrEntry) XXX_Merge 

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

func (*AddrBookRecord_AddrEntry) XXX_Size 

func (m *AddrBookRecord_AddrEntry) XXX_Size() int

func (*AddrBookRecord_AddrEntry) XXX_Unmarshal 

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

type ExchangeEdgesReply 

type ExchangeEdgesReply struct {
	// edges contains edge information about requested threads.
	Edges []*ExchangeEdgesReply_ThreadEdges `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
}

ExchangeEdgesReply contains edges requested with an ExchangeEdgesRequest.

func NewPopulatedExchangeEdgesReply 

func NewPopulatedExchangeEdgesReply(r randyNet, easy bool) *ExchangeEdgesReply

func (*ExchangeEdgesReply) Descriptor 

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

func (*ExchangeEdgesReply) GetEdges 

func (m *ExchangeEdgesReply) GetEdges() []*ExchangeEdgesReply_ThreadEdges

func (*ExchangeEdgesReply) Marshal 

func (m *ExchangeEdgesReply) Marshal() (dAtA []byte, err error)

func (*ExchangeEdgesReply) MarshalTo 

func (m *ExchangeEdgesReply) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeEdgesReply) MarshalToSizedBuffer 

func (m *ExchangeEdgesReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangeEdgesReply) ProtoMessage 

func (*ExchangeEdgesReply) ProtoMessage()

func (*ExchangeEdgesReply) Reset 

func (m *ExchangeEdgesReply) Reset()

func (*ExchangeEdgesReply) Size 

func (m *ExchangeEdgesReply) Size() (n int)

func (*ExchangeEdgesReply) String 

func (m *ExchangeEdgesReply) String() string

func (*ExchangeEdgesReply) Unmarshal 

func (m *ExchangeEdgesReply) Unmarshal(dAtA []byte) error

func (*ExchangeEdgesReply) XXX_DiscardUnknown 

func (m *ExchangeEdgesReply) XXX_DiscardUnknown()

func (*ExchangeEdgesReply) XXX_Marshal 

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

func (*ExchangeEdgesReply) XXX_Merge 

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

func (*ExchangeEdgesReply) XXX_Size 

func (m *ExchangeEdgesReply) XXX_Size() int

func (*ExchangeEdgesReply) XXX_Unmarshal 

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

type ExchangeEdgesReply_ThreadEdges 

type ExchangeEdgesReply_ThreadEdges struct {
	// threadID is the requested thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// deprecated, use default values for addressEdge and headsEdge
	Exists bool `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// addressEdge is the current hash of peers addresses stored on a respondent.
	AddressEdge uint64 `protobuf:"varint,3,opt,name=addressEdge,proto3" json:"addressEdge,omitempty"`
	// headsEdge is the current hash of the log's heads stored on a respondent.
	HeadsEdge uint64 `protobuf:"varint,4,opt,name=headsEdge,proto3" json:"headsEdge,omitempty"`
}

func NewPopulatedExchangeEdgesReply_ThreadEdges 

func NewPopulatedExchangeEdgesReply_ThreadEdges(r randyNet, easy bool) *ExchangeEdgesReply_ThreadEdges

func (*ExchangeEdgesReply_ThreadEdges) Descriptor 

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

func (*ExchangeEdgesReply_ThreadEdges) GetAddressEdge 

func (m *ExchangeEdgesReply_ThreadEdges) GetAddressEdge() uint64

func (*ExchangeEdgesReply_ThreadEdges) GetExists 

func (m *ExchangeEdgesReply_ThreadEdges) GetExists() bool

func (*ExchangeEdgesReply_ThreadEdges) GetHeadsEdge 

func (m *ExchangeEdgesReply_ThreadEdges) GetHeadsEdge() uint64

func (*ExchangeEdgesReply_ThreadEdges) Marshal 

func (m *ExchangeEdgesReply_ThreadEdges) Marshal() (dAtA []byte, err error)

func (*ExchangeEdgesReply_ThreadEdges) MarshalTo 

func (m *ExchangeEdgesReply_ThreadEdges) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeEdgesReply_ThreadEdges) MarshalToSizedBuffer 

func (m *ExchangeEdgesReply_ThreadEdges) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangeEdgesReply_ThreadEdges) ProtoMessage 

func (*ExchangeEdgesReply_ThreadEdges) ProtoMessage()

func (*ExchangeEdgesReply_ThreadEdges) Reset 

func (m *ExchangeEdgesReply_ThreadEdges) Reset()

func (*ExchangeEdgesReply_ThreadEdges) Size 

func (m *ExchangeEdgesReply_ThreadEdges) Size() (n int)

func (*ExchangeEdgesReply_ThreadEdges) String 

func (m *ExchangeEdgesReply_ThreadEdges) String() string

func (*ExchangeEdgesReply_ThreadEdges) Unmarshal 

func (m *ExchangeEdgesReply_ThreadEdges) Unmarshal(dAtA []byte) error

func (*ExchangeEdgesReply_ThreadEdges) XXX_DiscardUnknown 

func (m *ExchangeEdgesReply_ThreadEdges) XXX_DiscardUnknown()

func (*ExchangeEdgesReply_ThreadEdges) XXX_Marshal 

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

func (*ExchangeEdgesReply_ThreadEdges) XXX_Merge 

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

func (*ExchangeEdgesReply_ThreadEdges) XXX_Size 

func (m *ExchangeEdgesReply_ThreadEdges) XXX_Size() int

func (*ExchangeEdgesReply_ThreadEdges) XXX_Unmarshal 

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

type ExchangeEdgesRequest 

type ExchangeEdgesRequest struct {
	// body is the message body.
	Body *ExchangeEdgesRequest_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

ExchangeEdgesRequest is used to exchange address/heads edges with a peer.

func NewPopulatedExchangeEdgesRequest 

func NewPopulatedExchangeEdgesRequest(r randyNet, easy bool) *ExchangeEdgesRequest

func (*ExchangeEdgesRequest) Descriptor 

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

func (*ExchangeEdgesRequest) GetBody 

func (m *ExchangeEdgesRequest) GetBody() *ExchangeEdgesRequest_Body

func (*ExchangeEdgesRequest) Marshal 

func (m *ExchangeEdgesRequest) Marshal() (dAtA []byte, err error)

func (*ExchangeEdgesRequest) MarshalTo 

func (m *ExchangeEdgesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest) MarshalToSizedBuffer 

func (m *ExchangeEdgesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest) ProtoMessage 

func (*ExchangeEdgesRequest) ProtoMessage()

func (*ExchangeEdgesRequest) Reset 

func (m *ExchangeEdgesRequest) Reset()

func (*ExchangeEdgesRequest) Size 

func (m *ExchangeEdgesRequest) Size() (n int)

func (*ExchangeEdgesRequest) String 

func (m *ExchangeEdgesRequest) String() string

func (*ExchangeEdgesRequest) Unmarshal 

func (m *ExchangeEdgesRequest) Unmarshal(dAtA []byte) error

func (*ExchangeEdgesRequest) XXX_DiscardUnknown 

func (m *ExchangeEdgesRequest) XXX_DiscardUnknown()

func (*ExchangeEdgesRequest) XXX_Marshal 

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

func (*ExchangeEdgesRequest) XXX_Merge 

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

func (*ExchangeEdgesRequest) XXX_Size 

func (m *ExchangeEdgesRequest) XXX_Size() int

func (*ExchangeEdgesRequest) XXX_Unmarshal 

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

type ExchangeEdgesRequest_Body 

type ExchangeEdgesRequest_Body struct {
	// threads is a list of requested thread IDs with its local edges.
	Threads []*ExchangeEdgesRequest_Body_ThreadEntry `protobuf:"bytes,1,rep,name=threads,proto3" json:"threads,omitempty"`
}

func NewPopulatedExchangeEdgesRequest_Body 

func NewPopulatedExchangeEdgesRequest_Body(r randyNet, easy bool) *ExchangeEdgesRequest_Body

func (*ExchangeEdgesRequest_Body) Descriptor 

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

func (*ExchangeEdgesRequest_Body) GetThreads 

func (m *ExchangeEdgesRequest_Body) GetThreads() []*ExchangeEdgesRequest_Body_ThreadEntry

func (*ExchangeEdgesRequest_Body) Marshal 

func (m *ExchangeEdgesRequest_Body) Marshal() (dAtA []byte, err error)

func (*ExchangeEdgesRequest_Body) MarshalTo 

func (m *ExchangeEdgesRequest_Body) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest_Body) MarshalToSizedBuffer 

func (m *ExchangeEdgesRequest_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest_Body) ProtoMessage 

func (*ExchangeEdgesRequest_Body) ProtoMessage()

func (*ExchangeEdgesRequest_Body) Reset 

func (m *ExchangeEdgesRequest_Body) Reset()

func (*ExchangeEdgesRequest_Body) Size 

func (m *ExchangeEdgesRequest_Body) Size() (n int)

func (*ExchangeEdgesRequest_Body) String 

func (m *ExchangeEdgesRequest_Body) String() string

func (*ExchangeEdgesRequest_Body) Unmarshal 

func (m *ExchangeEdgesRequest_Body) Unmarshal(dAtA []byte) error

func (*ExchangeEdgesRequest_Body) XXX_DiscardUnknown 

func (m *ExchangeEdgesRequest_Body) XXX_DiscardUnknown()

func (*ExchangeEdgesRequest_Body) XXX_Marshal 

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

func (*ExchangeEdgesRequest_Body) XXX_Merge 

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

func (*ExchangeEdgesRequest_Body) XXX_Size 

func (m *ExchangeEdgesRequest_Body) XXX_Size() int

func (*ExchangeEdgesRequest_Body) XXX_Unmarshal 

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

type ExchangeEdgesRequest_Body_ThreadEntry 

type ExchangeEdgesRequest_Body_ThreadEntry struct {
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// addressEdge is the current hash of peers addresses stored on a requester.
	AddressEdge uint64 `protobuf:"varint,2,opt,name=addressEdge,proto3" json:"addressEdge,omitempty"`
	// headsEdge is the current hash of the log's heads stored on a requester.
	HeadsEdge uint64 `protobuf:"varint,3,opt,name=headsEdge,proto3" json:"headsEdge,omitempty"`
}

func NewPopulatedExchangeEdgesRequest_Body_ThreadEntry 

func NewPopulatedExchangeEdgesRequest_Body_ThreadEntry(r randyNet, easy bool) *ExchangeEdgesRequest_Body_ThreadEntry

func (*ExchangeEdgesRequest_Body_ThreadEntry) Descriptor 

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

func (*ExchangeEdgesRequest_Body_ThreadEntry) GetAddressEdge 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) GetAddressEdge() uint64

func (*ExchangeEdgesRequest_Body_ThreadEntry) GetHeadsEdge 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) GetHeadsEdge() uint64

func (*ExchangeEdgesRequest_Body_ThreadEntry) Marshal 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) Marshal() (dAtA []byte, err error)

func (*ExchangeEdgesRequest_Body_ThreadEntry) MarshalTo 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) MarshalTo(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest_Body_ThreadEntry) MarshalToSizedBuffer 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangeEdgesRequest_Body_ThreadEntry) ProtoMessage 

func (*ExchangeEdgesRequest_Body_ThreadEntry) ProtoMessage()

func (*ExchangeEdgesRequest_Body_ThreadEntry) Reset 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) Reset()

func (*ExchangeEdgesRequest_Body_ThreadEntry) Size 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) Size() (n int)

func (*ExchangeEdgesRequest_Body_ThreadEntry) String 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) String() string

func (*ExchangeEdgesRequest_Body_ThreadEntry) Unmarshal 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) Unmarshal(dAtA []byte) error

func (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_DiscardUnknown 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) XXX_DiscardUnknown()

func (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_Marshal 

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

func (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_Merge 

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

func (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_Size 

func (m *ExchangeEdgesRequest_Body_ThreadEntry) XXX_Size() int

func (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_Unmarshal 

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

type GetLogsReply 

type GetLogsReply struct {
	// logs are the result of the request.
	Logs []*Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
}

GetLogsReply is the response from a GetLogsRequest.

func NewPopulatedGetLogsReply 

func NewPopulatedGetLogsReply(r randyNet, easy bool) *GetLogsReply

func (*GetLogsReply) Descriptor 

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

func (*GetLogsReply) GetLogs 

func (m *GetLogsReply) GetLogs() []*Log

func (*GetLogsReply) Marshal 

func (m *GetLogsReply) Marshal() (dAtA []byte, err error)

func (*GetLogsReply) MarshalTo 

func (m *GetLogsReply) MarshalTo(dAtA []byte) (int, error)

func (*GetLogsReply) MarshalToSizedBuffer 

func (m *GetLogsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLogsReply) ProtoMessage 

func (*GetLogsReply) ProtoMessage()

func (*GetLogsReply) Reset 

func (m *GetLogsReply) Reset()

func (*GetLogsReply) Size 

func (m *GetLogsReply) Size() (n int)

func (*GetLogsReply) String 

func (m *GetLogsReply) String() string

func (*GetLogsReply) Unmarshal 

func (m *GetLogsReply) Unmarshal(dAtA []byte) error

func (*GetLogsReply) XXX_DiscardUnknown 

func (m *GetLogsReply) XXX_DiscardUnknown()

func (*GetLogsReply) XXX_Marshal 

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

func (*GetLogsReply) XXX_Merge 

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

func (*GetLogsReply) XXX_Size 

func (m *GetLogsReply) XXX_Size() int

func (*GetLogsReply) XXX_Unmarshal 

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

type GetLogsRequest 

type GetLogsRequest struct {
	// body is the message body.
	Body *GetLogsRequest_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

GetLogsRequest is used to request thread logs.

func NewPopulatedGetLogsRequest 

func NewPopulatedGetLogsRequest(r randyNet, easy bool) *GetLogsRequest

func (*GetLogsRequest) Descriptor 

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

func (*GetLogsRequest) GetBody 

func (m *GetLogsRequest) GetBody() *GetLogsRequest_Body

func (*GetLogsRequest) Marshal 

func (m *GetLogsRequest) Marshal() (dAtA []byte, err error)

func (*GetLogsRequest) MarshalTo 

func (m *GetLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetLogsRequest) MarshalToSizedBuffer 

func (m *GetLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLogsRequest) ProtoMessage 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) Reset 

func (m *GetLogsRequest) Reset()

func (*GetLogsRequest) Size 

func (m *GetLogsRequest) Size() (n int)

func (*GetLogsRequest) String 

func (m *GetLogsRequest) String() string

func (*GetLogsRequest) Unmarshal 

func (m *GetLogsRequest) Unmarshal(dAtA []byte) error

func (*GetLogsRequest) XXX_DiscardUnknown 

func (m *GetLogsRequest) XXX_DiscardUnknown()

func (*GetLogsRequest) XXX_Marshal 

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

func (*GetLogsRequest) XXX_Merge 

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

func (*GetLogsRequest) XXX_Size 

func (m *GetLogsRequest) XXX_Size() int

func (*GetLogsRequest) XXX_Unmarshal 

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

type GetLogsRequest_Body 

type GetLogsRequest_Body struct {
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// serviceKey for the thread.
	ServiceKey *ProtoKey `protobuf:"bytes,2,opt,name=serviceKey,proto3,customtype=ProtoKey" json:"serviceKey,omitempty"`
}

func NewPopulatedGetLogsRequest_Body 

func NewPopulatedGetLogsRequest_Body(r randyNet, easy bool) *GetLogsRequest_Body

func (*GetLogsRequest_Body) Descriptor 

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

func (*GetLogsRequest_Body) Marshal 

func (m *GetLogsRequest_Body) Marshal() (dAtA []byte, err error)

func (*GetLogsRequest_Body) MarshalTo 

func (m *GetLogsRequest_Body) MarshalTo(dAtA []byte) (int, error)

func (*GetLogsRequest_Body) MarshalToSizedBuffer 

func (m *GetLogsRequest_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLogsRequest_Body) ProtoMessage 

func (*GetLogsRequest_Body) ProtoMessage()

func (*GetLogsRequest_Body) Reset 

func (m *GetLogsRequest_Body) Reset()

func (*GetLogsRequest_Body) Size 

func (m *GetLogsRequest_Body) Size() (n int)

func (*GetLogsRequest_Body) String 

func (m *GetLogsRequest_Body) String() string

func (*GetLogsRequest_Body) Unmarshal 

func (m *GetLogsRequest_Body) Unmarshal(dAtA []byte) error

func (*GetLogsRequest_Body) XXX_DiscardUnknown 

func (m *GetLogsRequest_Body) XXX_DiscardUnknown()

func (*GetLogsRequest_Body) XXX_Marshal 

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

func (*GetLogsRequest_Body) XXX_Merge 

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

func (*GetLogsRequest_Body) XXX_Size 

func (m *GetLogsRequest_Body) XXX_Size() int

func (*GetLogsRequest_Body) XXX_Unmarshal 

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

type GetRecordsReply 

type GetRecordsReply struct {
	// records are the result of the request.
	Logs []*GetRecordsReply_LogEntry `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
}

GetRecordsReply contains records requested with a GetRecordsRequest.

func NewPopulatedGetRecordsReply 

func NewPopulatedGetRecordsReply(r randyNet, easy bool) *GetRecordsReply

func (*GetRecordsReply) Descriptor 

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

func (*GetRecordsReply) GetLogs 

func (m *GetRecordsReply) GetLogs() []*GetRecordsReply_LogEntry

func (*GetRecordsReply) Marshal 

func (m *GetRecordsReply) Marshal() (dAtA []byte, err error)

func (*GetRecordsReply) MarshalTo 

func (m *GetRecordsReply) MarshalTo(dAtA []byte) (int, error)

func (*GetRecordsReply) MarshalToSizedBuffer 

func (m *GetRecordsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsReply) ProtoMessage 

func (*GetRecordsReply) ProtoMessage()

func (*GetRecordsReply) Reset 

func (m *GetRecordsReply) Reset()

func (*GetRecordsReply) Size 

func (m *GetRecordsReply) Size() (n int)

func (*GetRecordsReply) String 

func (m *GetRecordsReply) String() string

func (*GetRecordsReply) Unmarshal 

func (m *GetRecordsReply) Unmarshal(dAtA []byte) error

func (*GetRecordsReply) XXX_DiscardUnknown 

func (m *GetRecordsReply) XXX_DiscardUnknown()

func (*GetRecordsReply) XXX_Marshal 

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

func (*GetRecordsReply) XXX_Merge 

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

func (*GetRecordsReply) XXX_Size 

func (m *GetRecordsReply) XXX_Size() int

func (*GetRecordsReply) XXX_Unmarshal 

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

type GetRecordsReply_LogEntry 

type GetRecordsReply_LogEntry struct {
	// logID of this entry.
	LogID *ProtoPeerID `protobuf:"bytes,1,opt,name=logID,proto3,customtype=ProtoPeerID" json:"logID,omitempty"`
	// records returned for this entry.
	Records []*Log_Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// log contains new log info that was missing from the request.
	Log *Log `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
}

LogEntry represents a single log.

func NewPopulatedGetRecordsReply_LogEntry 

func NewPopulatedGetRecordsReply_LogEntry(r randyNet, easy bool) *GetRecordsReply_LogEntry

func (*GetRecordsReply_LogEntry) Descriptor 

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

func (*GetRecordsReply_LogEntry) GetLog 

func (m *GetRecordsReply_LogEntry) GetLog() *Log

func (*GetRecordsReply_LogEntry) GetRecords 

func (m *GetRecordsReply_LogEntry) GetRecords() []*Log_Record

func (*GetRecordsReply_LogEntry) Marshal 

func (m *GetRecordsReply_LogEntry) Marshal() (dAtA []byte, err error)

func (*GetRecordsReply_LogEntry) MarshalTo 

func (m *GetRecordsReply_LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*GetRecordsReply_LogEntry) MarshalToSizedBuffer 

func (m *GetRecordsReply_LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsReply_LogEntry) ProtoMessage 

func (*GetRecordsReply_LogEntry) ProtoMessage()

func (*GetRecordsReply_LogEntry) Reset 

func (m *GetRecordsReply_LogEntry) Reset()

func (*GetRecordsReply_LogEntry) Size 

func (m *GetRecordsReply_LogEntry) Size() (n int)

func (*GetRecordsReply_LogEntry) String 

func (m *GetRecordsReply_LogEntry) String() string

func (*GetRecordsReply_LogEntry) Unmarshal 

func (m *GetRecordsReply_LogEntry) Unmarshal(dAtA []byte) error

func (*GetRecordsReply_LogEntry) XXX_DiscardUnknown 

func (m *GetRecordsReply_LogEntry) XXX_DiscardUnknown()

func (*GetRecordsReply_LogEntry) XXX_Marshal 

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

func (*GetRecordsReply_LogEntry) XXX_Merge 

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

func (*GetRecordsReply_LogEntry) XXX_Size 

func (m *GetRecordsReply_LogEntry) XXX_Size() int

func (*GetRecordsReply_LogEntry) XXX_Unmarshal 

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

type GetRecordsRequest 

type GetRecordsRequest struct {
	// body is the message body.
	Body *GetRecordsRequest_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

GetRecordsRequest is used to request records from a log address.

func NewPopulatedGetRecordsRequest 

func NewPopulatedGetRecordsRequest(r randyNet, easy bool) *GetRecordsRequest

func (*GetRecordsRequest) Descriptor 

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

func (*GetRecordsRequest) GetBody 

func (m *GetRecordsRequest) GetBody() *GetRecordsRequest_Body

func (*GetRecordsRequest) Marshal 

func (m *GetRecordsRequest) Marshal() (dAtA []byte, err error)

func (*GetRecordsRequest) MarshalTo 

func (m *GetRecordsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRecordsRequest) MarshalToSizedBuffer 

func (m *GetRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsRequest) ProtoMessage 

func (*GetRecordsRequest) ProtoMessage()

func (*GetRecordsRequest) Reset 

func (m *GetRecordsRequest) Reset()

func (*GetRecordsRequest) Size 

func (m *GetRecordsRequest) Size() (n int)

func (*GetRecordsRequest) String 

func (m *GetRecordsRequest) String() string

func (*GetRecordsRequest) Unmarshal 

func (m *GetRecordsRequest) Unmarshal(dAtA []byte) error

func (*GetRecordsRequest) XXX_DiscardUnknown 

func (m *GetRecordsRequest) XXX_DiscardUnknown()

func (*GetRecordsRequest) XXX_Marshal 

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

func (*GetRecordsRequest) XXX_Merge 

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

func (*GetRecordsRequest) XXX_Size 

func (m *GetRecordsRequest) XXX_Size() int

func (*GetRecordsRequest) XXX_Unmarshal 

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

type GetRecordsRequest_Body 

type GetRecordsRequest_Body struct {
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// serviceKey for the thread.
	ServiceKey *ProtoKey `protobuf:"bytes,2,opt,name=serviceKey,proto3,customtype=ProtoKey" json:"serviceKey,omitempty"`
	// List of requested logs.
	Logs []*GetRecordsRequest_Body_LogEntry `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
}

func NewPopulatedGetRecordsRequest_Body 

func NewPopulatedGetRecordsRequest_Body(r randyNet, easy bool) *GetRecordsRequest_Body

func (*GetRecordsRequest_Body) Descriptor 

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

func (*GetRecordsRequest_Body) GetLogs 

func (m *GetRecordsRequest_Body) GetLogs() []*GetRecordsRequest_Body_LogEntry

func (*GetRecordsRequest_Body) Marshal 

func (m *GetRecordsRequest_Body) Marshal() (dAtA []byte, err error)

func (*GetRecordsRequest_Body) MarshalTo 

func (m *GetRecordsRequest_Body) MarshalTo(dAtA []byte) (int, error)

func (*GetRecordsRequest_Body) MarshalToSizedBuffer 

func (m *GetRecordsRequest_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsRequest_Body) ProtoMessage 

func (*GetRecordsRequest_Body) ProtoMessage()

func (*GetRecordsRequest_Body) Reset 

func (m *GetRecordsRequest_Body) Reset()

func (*GetRecordsRequest_Body) Size 

func (m *GetRecordsRequest_Body) Size() (n int)

func (*GetRecordsRequest_Body) String 

func (m *GetRecordsRequest_Body) String() string

func (*GetRecordsRequest_Body) Unmarshal 

func (m *GetRecordsRequest_Body) Unmarshal(dAtA []byte) error

func (*GetRecordsRequest_Body) XXX_DiscardUnknown 

func (m *GetRecordsRequest_Body) XXX_DiscardUnknown()

func (*GetRecordsRequest_Body) XXX_Marshal 

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

func (*GetRecordsRequest_Body) XXX_Merge 

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

func (*GetRecordsRequest_Body) XXX_Size 

func (m *GetRecordsRequest_Body) XXX_Size() int

func (*GetRecordsRequest_Body) XXX_Unmarshal 

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

type GetRecordsRequest_Body_LogEntry 

type GetRecordsRequest_Body_LogEntry struct {
	// logID of this entry.
	LogID *ProtoPeerID `protobuf:"bytes,1,opt,name=logID,proto3,customtype=ProtoPeerID" json:"logID,omitempty"`
	// offset tells the recipient at which point to consider records new for the reply.
	Offset *ProtoCid `protobuf:"bytes,2,opt,name=offset,proto3,customtype=ProtoCid" json:"offset,omitempty"`
	// limit indicates the max number of records to return.
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// counter indicates the position of record
	Counter int64 `protobuf:"varint,4,opt,name=counter,proto3" json:"counter,omitempty"`
}

LogEntry represents a single log.

func NewPopulatedGetRecordsRequest_Body_LogEntry 

func NewPopulatedGetRecordsRequest_Body_LogEntry(r randyNet, easy bool) *GetRecordsRequest_Body_LogEntry

func (*GetRecordsRequest_Body_LogEntry) Descriptor 

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

func (*GetRecordsRequest_Body_LogEntry) GetCounter 

func (m *GetRecordsRequest_Body_LogEntry) GetCounter() int64

func (*GetRecordsRequest_Body_LogEntry) GetLimit 

func (m *GetRecordsRequest_Body_LogEntry) GetLimit() int32

func (*GetRecordsRequest_Body_LogEntry) Marshal 

func (m *GetRecordsRequest_Body_LogEntry) Marshal() (dAtA []byte, err error)

func (*GetRecordsRequest_Body_LogEntry) MarshalTo 

func (m *GetRecordsRequest_Body_LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*GetRecordsRequest_Body_LogEntry) MarshalToSizedBuffer 

func (m *GetRecordsRequest_Body_LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsRequest_Body_LogEntry) ProtoMessage 

func (*GetRecordsRequest_Body_LogEntry) ProtoMessage()

func (*GetRecordsRequest_Body_LogEntry) Reset 

func (m *GetRecordsRequest_Body_LogEntry) Reset()

func (*GetRecordsRequest_Body_LogEntry) Size 

func (m *GetRecordsRequest_Body_LogEntry) Size() (n int)

func (*GetRecordsRequest_Body_LogEntry) String 

func (m *GetRecordsRequest_Body_LogEntry) String() string

func (*GetRecordsRequest_Body_LogEntry) Unmarshal 

func (m *GetRecordsRequest_Body_LogEntry) Unmarshal(dAtA []byte) error

func (*GetRecordsRequest_Body_LogEntry) XXX_DiscardUnknown 

func (m *GetRecordsRequest_Body_LogEntry) XXX_DiscardUnknown()

func (*GetRecordsRequest_Body_LogEntry) XXX_Marshal 

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

func (*GetRecordsRequest_Body_LogEntry) XXX_Merge 

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

func (*GetRecordsRequest_Body_LogEntry) XXX_Size 

func (m *GetRecordsRequest_Body_LogEntry) XXX_Size() int

func (*GetRecordsRequest_Body_LogEntry) XXX_Unmarshal 

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

type HeadBookRecord 

type HeadBookRecord struct {
	// List of current heads of a log.
	Heads []*HeadBookRecord_HeadEntry `protobuf:"bytes,1,rep,name=heads,proto3" json:"heads,omitempty"`
}

HeadBookRecord represents the list of heads currently in a log

func NewPopulatedHeadBookRecord 

func NewPopulatedHeadBookRecord(r randyLstore, easy bool) *HeadBookRecord

func (*HeadBookRecord) Descriptor 

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

func (*HeadBookRecord) GetHeads 

func (m *HeadBookRecord) GetHeads() []*HeadBookRecord_HeadEntry

func (*HeadBookRecord) Marshal 

func (m *HeadBookRecord) Marshal() (dAtA []byte, err error)

func (*HeadBookRecord) MarshalTo 

func (m *HeadBookRecord) MarshalTo(dAtA []byte) (int, error)

func (*HeadBookRecord) MarshalToSizedBuffer 

func (m *HeadBookRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeadBookRecord) ProtoMessage 

func (*HeadBookRecord) ProtoMessage()

func (*HeadBookRecord) Reset 

func (m *HeadBookRecord) Reset()

func (*HeadBookRecord) Size 

func (m *HeadBookRecord) Size() (n int)

func (*HeadBookRecord) String 

func (m *HeadBookRecord) String() string

func (*HeadBookRecord) Unmarshal 

func (m *HeadBookRecord) Unmarshal(dAtA []byte) error

func (*HeadBookRecord) XXX_DiscardUnknown 

func (m *HeadBookRecord) XXX_DiscardUnknown()

func (*HeadBookRecord) XXX_Marshal 

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

func (*HeadBookRecord) XXX_Merge 

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

func (*HeadBookRecord) XXX_Size 

func (m *HeadBookRecord) XXX_Size() int

func (*HeadBookRecord) XXX_Unmarshal 

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

type HeadBookRecord_HeadEntry 

type HeadBookRecord_HeadEntry struct {
	Cid     *ProtoCid `protobuf:"bytes,1,opt,name=cid,proto3,customtype=ProtoCid" json:"cid,omitempty"`
	Counter int64     `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
}

HeadEntry represents a single cid.

func NewPopulatedHeadBookRecord_HeadEntry 

func NewPopulatedHeadBookRecord_HeadEntry(r randyLstore, easy bool) *HeadBookRecord_HeadEntry

func (*HeadBookRecord_HeadEntry) Descriptor 

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

func (*HeadBookRecord_HeadEntry) GetCounter 

func (m *HeadBookRecord_HeadEntry) GetCounter() int64

func (*HeadBookRecord_HeadEntry) Marshal 

func (m *HeadBookRecord_HeadEntry) Marshal() (dAtA []byte, err error)

func (*HeadBookRecord_HeadEntry) MarshalTo 

func (m *HeadBookRecord_HeadEntry) MarshalTo(dAtA []byte) (int, error)

func (*HeadBookRecord_HeadEntry) MarshalToSizedBuffer 

func (m *HeadBookRecord_HeadEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeadBookRecord_HeadEntry) ProtoMessage 

func (*HeadBookRecord_HeadEntry) ProtoMessage()

func (*HeadBookRecord_HeadEntry) Reset 

func (m *HeadBookRecord_HeadEntry) Reset()

func (*HeadBookRecord_HeadEntry) Size 

func (m *HeadBookRecord_HeadEntry) Size() (n int)

func (*HeadBookRecord_HeadEntry) String 

func (m *HeadBookRecord_HeadEntry) String() string

func (*HeadBookRecord_HeadEntry) Unmarshal 

func (m *HeadBookRecord_HeadEntry) Unmarshal(dAtA []byte) error

func (*HeadBookRecord_HeadEntry) XXX_DiscardUnknown 

func (m *HeadBookRecord_HeadEntry) XXX_DiscardUnknown()

func (*HeadBookRecord_HeadEntry) XXX_Marshal 

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

func (*HeadBookRecord_HeadEntry) XXX_Merge 

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

func (*HeadBookRecord_HeadEntry) XXX_Size 

func (m *HeadBookRecord_HeadEntry) XXX_Size() int

func (*HeadBookRecord_HeadEntry) XXX_Unmarshal 

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

type Log 

type Log struct {
	// ID of the log.
	ID *ProtoPeerID `protobuf:"bytes,1,opt,name=ID,proto3,customtype=ProtoPeerID" json:"ID,omitempty"`
	// pubKey of the log.
	PubKey *ProtoPubKey `protobuf:"bytes,2,opt,name=pubKey,proto3,customtype=ProtoPubKey" json:"pubKey,omitempty"`
	// addrs of the log.
	Addrs []ProtoAddr `protobuf:"bytes,3,rep,name=addrs,proto3,customtype=ProtoAddr" json:"addrs,omitempty"`
	// head of the log.
	Head *ProtoCid `protobuf:"bytes,4,opt,name=head,proto3,customtype=ProtoCid" json:"head,omitempty"`
	// position of the log
	Counter int64 `protobuf:"varint,5,opt,name=counter,proto3" json:"counter,omitempty"`
}

Log represents a thread log.

func NewPopulatedLog 

func NewPopulatedLog(r randyNet, easy bool) *Log

func (*Log) Descriptor 

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

func (*Log) GetCounter 

func (m *Log) GetCounter() int64

func (*Log) Marshal 

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo 

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) MarshalToSizedBuffer 

func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

func (m *Log) Size() (n int)

func (*Log) String 

func (m *Log) String() string

func (*Log) Unmarshal 

func (m *Log) Unmarshal(dAtA []byte) error

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

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

func (*Log) XXX_Merge 

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

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

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

type Log_Record 

type Log_Record struct {
	// recordNode is the top-level node's raw data.
	RecordNode []byte `protobuf:"bytes,1,opt,name=recordNode,proto3" json:"recordNode,omitempty"`
	// eventNode is the event node's raw data.
	EventNode []byte `protobuf:"bytes,2,opt,name=eventNode,proto3" json:"eventNode,omitempty"`
	// headerNode is the header node's raw data.
	HeaderNode []byte `protobuf:"bytes,3,opt,name=headerNode,proto3" json:"headerNode,omitempty"`
	// bodyNode is the body node's raw data.
	BodyNode []byte `protobuf:"bytes,4,opt,name=bodyNode,proto3" json:"bodyNode,omitempty"`
}

Record is a thread record containing link data.

func NewPopulatedLog_Record 

func NewPopulatedLog_Record(r randyNet, easy bool) *Log_Record

func (*Log_Record) Descriptor 

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

func (*Log_Record) GetBodyNode 

func (m *Log_Record) GetBodyNode() []byte

func (*Log_Record) GetEventNode 

func (m *Log_Record) GetEventNode() []byte

func (*Log_Record) GetHeaderNode 

func (m *Log_Record) GetHeaderNode() []byte

func (*Log_Record) GetRecordNode 

func (m *Log_Record) GetRecordNode() []byte

func (*Log_Record) Marshal 

func (m *Log_Record) Marshal() (dAtA []byte, err error)

func (*Log_Record) MarshalTo 

func (m *Log_Record) MarshalTo(dAtA []byte) (int, error)

func (*Log_Record) MarshalToSizedBuffer 

func (m *Log_Record) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Log_Record) ProtoMessage 

func (*Log_Record) ProtoMessage()

func (*Log_Record) Reset 

func (m *Log_Record) Reset()

func (*Log_Record) Size 

func (m *Log_Record) Size() (n int)

func (*Log_Record) String 

func (m *Log_Record) String() string

func (*Log_Record) Unmarshal 

func (m *Log_Record) Unmarshal(dAtA []byte) error

func (*Log_Record) XXX_DiscardUnknown 

func (m *Log_Record) XXX_DiscardUnknown()

func (*Log_Record) XXX_Marshal 

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

func (*Log_Record) XXX_Merge 

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

func (*Log_Record) XXX_Size 

func (m *Log_Record) XXX_Size() int

func (*Log_Record) XXX_Unmarshal 

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

type ProtoAddr 

type ProtoAddr struct {
	ma.Multiaddr
}

ProtoAddr is a custom type used by gogo to serde raw multiaddresses into the ma.Multiaddr type, and back.

func NewPopulatedProtoAddr 

func NewPopulatedProtoAddr(_ randyNet) *ProtoAddr

NewPopulatedProtoAddr generates a populated instance of the custom gogo type ProtoAddr. It is required by gogo-generated tests.

func (ProtoAddr) Marshal 

func (a ProtoAddr) Marshal() ([]byte, error)

func (ProtoAddr) MarshalJSON 

func (a ProtoAddr) MarshalJSON() ([]byte, error)

func (ProtoAddr) MarshalTo 

func (a ProtoAddr) MarshalTo(data []byte) (n int, err error)

func (ProtoAddr) Size 

func (a ProtoAddr) Size() int

func (*ProtoAddr) Unmarshal 

func (a *ProtoAddr) Unmarshal(data []byte) (err error)

func (*ProtoAddr) UnmarshalJSON 

func (a *ProtoAddr) UnmarshalJSON(data []byte) error

type ProtoCid 

type ProtoCid struct {
	cid.Cid
}

ProtoCid is a custom type used by gogo to serde raw CIDs into the cid.CID type, and back.

func NewPopulatedProtoCid 

func NewPopulatedProtoCid(_ randyNet) *ProtoCid

NewPopulatedProtoCid generates a populated instance of the custom gogo type ProtoCid. It is required by gogo-generated tests.

func (ProtoCid) Marshal 

func (c ProtoCid) Marshal() ([]byte, error)

func (ProtoCid) MarshalJSON 

func (c ProtoCid) MarshalJSON() ([]byte, error)

func (ProtoCid) MarshalTo 

func (c ProtoCid) MarshalTo(data []byte) (n int, err error)

func (ProtoCid) Size 

func (c ProtoCid) Size() int

func (*ProtoCid) Unmarshal 

func (c *ProtoCid) Unmarshal(data []byte) (err error)

func (*ProtoCid) UnmarshalJSON 

func (c *ProtoCid) UnmarshalJSON(data []byte) error

type ProtoKey 

type ProtoKey struct {
	*sym.Key
}

ProtoKey is a custom type used by gogo to serde raw keys into the symmetric.Key type, and back.

func NewPopulatedProtoKey 

func NewPopulatedProtoKey(_ randyNet) *ProtoKey

NewPopulatedProtoKey generates a populated instance of the custom gogo type ProtoKey. It is required by gogo-generated tests.

func (ProtoKey) Marshal 

func (k ProtoKey) Marshal() ([]byte, error)

func (ProtoKey) MarshalJSON 

func (k ProtoKey) MarshalJSON() ([]byte, error)

func (ProtoKey) MarshalTo 

func (k ProtoKey) MarshalTo(data []byte) (n int, err error)

func (ProtoKey) Size 

func (k ProtoKey) Size() int

func (*ProtoKey) Unmarshal 

func (k *ProtoKey) Unmarshal(data []byte) (err error)

func (*ProtoKey) UnmarshalJSON 

func (k *ProtoKey) UnmarshalJSON(data []byte) error

type ProtoPeerID 

type ProtoPeerID struct {
	peer.ID
}

ProtoPeerID is a custom type used by gogo to serde raw peer IDs into the peer.ID type, and back.

func NewPopulatedProtoPeerID 

func NewPopulatedProtoPeerID(_ randyNet) *ProtoPeerID

NewPopulatedProtoPeerID generates a populated instance of the custom gogo type ProtoPeerID. It is required by gogo-generated tests.

func (ProtoPeerID) Marshal 

func (id ProtoPeerID) Marshal() ([]byte, error)

func (ProtoPeerID) MarshalJSON 

func (id ProtoPeerID) MarshalJSON() ([]byte, error)

func (ProtoPeerID) MarshalTo 

func (id ProtoPeerID) MarshalTo(data []byte) (n int, err error)

func (ProtoPeerID) Size 

func (id ProtoPeerID) Size() int

func (*ProtoPeerID) Unmarshal 

func (id *ProtoPeerID) Unmarshal(data []byte) (err error)

func (*ProtoPeerID) UnmarshalJSON 

func (id *ProtoPeerID) UnmarshalJSON(data []byte) error

type ProtoPrivKey 

type ProtoPrivKey struct {
	crypto.PrivKey
}

ProtoPrivKey is a custom type used by gogo to serde raw private keys into the PrivKey type, and back.

func NewPopulatedProtoPrivKey 

func NewPopulatedProtoPrivKey(_ randyNet) *ProtoPrivKey

NewPopulatedProtoPrivKey generates a populated instance of the custom gogo type ProtoPrivKey. It is required by gogo-generated tests.

func (ProtoPrivKey) Marshal 

func (k ProtoPrivKey) Marshal() ([]byte, error)

func (ProtoPrivKey) MarshalJSON 

func (k ProtoPrivKey) MarshalJSON() ([]byte, error)

func (ProtoPrivKey) MarshalTo 

func (k ProtoPrivKey) MarshalTo(data []byte) (n int, err error)

func (ProtoPrivKey) Size 

func (k ProtoPrivKey) Size() int

func (*ProtoPrivKey) Unmarshal 

func (k *ProtoPrivKey) Unmarshal(data []byte) (err error)

func (*ProtoPrivKey) UnmarshalJSON 

func (k *ProtoPrivKey) UnmarshalJSON(data []byte) error

type ProtoPubKey 

type ProtoPubKey struct {
	crypto.PubKey
}

ProtoPubKey is a custom type used by gogo to serde raw public keys into the PubKey type, and back.

func NewPopulatedProtoPubKey 

func NewPopulatedProtoPubKey(_ randyNet) *ProtoPubKey

NewPopulatedProtoPubKey generates a populated instance of the custom gogo type ProtoPubKey. It is required by gogo-generated tests.

func (ProtoPubKey) Marshal 

func (k ProtoPubKey) Marshal() ([]byte, error)

func (ProtoPubKey) MarshalJSON 

func (k ProtoPubKey) MarshalJSON() ([]byte, error)

func (ProtoPubKey) MarshalTo 

func (k ProtoPubKey) MarshalTo(data []byte) (n int, err error)

func (ProtoPubKey) Size 

func (k ProtoPubKey) Size() int

func (*ProtoPubKey) Unmarshal 

func (k *ProtoPubKey) Unmarshal(data []byte) (err error)

func (*ProtoPubKey) UnmarshalJSON 

func (k *ProtoPubKey) UnmarshalJSON(data []byte) error

type ProtoThreadID 

type ProtoThreadID struct {
	thread.ID
}

ProtoThreadID is a custom type used by gogo to serde raw thread IDs into the service.ID type, and back.

func NewPopulatedProtoThreadID 

func NewPopulatedProtoThreadID(_ randyNet) *ProtoThreadID

NewPopulatedProtoThreadID generates a populated instance of the custom gogo type ProtoThreadID. It is required by gogo-generated tests.

func (ProtoThreadID) Marshal 

func (id ProtoThreadID) Marshal() ([]byte, error)

func (ProtoThreadID) MarshalJSON 

func (id ProtoThreadID) MarshalJSON() ([]byte, error)

func (ProtoThreadID) MarshalTo 

func (id ProtoThreadID) MarshalTo(data []byte) (n int, err error)

func (ProtoThreadID) Size 

func (id ProtoThreadID) Size() int

func (*ProtoThreadID) Unmarshal 

func (id *ProtoThreadID) Unmarshal(data []byte) (err error)

func (*ProtoThreadID) UnmarshalJSON 

func (id *ProtoThreadID) UnmarshalJSON(data []byte) error

type PushLogReply 

type PushLogReply struct {
}

PushLogReply is the response from a PushLogRequest.

func NewPopulatedPushLogReply 

func NewPopulatedPushLogReply(r randyNet, easy bool) *PushLogReply

func (*PushLogReply) Descriptor 

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

func (*PushLogReply) Marshal 

func (m *PushLogReply) Marshal() (dAtA []byte, err error)

func (*PushLogReply) MarshalTo 

func (m *PushLogReply) MarshalTo(dAtA []byte) (int, error)

func (*PushLogReply) MarshalToSizedBuffer 

func (m *PushLogReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushLogReply) ProtoMessage 

func (*PushLogReply) ProtoMessage()

func (*PushLogReply) Reset 

func (m *PushLogReply) Reset()

func (*PushLogReply) Size 

func (m *PushLogReply) Size() (n int)

func (*PushLogReply) String 

func (m *PushLogReply) String() string

func (*PushLogReply) Unmarshal 

func (m *PushLogReply) Unmarshal(dAtA []byte) error

func (*PushLogReply) XXX_DiscardUnknown 

func (m *PushLogReply) XXX_DiscardUnknown()

func (*PushLogReply) XXX_Marshal 

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

func (*PushLogReply) XXX_Merge 

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

func (*PushLogReply) XXX_Size 

func (m *PushLogReply) XXX_Size() int

func (*PushLogReply) XXX_Unmarshal 

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

type PushLogRequest 

type PushLogRequest struct {
	// body is the message body.
	Body *PushLogRequest_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

PushLogRequest is used to push a thread log to a peer.

func NewPopulatedPushLogRequest 

func NewPopulatedPushLogRequest(r randyNet, easy bool) *PushLogRequest

func (*PushLogRequest) Descriptor 

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

func (*PushLogRequest) GetBody 

func (m *PushLogRequest) GetBody() *PushLogRequest_Body

func (*PushLogRequest) Marshal 

func (m *PushLogRequest) Marshal() (dAtA []byte, err error)

func (*PushLogRequest) MarshalTo 

func (m *PushLogRequest) MarshalTo(dAtA []byte) (int, error)

func (*PushLogRequest) MarshalToSizedBuffer 

func (m *PushLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushLogRequest) ProtoMessage 

func (*PushLogRequest) ProtoMessage()

func (*PushLogRequest) Reset 

func (m *PushLogRequest) Reset()

func (*PushLogRequest) Size 

func (m *PushLogRequest) Size() (n int)

func (*PushLogRequest) String 

func (m *PushLogRequest) String() string

func (*PushLogRequest) Unmarshal 

func (m *PushLogRequest) Unmarshal(dAtA []byte) error

func (*PushLogRequest) XXX_DiscardUnknown 

func (m *PushLogRequest) XXX_DiscardUnknown()

func (*PushLogRequest) XXX_Marshal 

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

func (*PushLogRequest) XXX_Merge 

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

func (*PushLogRequest) XXX_Size 

func (m *PushLogRequest) XXX_Size() int

func (*PushLogRequest) XXX_Unmarshal 

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

type PushLogRequest_Body 

type PushLogRequest_Body struct {
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// serviceKey for the thread.
	ServiceKey *ProtoKey `protobuf:"bytes,2,opt,name=serviceKey,proto3,customtype=ProtoKey" json:"serviceKey,omitempty"`
	// readKey for the thread.
	ReadKey *ProtoKey `protobuf:"bytes,3,opt,name=readKey,proto3,customtype=ProtoKey" json:"readKey,omitempty"`
	// log is the actual log payload.
	Log *Log `protobuf:"bytes,4,opt,name=log,proto3" json:"log,omitempty"`
}

func NewPopulatedPushLogRequest_Body 

func NewPopulatedPushLogRequest_Body(r randyNet, easy bool) *PushLogRequest_Body

func (*PushLogRequest_Body) Descriptor 

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

func (*PushLogRequest_Body) GetLog 

func (m *PushLogRequest_Body) GetLog() *Log

func (*PushLogRequest_Body) Marshal 

func (m *PushLogRequest_Body) Marshal() (dAtA []byte, err error)

func (*PushLogRequest_Body) MarshalTo 

func (m *PushLogRequest_Body) MarshalTo(dAtA []byte) (int, error)

func (*PushLogRequest_Body) MarshalToSizedBuffer 

func (m *PushLogRequest_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushLogRequest_Body) ProtoMessage 

func (*PushLogRequest_Body) ProtoMessage()

func (*PushLogRequest_Body) Reset 

func (m *PushLogRequest_Body) Reset()

func (*PushLogRequest_Body) Size 

func (m *PushLogRequest_Body) Size() (n int)

func (*PushLogRequest_Body) String 

func (m *PushLogRequest_Body) String() string

func (*PushLogRequest_Body) Unmarshal 

func (m *PushLogRequest_Body) Unmarshal(dAtA []byte) error

func (*PushLogRequest_Body) XXX_DiscardUnknown 

func (m *PushLogRequest_Body) XXX_DiscardUnknown()

func (*PushLogRequest_Body) XXX_Marshal 

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

func (*PushLogRequest_Body) XXX_Merge 

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

func (*PushLogRequest_Body) XXX_Size 

func (m *PushLogRequest_Body) XXX_Size() int

func (*PushLogRequest_Body) XXX_Unmarshal 

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

type PushRecordReply 

type PushRecordReply struct {
}

PushRecordReply is the response from a PushRecordRequest.

func NewPopulatedPushRecordReply 

func NewPopulatedPushRecordReply(r randyNet, easy bool) *PushRecordReply

func (*PushRecordReply) Descriptor 

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

func (*PushRecordReply) Marshal 

func (m *PushRecordReply) Marshal() (dAtA []byte, err error)

func (*PushRecordReply) MarshalTo 

func (m *PushRecordReply) MarshalTo(dAtA []byte) (int, error)

func (*PushRecordReply) MarshalToSizedBuffer 

func (m *PushRecordReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushRecordReply) ProtoMessage 

func (*PushRecordReply) ProtoMessage()

func (*PushRecordReply) Reset 

func (m *PushRecordReply) Reset()

func (*PushRecordReply) Size 

func (m *PushRecordReply) Size() (n int)

func (*PushRecordReply) String 

func (m *PushRecordReply) String() string

func (*PushRecordReply) Unmarshal 

func (m *PushRecordReply) Unmarshal(dAtA []byte) error

func (*PushRecordReply) XXX_DiscardUnknown 

func (m *PushRecordReply) XXX_DiscardUnknown()

func (*PushRecordReply) XXX_Marshal 

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

func (*PushRecordReply) XXX_Merge 

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

func (*PushRecordReply) XXX_Size 

func (m *PushRecordReply) XXX_Size() int

func (*PushRecordReply) XXX_Unmarshal 

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

type PushRecordRequest 

type PushRecordRequest struct {
	// body is the message body.
	Body *PushRecordRequest_Body `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// position of the record
	Counter int64 `protobuf:"varint,3,opt,name=counter,proto3" json:"counter,omitempty"`
}

PushRecordRequest is used to push a log record to a peer.

func NewPopulatedPushRecordRequest 

func NewPopulatedPushRecordRequest(r randyNet, easy bool) *PushRecordRequest

func (*PushRecordRequest) Descriptor 

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

func (*PushRecordRequest) GetBody 

func (m *PushRecordRequest) GetBody() *PushRecordRequest_Body

func (*PushRecordRequest) GetCounter 

func (m *PushRecordRequest) GetCounter() int64

func (*PushRecordRequest) Marshal 

func (m *PushRecordRequest) Marshal() (dAtA []byte, err error)

func (*PushRecordRequest) MarshalTo 

func (m *PushRecordRequest) MarshalTo(dAtA []byte) (int, error)

func (*PushRecordRequest) MarshalToSizedBuffer 

func (m *PushRecordRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushRecordRequest) ProtoMessage 

func (*PushRecordRequest) ProtoMessage()

func (*PushRecordRequest) Reset 

func (m *PushRecordRequest) Reset()

func (*PushRecordRequest) Size 

func (m *PushRecordRequest) Size() (n int)

func (*PushRecordRequest) String 

func (m *PushRecordRequest) String() string

func (*PushRecordRequest) Unmarshal 

func (m *PushRecordRequest) Unmarshal(dAtA []byte) error

func (*PushRecordRequest) XXX_DiscardUnknown 

func (m *PushRecordRequest) XXX_DiscardUnknown()

func (*PushRecordRequest) XXX_Marshal 

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

func (*PushRecordRequest) XXX_Merge 

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

func (*PushRecordRequest) XXX_Size 

func (m *PushRecordRequest) XXX_Size() int

func (*PushRecordRequest) XXX_Unmarshal 

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

type PushRecordRequest_Body 

type PushRecordRequest_Body struct {
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,1,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// logID is the target log's ID.
	LogID *ProtoPeerID `protobuf:"bytes,2,opt,name=logID,proto3,customtype=ProtoPeerID" json:"logID,omitempty"`
	// record is the actual record payload.
	Record *Log_Record `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
}

func NewPopulatedPushRecordRequest_Body 

func NewPopulatedPushRecordRequest_Body(r randyNet, easy bool) *PushRecordRequest_Body

func (*PushRecordRequest_Body) Descriptor 

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

func (*PushRecordRequest_Body) GetRecord 

func (m *PushRecordRequest_Body) GetRecord() *Log_Record

func (*PushRecordRequest_Body) Marshal 

func (m *PushRecordRequest_Body) Marshal() (dAtA []byte, err error)

func (*PushRecordRequest_Body) MarshalTo 

func (m *PushRecordRequest_Body) MarshalTo(dAtA []byte) (int, error)

func (*PushRecordRequest_Body) MarshalToSizedBuffer 

func (m *PushRecordRequest_Body) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushRecordRequest_Body) ProtoMessage 

func (*PushRecordRequest_Body) ProtoMessage()

func (*PushRecordRequest_Body) Reset 

func (m *PushRecordRequest_Body) Reset()

func (*PushRecordRequest_Body) Size 

func (m *PushRecordRequest_Body) Size() (n int)

func (*PushRecordRequest_Body) String 

func (m *PushRecordRequest_Body) String() string

func (*PushRecordRequest_Body) Unmarshal 

func (m *PushRecordRequest_Body) Unmarshal(dAtA []byte) error

func (*PushRecordRequest_Body) XXX_DiscardUnknown 

func (m *PushRecordRequest_Body) XXX_DiscardUnknown()

func (*PushRecordRequest_Body) XXX_Marshal 

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

func (*PushRecordRequest_Body) XXX_Merge 

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

func (*PushRecordRequest_Body) XXX_Size 

func (m *PushRecordRequest_Body) XXX_Size() int

func (*PushRecordRequest_Body) XXX_Unmarshal 

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

type ServiceClient 

type ServiceClient interface {
	// GetLogs from a peer.
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsReply, error)
	// PushLog to a peer.
	PushLog(ctx context.Context, in *PushLogRequest, opts ...grpc.CallOption) (*PushLogReply, error)
	// GetRecords from a peer.
	GetRecords(ctx context.Context, in *GetRecordsRequest, opts ...grpc.CallOption) (*GetRecordsReply, error)
	// PushRecord to a peer.
	PushRecord(ctx context.Context, in *PushRecordRequest, opts ...grpc.CallOption) (*PushRecordReply, error)
	// ExchangeEdges with a peer.
	ExchangeEdges(ctx context.Context, in *ExchangeEdgesRequest, opts ...grpc.CallOption) (*ExchangeEdgesReply, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceClient 

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceServer 

type ServiceServer interface {
	// GetLogs from a peer.
	GetLogs(context.Context, *GetLogsRequest) (*GetLogsReply, error)
	// PushLog to a peer.
	PushLog(context.Context, *PushLogRequest) (*PushLogReply, error)
	// GetRecords from a peer.
	GetRecords(context.Context, *GetRecordsRequest) (*GetRecordsReply, error)
	// PushRecord to a peer.
	PushRecord(context.Context, *PushRecordRequest) (*PushRecordReply, error)
	// ExchangeEdges with a peer.
	ExchangeEdges(context.Context, *ExchangeEdgesRequest) (*ExchangeEdgesReply, error)
}

ServiceServer is the server API for Service service.

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) ExchangeEdges 

func (*UnimplementedServiceServer) ExchangeEdges(ctx context.Context, req *ExchangeEdgesRequest) (*ExchangeEdgesReply, error)

func (*UnimplementedServiceServer) GetLogs 

func (*UnimplementedServiceServer) GetLogs(ctx context.Context, req *GetLogsRequest) (*GetLogsReply, error)

func (*UnimplementedServiceServer) GetRecords 

func (*UnimplementedServiceServer) GetRecords(ctx context.Context, req *GetRecordsRequest) (*GetRecordsReply, error)

func (*UnimplementedServiceServer) PushLog 

func (*UnimplementedServiceServer) PushLog(ctx context.Context, req *PushLogRequest) (*PushLogReply, error)

func (*UnimplementedServiceServer) PushRecord 

func (*UnimplementedServiceServer) PushRecord(ctx context.Context, req *PushRecordRequest) (*PushRecordReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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