service_pb

package
v0.1.10 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2020 License: MIT Imports: 17 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")
)
View Source 
var (
	ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService   = fmt.Errorf("proto: integer overflow")
)

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) 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) 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 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 randyService, 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) 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 {
	// header is the message header.
	Header *GetLogsRequest_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,2,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// followKey for the thread.
	FollowKey *ProtoKey `protobuf:"bytes,3,opt,name=followKey,proto3,customtype=ProtoKey" json:"followKey,omitempty"`
}

GetLogsRequest is used to request thread logs.

func NewPopulatedGetLogsRequest 

func NewPopulatedGetLogsRequest(r randyService, easy bool) *GetLogsRequest

func (*GetLogsRequest) Descriptor 

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

func (*GetLogsRequest) GetHeader 

func (m *GetLogsRequest) GetHeader() *GetLogsRequest_Header

func (*GetLogsRequest) Marshal 

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

func (*GetLogsRequest) MarshalTo 

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

type GetLogsRequest_Header struct {
	From *ProtoPeerID `protobuf:"bytes,1,opt,name=from,proto3,customtype=ProtoPeerID" json:"from,omitempty"`
}

Header holds sender information.

func NewPopulatedGetLogsRequest_Header 

func NewPopulatedGetLogsRequest_Header(r randyService, easy bool) *GetLogsRequest_Header

func (*GetLogsRequest_Header) Descriptor 

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

func (*GetLogsRequest_Header) Marshal 

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

func (*GetLogsRequest_Header) MarshalTo 

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

func (*GetLogsRequest_Header) ProtoMessage 

func (*GetLogsRequest_Header) ProtoMessage()

func (*GetLogsRequest_Header) Reset 

func (m *GetLogsRequest_Header) Reset()

func (*GetLogsRequest_Header) Size 

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

func (*GetLogsRequest_Header) String 

func (m *GetLogsRequest_Header) String() string

func (*GetLogsRequest_Header) Unmarshal 

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

func (*GetLogsRequest_Header) XXX_DiscardUnknown 

func (m *GetLogsRequest_Header) XXX_DiscardUnknown()

func (*GetLogsRequest_Header) XXX_Marshal 

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

func (*GetLogsRequest_Header) XXX_Merge 

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

func (*GetLogsRequest_Header) XXX_Size 

func (m *GetLogsRequest_Header) XXX_Size() int

func (*GetLogsRequest_Header) XXX_Unmarshal 

func (m *GetLogsRequest_Header) 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 randyService, 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) 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 randyService, 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) 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 {
	// header is the message header.
	Header *GetRecordsRequest_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,2,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// followKey for the thread.
	FollowKey *ProtoKey `protobuf:"bytes,3,opt,name=followKey,proto3,customtype=ProtoKey" json:"followKey,omitempty"`
	// List of requested logs.
	Logs []*GetRecordsRequest_LogEntry `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
}

GetRecordsRequest is used to request records from a log address.

func NewPopulatedGetRecordsRequest 

func NewPopulatedGetRecordsRequest(r randyService, easy bool) *GetRecordsRequest

func (*GetRecordsRequest) Descriptor 

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

func (*GetRecordsRequest) GetHeader 

func (m *GetRecordsRequest) GetHeader() *GetRecordsRequest_Header

func (*GetRecordsRequest) GetLogs 

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

func (*GetRecordsRequest) Marshal 

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

func (*GetRecordsRequest) MarshalTo 

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

type GetRecordsRequest_Header struct {
	From *ProtoPeerID `protobuf:"bytes,1,opt,name=from,proto3,customtype=ProtoPeerID" json:"from,omitempty"`
}

Header holds sender information.

func NewPopulatedGetRecordsRequest_Header 

func NewPopulatedGetRecordsRequest_Header(r randyService, easy bool) *GetRecordsRequest_Header

func (*GetRecordsRequest_Header) Descriptor 

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

func (*GetRecordsRequest_Header) Marshal 

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

func (*GetRecordsRequest_Header) MarshalTo 

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

func (*GetRecordsRequest_Header) ProtoMessage 

func (*GetRecordsRequest_Header) ProtoMessage()

func (*GetRecordsRequest_Header) Reset 

func (m *GetRecordsRequest_Header) Reset()

func (*GetRecordsRequest_Header) Size 

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

func (*GetRecordsRequest_Header) String 

func (m *GetRecordsRequest_Header) String() string

func (*GetRecordsRequest_Header) Unmarshal 

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

func (*GetRecordsRequest_Header) XXX_DiscardUnknown 

func (m *GetRecordsRequest_Header) XXX_DiscardUnknown()

func (*GetRecordsRequest_Header) XXX_Marshal 

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

func (*GetRecordsRequest_Header) XXX_Merge 

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

func (*GetRecordsRequest_Header) XXX_Size 

func (m *GetRecordsRequest_Header) XXX_Size() int

func (*GetRecordsRequest_Header) XXX_Unmarshal 

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

type GetRecordsRequest_LogEntry 

type GetRecordsRequest_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"`
}

