net_pb

package
v0.1.17 Latest Latest
Warning

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

Go to latest
Published: Apr 3, 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 (*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 (*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 (*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 (*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 (*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 (*ExchangeEdgesRequest_Body_ThreadEntry) Size

func (*ExchangeEdgesRequest_Body_ThreadEntry) 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 (*ExchangeEdgesRequest_Body_ThreadEntry) XXX_Size

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 (*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 (*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 (*GetRecordsRequest_Body_LogEntry) Size

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

func (*GetRecordsRequest_Body_LogEntry) 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 (*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) GetLogs

func (*UnimplementedServiceServer) GetRecords

func (*UnimplementedServiceServer) PushLog

func (*UnimplementedServiceServer) PushRecord

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL