Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

net_pb

package

Go to main page

Versions in this module

v0

v0.1.18

May 7, 2024

v0.1.17

Apr 3, 2024

v0.1.16

Apr 3, 2024

v0.1.15

Feb 27, 2024

v0.1.14

Jan 10, 2024

v0.1.13

Jan 10, 2024

v0.1.12

Dec 13, 2023

v0.1.11

Dec 13, 2023

v0.1.10

Dec 13, 2023

v0.1.9

Nov 25, 2023

v0.1.8

Aug 17, 2023

v0.1.7

Jun 9, 2023

v0.1.6

Jun 3, 2023

v0.1.5

Jun 2, 2023

v0.1.4

Jun 2, 2023

v0.1.1

May 25, 2023

v0.1.0

Apr 24, 2023

v0.0.9

Mar 14, 2023

v0.0.8

Mar 14, 2023

v0.0.7

Mar 14, 2023

v0.0.6

Feb 24, 2023

v0.0.5

Feb 1, 2023

v0.0.4

Dec 29, 2022

v0.0.3

Dec 13, 2022

v0.0.2

Dec 11, 2022

v0.0.1

Dec 9, 2022

Changes in this version

+ var ErrIntOverflowLstore = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowNet = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLstore = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthNet = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupLstore = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupNet = fmt.Errorf("proto: unexpected end of group")

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

+ type AddrBookRecord struct

+ Addrs []*AddrBookRecord_AddrEntry

+ PeerID *ProtoPeerID

+ ThreadID *ProtoThreadID

+ func NewPopulatedAddrBookRecord(r randyLstore, easy bool) *AddrBookRecord

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

+ func (*AddrBookRecord) ProtoMessage()

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

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

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

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

+ func (m *AddrBookRecord) Reset()

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

+ func (m *AddrBookRecord) String() string

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

+ func (m *AddrBookRecord) XXX_DiscardUnknown()

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

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

+ func (m *AddrBookRecord) XXX_Size() int

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

+ type AddrBookRecord_AddrEntry struct

+ Addr *ProtoAddr

+ Expiry int64

+ Ttl int64

+ func NewPopulatedAddrBookRecord_AddrEntry(r randyLstore, easy bool) *AddrBookRecord_AddrEntry

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

+ func (*AddrBookRecord_AddrEntry) ProtoMessage()

+ func (m *AddrBookRecord_AddrEntry) GetExpiry() int64

+ func (m *AddrBookRecord_AddrEntry) GetTtl() int64

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

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

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

+ func (m *AddrBookRecord_AddrEntry) Reset()

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

+ func (m *AddrBookRecord_AddrEntry) String() string

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

+ func (m *AddrBookRecord_AddrEntry) XXX_DiscardUnknown()

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

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

+ func (m *AddrBookRecord_AddrEntry) XXX_Size() int

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

+ type ExchangeEdgesReply struct

+ Edges []*ExchangeEdgesReply_ThreadEdges

+ func NewPopulatedExchangeEdgesReply(r randyNet, easy bool) *ExchangeEdgesReply

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

+ func (*ExchangeEdgesReply) ProtoMessage()

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

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

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

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

+ func (m *ExchangeEdgesReply) Reset()

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

+ func (m *ExchangeEdgesReply) String() string

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

+ func (m *ExchangeEdgesReply) XXX_DiscardUnknown()

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

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

+ func (m *ExchangeEdgesReply) XXX_Size() int

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

+ type ExchangeEdgesReply_ThreadEdges struct

+ AddressEdge uint64

+ Exists bool

+ HeadsEdge uint64

+ ThreadID *ProtoThreadID

+ func NewPopulatedExchangeEdgesReply_ThreadEdges(r randyNet, easy bool) *ExchangeEdgesReply_ThreadEdges

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

+ func (*ExchangeEdgesReply_ThreadEdges) ProtoMessage()

+ func (m *ExchangeEdgesReply_ThreadEdges) GetAddressEdge() uint64

+ func (m *ExchangeEdgesReply_ThreadEdges) GetExists() bool

+ func (m *ExchangeEdgesReply_ThreadEdges) GetHeadsEdge() uint64

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

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

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

+ func (m *ExchangeEdgesReply_ThreadEdges) Reset()

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

+ func (m *ExchangeEdgesReply_ThreadEdges) String() string

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

+ func (m *ExchangeEdgesReply_ThreadEdges) XXX_DiscardUnknown()

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

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

+ func (m *ExchangeEdgesReply_ThreadEdges) XXX_Size() int

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

+ type ExchangeEdgesRequest struct

+ Body *ExchangeEdgesRequest_Body

+ func NewPopulatedExchangeEdgesRequest(r randyNet, easy bool) *ExchangeEdgesRequest

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

+ func (*ExchangeEdgesRequest) ProtoMessage()

+ func (m *ExchangeEdgesRequest) GetBody() *ExchangeEdgesRequest_Body

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

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

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

+ func (m *ExchangeEdgesRequest) Reset()

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

+ func (m *ExchangeEdgesRequest) String() string

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

+ func (m *ExchangeEdgesRequest) XXX_DiscardUnknown()

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

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

+ func (m *ExchangeEdgesRequest) XXX_Size() int

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

+ type ExchangeEdgesRequest_Body struct

+ Threads []*ExchangeEdgesRequest_Body_ThreadEntry

+ func NewPopulatedExchangeEdgesRequest_Body(r randyNet, easy bool) *ExchangeEdgesRequest_Body

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

+ func (*ExchangeEdgesRequest_Body) ProtoMessage()

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

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

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

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

+ func (m *ExchangeEdgesRequest_Body) Reset()

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

+ func (m *ExchangeEdgesRequest_Body) String() string

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

+ func (m *ExchangeEdgesRequest_Body) XXX_DiscardUnknown()

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

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

+ func (m *ExchangeEdgesRequest_Body) XXX_Size() int

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

+ type ExchangeEdgesRequest_Body_ThreadEntry struct

+ AddressEdge uint64

+ HeadsEdge uint64

+ ThreadID *ProtoThreadID

+ func NewPopulatedExchangeEdgesRequest_Body_ThreadEntry(r randyNet, easy bool) *ExchangeEdgesRequest_Body_ThreadEntry

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

+ func (*ExchangeEdgesRequest_Body_ThreadEntry) ProtoMessage()

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) GetAddressEdge() uint64

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) GetHeadsEdge() uint64

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

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

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

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) Reset()

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

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) String() string

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

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) XXX_DiscardUnknown()

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

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

+ func (m *ExchangeEdgesRequest_Body_ThreadEntry) XXX_Size() int

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

+ type GetLogsReply struct

+ Logs []*Log

+ func NewPopulatedGetLogsReply(r randyNet, easy bool) *GetLogsReply

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

+ func (*GetLogsReply) ProtoMessage()

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

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

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

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

+ func (m *GetLogsReply) Reset()

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

+ func (m *GetLogsReply) String() string

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

+ func (m *GetLogsReply) XXX_DiscardUnknown()

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

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

+ func (m *GetLogsReply) XXX_Size() int

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

+ type GetLogsRequest struct

+ Body *GetLogsRequest_Body

+ func NewPopulatedGetLogsRequest(r randyNet, easy bool) *GetLogsRequest

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

+ func (*GetLogsRequest) ProtoMessage()

+ func (m *GetLogsRequest) GetBody() *GetLogsRequest_Body

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

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

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

+ func (m *GetLogsRequest) Reset()

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

+ func (m *GetLogsRequest) String() string

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

+ func (m *GetLogsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetLogsRequest) XXX_Size() int

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

+ type GetLogsRequest_Body struct

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

+ func NewPopulatedGetLogsRequest_Body(r randyNet, easy bool) *GetLogsRequest_Body

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

+ func (*GetLogsRequest_Body) ProtoMessage()

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

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

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

+ func (m *GetLogsRequest_Body) Reset()

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

+ func (m *GetLogsRequest_Body) String() string

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

+ func (m *GetLogsRequest_Body) XXX_DiscardUnknown()

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

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

+ func (m *GetLogsRequest_Body) XXX_Size() int

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

+ type GetRecordsReply struct

+ Logs []*GetRecordsReply_LogEntry

+ func NewPopulatedGetRecordsReply(r randyNet, easy bool) *GetRecordsReply

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

+ func (*GetRecordsReply) ProtoMessage()

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

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

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

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

+ func (m *GetRecordsReply) Reset()

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

+ func (m *GetRecordsReply) String() string

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

+ func (m *GetRecordsReply) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsReply) XXX_Size() int

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

+ type GetRecordsReply_LogEntry struct

+ Log *Log

+ LogID *ProtoPeerID

+ Records []*Log_Record

+ func NewPopulatedGetRecordsReply_LogEntry(r randyNet, easy bool) *GetRecordsReply_LogEntry

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

+ func (*GetRecordsReply_LogEntry) ProtoMessage()

+ func (m *GetRecordsReply_LogEntry) GetLog() *Log

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

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

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

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

+ func (m *GetRecordsReply_LogEntry) Reset()

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

+ func (m *GetRecordsReply_LogEntry) String() string

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

+ func (m *GetRecordsReply_LogEntry) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsReply_LogEntry) XXX_Size() int

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

+ type GetRecordsRequest struct

+ Body *GetRecordsRequest_Body

+ func NewPopulatedGetRecordsRequest(r randyNet, easy bool) *GetRecordsRequest

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

+ func (*GetRecordsRequest) ProtoMessage()

+ func (m *GetRecordsRequest) GetBody() *GetRecordsRequest_Body

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

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

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

+ func (m *GetRecordsRequest) Reset()

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

+ func (m *GetRecordsRequest) String() string

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

+ func (m *GetRecordsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsRequest) XXX_Size() int

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

+ type GetRecordsRequest_Body struct

+ Logs []*GetRecordsRequest_Body_LogEntry

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

+ func NewPopulatedGetRecordsRequest_Body(r randyNet, easy bool) *GetRecordsRequest_Body

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

+ func (*GetRecordsRequest_Body) ProtoMessage()

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

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

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

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

+ func (m *GetRecordsRequest_Body) Reset()

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

+ func (m *GetRecordsRequest_Body) String() string

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

+ func (m *GetRecordsRequest_Body) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsRequest_Body) XXX_Size() int

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

+ type GetRecordsRequest_Body_LogEntry struct

+ Counter int64

+ Limit int32

+ LogID *ProtoPeerID

+ Offset *ProtoCid

+ func NewPopulatedGetRecordsRequest_Body_LogEntry(r randyNet, easy bool) *GetRecordsRequest_Body_LogEntry

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

+ func (*GetRecordsRequest_Body_LogEntry) ProtoMessage()

+ func (m *GetRecordsRequest_Body_LogEntry) GetCounter() int64

+ func (m *GetRecordsRequest_Body_LogEntry) GetLimit() int32

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

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

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

+ func (m *GetRecordsRequest_Body_LogEntry) Reset()

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

+ func (m *GetRecordsRequest_Body_LogEntry) String() string

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

+ func (m *GetRecordsRequest_Body_LogEntry) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsRequest_Body_LogEntry) XXX_Size() int

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

+ type HeadBookRecord struct

+ Heads []*HeadBookRecord_HeadEntry

+ func NewPopulatedHeadBookRecord(r randyLstore, easy bool) *HeadBookRecord

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

+ func (*HeadBookRecord) ProtoMessage()

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

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

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

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

+ func (m *HeadBookRecord) Reset()

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

+ func (m *HeadBookRecord) String() string

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

+ func (m *HeadBookRecord) XXX_DiscardUnknown()

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

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

+ func (m *HeadBookRecord) XXX_Size() int

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

