net_pb

Aug 21, 2021

Changes in this version

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

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

type AddrBookRecord

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

type AddrBookRecord_AddrEntry

+ func (m *AddrBookRecord_AddrEntry) MarshalToSizedBuffer(dAtA []byte) (int, 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

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

type GetLogsRequest

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

type GetLogsRequest_Body

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

type GetRecordsReply

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

type GetRecordsReply_LogEntry

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

type GetRecordsRequest

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

type GetRecordsRequest_Body

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

type GetRecordsRequest_Body_LogEntry

+ Counter int64

+ func (m *GetRecordsRequest_Body_LogEntry) GetCounter() int64

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

type HeadBookRecord

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

type HeadBookRecord_HeadEntry

+ Counter int64

+ func (m *HeadBookRecord_HeadEntry) GetCounter() int64

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

type Log

+ Counter int64

+ func (m *Log) GetCounter() int64

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

type Log_Record

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

type PushLogReply

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

type PushLogRequest

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

type PushLogRequest_Body

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

type PushRecordReply

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

type PushRecordRequest

+ Counter int64

+ func (m *PushRecordRequest) GetCounter() int64

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

type PushRecordRequest_Body

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

type ServiceClient

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

type ServiceServer

+ ExchangeEdges func(context.Context, *ExchangeEdgesRequest) (*ExchangeEdgesReply, 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)

Apr 4, 2020

Changes in this version

type GetLogsRequest

+ Body *GetLogsRequest_Body

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

+ 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) 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 GetRecordsRequest

+ Body *GetRecordsRequest_Body

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

+ 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) 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

+ 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) 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) 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 Header struct

+ PubKey *ProtoPubKey

+ Signature []byte

+ func NewPopulatedHeader(r randyNet, easy bool) *Header

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

+ func (*Header) ProtoMessage()

+ func (m *Header) GetSignature() []byte

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

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

+ func (m *Header) Reset()

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

+ func (m *Header) String() string

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

+ func (m *Header) XXX_DiscardUnknown()

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

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

+ func (m *Header) XXX_Size() int

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

type Log

+ Head *ProtoCid

type PushLogRequest

+ Body *PushLogRequest_Body

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

+ 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) 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 PushRecordRequest

+ Body *PushRecordRequest_Body

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

+ 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) 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

Mar 19, 2020

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")

+ 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) 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) 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 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) 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

+ Header *GetLogsRequest_Header

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

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

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

+ func (*GetLogsRequest) ProtoMessage()

+ func (m *GetLogsRequest) GetHeader() *GetLogsRequest_Header

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

+ func (m *GetLogsRequest) MarshalTo(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_Header struct

+ From *ProtoPeerID

+ func NewPopulatedGetLogsRequest_Header(r randyNet, easy bool) *GetLogsRequest_Header

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

+ func (*GetLogsRequest_Header) ProtoMessage()

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

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

+ func (m *GetLogsRequest_Header) Reset()

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

+ func (m *GetLogsRequest_Header) String() string

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

+ func (m *GetLogsRequest_Header) XXX_DiscardUnknown()

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

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

+ func (m *GetLogsRequest_Header) XXX_Size() int

+ func (m *GetLogsRequest_Header) 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) 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) 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

+ Header *GetRecordsRequest_Header

+ Logs []*GetRecordsRequest_LogEntry

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

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

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

+ func (*GetRecordsRequest) ProtoMessage()

+ func (m *GetRecordsRequest) GetHeader() *GetRecordsRequest_Header

+ func (m *GetRecordsRequest) GetLogs() []*GetRecordsRequest_LogEntry

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

+ func (m *GetRecordsRequest) MarshalTo(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_Header struct

+ From *ProtoPeerID

+ func NewPopulatedGetRecordsRequest_Header(r randyNet, easy bool) *GetRecordsRequest_Header

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

+ func (*GetRecordsRequest_Header) ProtoMessage()

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

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

+ func (m *GetRecordsRequest_Header) Reset()

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

+ func (m *GetRecordsRequest_Header) String() string

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

+ func (m *GetRecordsRequest_Header) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsRequest_Header) XXX_Size() int

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

+ type GetRecordsRequest_LogEntry struct

+ Limit int32

+ LogID *ProtoPeerID

+ Offset *ProtoCid

+ func NewPopulatedGetRecordsRequest_LogEntry(r randyNet, easy bool) *GetRecordsRequest_LogEntry

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

+ func (*GetRecordsRequest_LogEntry) ProtoMessage()

+ func (m *GetRecordsRequest_LogEntry) GetLimit() int32

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

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

+ func (m *GetRecordsRequest_LogEntry) Reset()

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

+ func (m *GetRecordsRequest_LogEntry) String() string

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

+ func (m *GetRecordsRequest_LogEntry) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordsRequest_LogEntry) XXX_Size() int

+ func (m *GetRecordsRequest_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) 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

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

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

+ func (*HeadBookRecord_HeadEntry) ProtoMessage()

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

+ func (m *HeadBookRecord_HeadEntry) MarshalTo(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

+ Heads []ProtoCid

+ ID *ProtoPeerID

+ PubKey *ProtoPubKey

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

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

+ func (*Log) ProtoMessage()

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

+ func (m *Log) MarshalTo(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) 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) 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

+ Header *PushLogRequest_Header

+ Log *Log

+ ReadKey *ProtoKey

+ ServiceKey *ProtoKey

+ ThreadID *ProtoThreadID

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

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

+ func (*PushLogRequest) ProtoMessage()

+ func (m *PushLogRequest) GetHeader() *PushLogRequest_Header

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

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

+ func (m *PushLogRequest) MarshalTo(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_Header struct

+ From *ProtoPeerID

+ func NewPopulatedPushLogRequest_Header(r randyNet, easy bool) *PushLogRequest_Header

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

+ func (*PushLogRequest_Header) ProtoMessage()

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

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

+ func (m *PushLogRequest_Header) Reset()

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

+ func (m *PushLogRequest_Header) String() string

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

+ func (m *PushLogRequest_Header) XXX_DiscardUnknown()

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

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

+ func (m *PushLogRequest_Header) XXX_Size() int

+ func (m *PushLogRequest_Header) 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) 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

+ Header *PushRecordRequest_Header

+ LogID *ProtoPeerID

+ Record *Log_Record

+ ThreadID *ProtoThreadID

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

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

+ func (*PushRecordRequest) ProtoMessage()

+ func (m *PushRecordRequest) GetHeader() *PushRecordRequest_Header

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

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

+ func (m *PushRecordRequest) MarshalTo(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_Header struct

+ From *ProtoPeerID

+ Key *ProtoPubKey

+ Signature []byte

+ func NewPopulatedPushRecordRequest_Header(r randyNet, easy bool) *PushRecordRequest_Header

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

+ func (*PushRecordRequest_Header) ProtoMessage()

+ func (m *PushRecordRequest_Header) GetSignature() []byte

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

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

+ func (m *PushRecordRequest_Header) Reset()

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

+ func (m *PushRecordRequest_Header) String() string

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

+ func (m *PushRecordRequest_Header) XXX_DiscardUnknown()

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

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

+ func (m *PushRecordRequest_Header) XXX_Size() int

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

+ type ServiceClient interface

+ 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

+ 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)