LogEntry represents a single log.

func NewPopulatedGetRecordsRequest_LogEntry 

func NewPopulatedGetRecordsRequest_LogEntry(r randyService, easy bool) *GetRecordsRequest_LogEntry

func (*GetRecordsRequest_LogEntry) Descriptor 

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

func (*GetRecordsRequest_LogEntry) GetLimit 

func (m *GetRecordsRequest_LogEntry) GetLimit() int32

func (*GetRecordsRequest_LogEntry) Marshal 

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

func (*GetRecordsRequest_LogEntry) MarshalTo 

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

func (*GetRecordsRequest_LogEntry) ProtoMessage 

func (*GetRecordsRequest_LogEntry) ProtoMessage()

func (*GetRecordsRequest_LogEntry) Reset 

func (m *GetRecordsRequest_LogEntry) Reset()

func (*GetRecordsRequest_LogEntry) Size 

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

func (*GetRecordsRequest_LogEntry) String 

func (m *GetRecordsRequest_LogEntry) String() string

func (*GetRecordsRequest_LogEntry) Unmarshal 

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

func (*GetRecordsRequest_LogEntry) XXX_DiscardUnknown 

func (m *GetRecordsRequest_LogEntry) XXX_DiscardUnknown()

func (*GetRecordsRequest_LogEntry) XXX_Marshal 

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

func (*GetRecordsRequest_LogEntry) XXX_Merge 

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

func (*GetRecordsRequest_LogEntry) XXX_Size 

func (m *GetRecordsRequest_LogEntry) XXX_Size() int

func (*GetRecordsRequest_LogEntry) XXX_Unmarshal 

func (m *GetRecordsRequest_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) 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"`
}

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) 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) 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"`
	// heads of the log.
	Heads []ProtoCid `protobuf:"bytes,4,rep,name=heads,proto3,customtype=ProtoCid" json:"heads,omitempty"`
}

Log represents a thread log.

func NewPopulatedLog 

func NewPopulatedLog(r randyService, easy bool) *Log

func (*Log) Descriptor 

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

func (*Log) Marshal 

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

func (*Log) MarshalTo 

func (m *Log) MarshalTo(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 randyService, 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) 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(r randyService) *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(r randyService) *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 {
	*symmetric.Key
}

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

func NewPopulatedProtoKey 