+ type HeadBookRecord_HeadEntry struct

+ Cid *ProtoCid

+ Counter int64

+ func NewPopulatedHeadBookRecord_HeadEntry(r randyLstore, easy bool) *HeadBookRecord_HeadEntry

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

+ func (*HeadBookRecord_HeadEntry) ProtoMessage()

+ func (m *HeadBookRecord_HeadEntry) GetCounter() int64

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

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

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

+ func (m *HeadBookRecord_HeadEntry) Reset()

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

+ func (m *HeadBookRecord_HeadEntry) String() string

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

+ func (m *HeadBookRecord_HeadEntry) XXX_DiscardUnknown()

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

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

+ func (m *HeadBookRecord_HeadEntry) XXX_Size() int

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

+ type Log struct

+ Addrs []ProtoAddr

+ Counter int64

+ Head *ProtoCid

+ ID *ProtoPeerID

+ PubKey *ProtoPubKey

+ func NewPopulatedLog(r randyNet, easy bool) *Log

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

+ func (*Log) ProtoMessage()

+ func (m *Log) GetCounter() int64

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

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

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

+ func (m *Log) Reset()

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

+ func (m *Log) String() string

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

+ func (m *Log) XXX_DiscardUnknown()

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

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

+ func (m *Log) XXX_Size() int

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

+ type Log_Record struct

+ BodyNode []byte

+ EventNode []byte

+ HeaderNode []byte

+ RecordNode []byte

+ func NewPopulatedLog_Record(r randyNet, easy bool) *Log_Record

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

+ func (*Log_Record) ProtoMessage()

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

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

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

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

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

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

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

+ func (m *Log_Record) Reset()

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

+ func (m *Log_Record) String() string

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

+ func (m *Log_Record) XXX_DiscardUnknown()

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

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

+ func (m *Log_Record) XXX_Size() int

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

+ type ProtoAddr struct

+ func NewPopulatedProtoAddr(_ randyNet) *ProtoAddr

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

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

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

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

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

+ func (a ProtoAddr) Size() int

+ type ProtoCid struct

+ func NewPopulatedProtoCid(_ randyNet) *ProtoCid

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

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

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

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

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

+ func (c ProtoCid) Size() int

+ type ProtoKey struct

+ func NewPopulatedProtoKey(_ randyNet) *ProtoKey

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

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

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

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

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

+ func (k ProtoKey) Size() int

+ type ProtoPeerID struct

+ func NewPopulatedProtoPeerID(_ randyNet) *ProtoPeerID

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

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

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

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

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

+ func (id ProtoPeerID) Size() int

+ type ProtoPrivKey struct

+ func NewPopulatedProtoPrivKey(_ randyNet) *ProtoPrivKey

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

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

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

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

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

+ func (k ProtoPrivKey) Size() int

+ type ProtoPubKey struct

+ func NewPopulatedProtoPubKey(_ randyNet) *ProtoPubKey

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

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

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

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

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

+ func (k ProtoPubKey) Size() int

+ type ProtoThreadID struct

+ func NewPopulatedProtoThreadID(_ randyNet) *ProtoThreadID

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

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

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

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

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

+ func (id ProtoThreadID) Size() int

+ type PushLogReply struct

+ func NewPopulatedPushLogReply(r randyNet, easy bool) *PushLogReply

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

+ func (*PushLogReply) ProtoMessage()

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

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

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

+ func (m *PushLogReply) Reset()

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

+ func (m *PushLogReply) String() string

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

+ func (m *PushLogReply) XXX_DiscardUnknown()

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

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

+ func (m *PushLogReply) XXX_Size() int

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

+ type PushLogRequest struct

+ Body *PushLogRequest_Body

+ func NewPopulatedPushLogRequest(r randyNet, easy bool) *PushLogRequest

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

+ func (*PushLogRequest) ProtoMessage()

+ func (m *PushLogRequest) GetBody() *PushLogRequest_Body

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

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

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

+ func (m *PushLogRequest) Reset()

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

+ func (m *PushLogRequest) String() string

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

+ func (m *PushLogRequest) XXX_DiscardUnknown()

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

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

+ func (m *PushLogRequest) XXX_Size() int

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

+ type PushLogRequest_Body struct

+ Log *Log

+ ReadKey *ProtoKey

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

+ func NewPopulatedPushLogRequest_Body(r randyNet, easy bool) *PushLogRequest_Body

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

+ func (*PushLogRequest_Body) ProtoMessage()

+ func (m *PushLogRequest_Body) GetLog() *Log

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

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

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

+ func (m *PushLogRequest_Body) Reset()

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

+ func (m *PushLogRequest_Body) String() string

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

+ func (m *PushLogRequest_Body) XXX_DiscardUnknown()

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

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

+ func (m *PushLogRequest_Body) XXX_Size() int

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

+ type PushRecordReply struct

+ func NewPopulatedPushRecordReply(r randyNet, easy bool) *PushRecordReply

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

+ func (*PushRecordReply) ProtoMessage()

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

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

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

+ func (m *PushRecordReply) Reset()

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

+ func (m *PushRecordReply) String() string

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

+ func (m *PushRecordReply) XXX_DiscardUnknown()

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

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

+ func (m *PushRecordReply) XXX_Size() int

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

+ type PushRecordRequest struct

+ Body *PushRecordRequest_Body

+ Counter int64

+ func NewPopulatedPushRecordRequest(r randyNet, easy bool) *PushRecordRequest

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

+ func (*PushRecordRequest) ProtoMessage()

+ func (m *PushRecordRequest) GetBody() *PushRecordRequest_Body

+ func (m *PushRecordRequest) GetCounter() int64

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

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

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

+ func (m *PushRecordRequest) Reset()

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

+ func (m *PushRecordRequest) String() string

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

+ func (m *PushRecordRequest) XXX_DiscardUnknown()

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

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

+ func (m *PushRecordRequest) XXX_Size() int

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

+ type PushRecordRequest_Body struct

+ LogID *ProtoPeerID

+ Record *Log_Record

+ ThreadID *ProtoThreadID

+ func NewPopulatedPushRecordRequest_Body(r randyNet, easy bool) *PushRecordRequest_Body

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

+ func (*PushRecordRequest_Body) ProtoMessage()

+ func (m *PushRecordRequest_Body) GetRecord() *Log_Record

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

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

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

+ func (m *PushRecordRequest_Body) Reset()

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

+ func (m *PushRecordRequest_Body) String() string

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

+ func (m *PushRecordRequest_Body) XXX_DiscardUnknown()

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

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

+ func (m *PushRecordRequest_Body) XXX_Size() int

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

+ type ServiceClient interface

+ ExchangeEdges func(ctx context.Context, in *ExchangeEdgesRequest, opts ...grpc.CallOption) (*ExchangeEdgesReply, error)

+ GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsReply, error)

+ GetRecords func(ctx context.Context, in *GetRecordsRequest, opts ...grpc.CallOption) (*GetRecordsReply, error)

+ PushLog func(ctx context.Context, in *PushLogRequest, opts ...grpc.CallOption) (*PushLogReply, error)

+ PushRecord func(ctx context.Context, in *PushRecordRequest, opts ...grpc.CallOption) (*PushRecordReply, error)

+ func NewServiceClient(cc *grpc.ClientConn) ServiceClient

+ type ServiceServer interface

+ ExchangeEdges func(context.Context, *ExchangeEdgesRequest) (*ExchangeEdgesReply, error)

+ GetLogs func(context.Context, *GetLogsRequest) (*GetLogsReply, error)

+ GetRecords func(context.Context, *GetRecordsRequest) (*GetRecordsReply, error)

+ PushLog func(context.Context, *PushLogRequest) (*PushLogReply, error)

+ PushRecord func(context.Context, *PushRecordRequest) (*PushRecordReply, error)

+ type UnimplementedServiceServer struct

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

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

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

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

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