func NewPopulatedProtoKey(r randyService) *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(r randyService) *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(r randyService) *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(r randyService) *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(r randyService) *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 randyService, 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) 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 {
	// header is the message header.
	Header *PushLogRequest_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,2,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// followKey for the thread.
	FollowKey *ProtoKey `protobuf:"bytes,3,opt,name=followKey,proto3,customtype=ProtoKey" json:"followKey,omitempty"`
	// readKey for the thread.
	ReadKey *ProtoKey `protobuf:"bytes,4,opt,name=readKey,proto3,customtype=ProtoKey" json:"readKey,omitempty"`
	// log is the actual log payload.
	Log *Log `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
}

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

func NewPopulatedPushLogRequest 

func NewPopulatedPushLogRequest(r randyService, easy bool) *PushLogRequest

func (*PushLogRequest) Descriptor 

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

func (*PushLogRequest) GetHeader 

func (m *PushLogRequest) GetHeader() *PushLogRequest_Header

func (*PushLogRequest) GetLog 

func (m *PushLogRequest) GetLog() *Log

func (*PushLogRequest) Marshal 

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

func (*PushLogRequest) MarshalTo 

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

type PushLogRequest_Header struct {
	From *ProtoPeerID `protobuf:"bytes,1,opt,name=from,proto3,customtype=ProtoPeerID" json:"from,omitempty"`
}

Header holds sender information.

func NewPopulatedPushLogRequest_Header 

func NewPopulatedPushLogRequest_Header(r randyService, easy bool) *PushLogRequest_Header

func (*PushLogRequest_Header) Descriptor 

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

func (*PushLogRequest_Header) Marshal 

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

func (*PushLogRequest_Header) MarshalTo 

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

func (*PushLogRequest_Header) ProtoMessage 

func (*PushLogRequest_Header) ProtoMessage()

func (*PushLogRequest_Header) Reset 

func (m *PushLogRequest_Header) Reset()

func (*PushLogRequest_Header) Size 

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

func (*PushLogRequest_Header) String 

func (m *PushLogRequest_Header) String() string

func (*PushLogRequest_Header) Unmarshal 

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

func (*PushLogRequest_Header) XXX_DiscardUnknown 

func (m *PushLogRequest_Header) XXX_DiscardUnknown()

func (*PushLogRequest_Header) XXX_Marshal 

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

func (*PushLogRequest_Header) XXX_Merge 

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

func (*PushLogRequest_Header) XXX_Size 

func (m *PushLogRequest_Header) XXX_Size() int

func (*PushLogRequest_Header) XXX_Unmarshal 

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

type PushRecordReply 

type PushRecordReply struct {
}

PushRecordReply is the response from a PushRecordRequest.

func NewPopulatedPushRecordReply 

func NewPopulatedPushRecordReply(r randyService, 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) 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 {
	// header is the header message.
	Header *PushRecordRequest_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// threadID is the target thread's ID.
	ThreadID *ProtoThreadID `protobuf:"bytes,2,opt,name=threadID,proto3,customtype=ProtoThreadID" json:"threadID,omitempty"`
	// logID is the target log's ID.
	LogID *ProtoPeerID `protobuf:"bytes,3,opt,name=logID,proto3,customtype=ProtoPeerID" json:"logID,omitempty"`
	// record is the actual record payload.
	Record *Log_Record `protobuf:"bytes,4,opt,name=record,proto3" json:"record,omitempty"`
}

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

func NewPopulatedPushRecordRequest 

func NewPopulatedPushRecordRequest(r randyService, easy bool) *PushRecordRequest

func (*PushRecordRequest) Descriptor 

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

func (*PushRecordRequest) GetHeader 

func (m *PushRecordRequest) GetHeader() *PushRecordRequest_Header

func (*PushRecordRequest) GetRecord 

func (m *PushRecordRequest) GetRecord() *Log_Record

func (*PushRecordRequest) Marshal 

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

func (*PushRecordRequest) MarshalTo 

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

type PushRecordRequest_Header struct {
	// from is the sender's peerID.
	From *ProtoPeerID `protobuf:"bytes,1,opt,name=from,proto3,customtype=ProtoPeerID" json:"from,omitempty"`
	// signature is the signature of the payload.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// key is the sender's public key used to sign the payload.
	Key *ProtoPubKey `protobuf:"bytes,3,opt,name=key,proto3,customtype=ProtoPubKey" json:"key,omitempty"`
}

Header holds sender and key information.

func NewPopulatedPushRecordRequest_Header 

func NewPopulatedPushRecordRequest_Header(r randyService, easy bool) *PushRecordRequest_Header

func (*PushRecordRequest_Header) Descriptor 

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

func (*PushRecordRequest_Header) GetSignature 

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

func (*PushRecordRequest_Header) Marshal 

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

func (*PushRecordRequest_Header) MarshalTo 

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

func (*PushRecordRequest_Header) ProtoMessage 

func (*PushRecordRequest_Header) ProtoMessage()

func (*PushRecordRequest_Header) Reset 

func (m *PushRecordRequest_Header) Reset()

func (*PushRecordRequest_Header) Size 

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

func (*PushRecordRequest_Header) String 

func (m *PushRecordRequest_Header) String() string

func (*PushRecordRequest_Header) Unmarshal 

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

func (*PushRecordRequest_Header) XXX_DiscardUnknown 

func (m *PushRecordRequest_Header) XXX_DiscardUnknown()

func (*PushRecordRequest_Header) XXX_Marshal 

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

func (*PushRecordRequest_Header) XXX_Merge 

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

func (*PushRecordRequest_Header) XXX_Size 

func (m *PushRecordRequest_Header) XXX_Size() int

func (*PushRecordRequest_Header) XXX_Unmarshal 

func (m *PushRecordRequest_Header) 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)
}

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

ServiceServer is the server API for Service service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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