threads_net_pb

Aug 22, 2021

Changes in this version

+ var API_ServiceDesc = grpc.ServiceDesc

+ var File_threadsnet_proto protoreflect.FileDescriptor

type AddRecordReply

+ func (x *AddRecordReply) ProtoReflect() protoreflect.Message

type AddRecordRequest

+ func (x *AddRecordRequest) ProtoReflect() protoreflect.Message

type AddReplicatorReply

+ func (x *AddReplicatorReply) ProtoReflect() protoreflect.Message

type AddReplicatorRequest

+ func (x *AddReplicatorRequest) ProtoReflect() protoreflect.Message

type AddThreadRequest

+ func (x *AddThreadRequest) ProtoReflect() protoreflect.Message

type CreateRecordRequest

+ func (x *CreateRecordRequest) ProtoReflect() protoreflect.Message

type CreateThreadRequest

+ func (x *CreateThreadRequest) ProtoReflect() protoreflect.Message

type DeleteThreadReply

+ func (x *DeleteThreadReply) ProtoReflect() protoreflect.Message

type DeleteThreadRequest

+ func (x *DeleteThreadRequest) ProtoReflect() protoreflect.Message

type GetHostIDReply

+ func (x *GetHostIDReply) ProtoReflect() protoreflect.Message

type GetHostIDRequest

+ func (x *GetHostIDRequest) ProtoReflect() protoreflect.Message

type GetRecordReply

+ func (x *GetRecordReply) ProtoReflect() protoreflect.Message

type GetRecordRequest

+ func (x *GetRecordRequest) ProtoReflect() protoreflect.Message

type GetThreadRequest

+ func (x *GetThreadRequest) ProtoReflect() protoreflect.Message

type GetTokenReply

+ func (x *GetTokenReply) ProtoReflect() protoreflect.Message

type GetTokenRequest

+ func (x *GetTokenRequest) ProtoReflect() protoreflect.Message

type Keys

+ func (x *Keys) ProtoReflect() protoreflect.Message

type LogInfo

+ func (x *LogInfo) ProtoReflect() protoreflect.Message

type NewRecordReply

+ func (x *NewRecordReply) ProtoReflect() protoreflect.Message

type PullThreadReply

+ func (x *PullThreadReply) ProtoReflect() protoreflect.Message

type PullThreadRequest

+ func (x *PullThreadRequest) ProtoReflect() protoreflect.Message

type Record

+ func (x *Record) ProtoReflect() protoreflect.Message

type SubscribeRequest

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

type ThreadInfoReply

+ func (x *ThreadInfoReply) ProtoReflect() protoreflect.Message

+ type UnsafeAPIServer interface

Aug 21, 2021

Changes in this version

type LogInfo

+ Counter []byte

+ func (m *LogInfo) GetCounter() []byte

Apr 4, 2020

Changes in this version

type APIClient

+ GetToken func(ctx context.Context, opts ...grpc.CallOption) (API_GetTokenClient, error)

type APIServer

+ GetToken func(API_GetTokenServer) error

+ type API_GetTokenClient interface

+ Recv func() (*GetTokenReply, error)

+ Send func(*GetTokenRequest) error

+ type API_GetTokenServer interface

+ Recv func() (*GetTokenRequest, error)

+ Send func(*GetTokenReply) error

+ type GetTokenReply struct

+ Payload isGetTokenReply_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetTokenReply) ProtoMessage()

+ func (*GetTokenReply) XXX_OneofWrappers() []interface{}

+ func (m *GetTokenReply) GetChallenge() []byte

+ func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload

+ func (m *GetTokenReply) GetToken() string

+ func (m *GetTokenReply) Reset()

+ func (m *GetTokenReply) String() string

+ func (m *GetTokenReply) XXX_DiscardUnknown()

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

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

+ func (m *GetTokenReply) XXX_Size() int

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

+ type GetTokenReply_Challenge struct

+ Challenge []byte

+ type GetTokenReply_Token struct

+ Token string

+ type GetTokenRequest struct

+ Payload isGetTokenRequest_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetTokenRequest) ProtoMessage()

+ func (*GetTokenRequest) XXX_OneofWrappers() []interface{}

+ func (m *GetTokenRequest) GetKey() string

+ func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload

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

+ func (m *GetTokenRequest) Reset()

+ func (m *GetTokenRequest) String() string

+ func (m *GetTokenRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetTokenRequest) XXX_Size() int

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

+ type GetTokenRequest_Key struct

+ Key string

+ type GetTokenRequest_Signature struct

+ Signature []byte

type LogInfo

+ Head []byte

+ func (m *LogInfo) GetHead() []byte

type ThreadInfoReply

+ Addrs [][]byte

+ ThreadID []byte

+ func (m *ThreadInfoReply) GetAddrs() [][]byte

+ func (m *ThreadInfoReply) GetThreadID() []byte

type UnimplementedAPIServer

+ func (*UnimplementedAPIServer) GetToken(srv API_GetTokenServer) error

Mar 19, 2020

Changes in this version

+ func RegisterAPIServer(s *grpc.Server, srv APIServer)

+ type APIClient interface

+ AddRecord func(ctx context.Context, in *AddRecordRequest, opts ...grpc.CallOption) (*AddRecordReply, error)

+ AddReplicator func(ctx context.Context, in *AddReplicatorRequest, opts ...grpc.CallOption) (*AddReplicatorReply, error)

+ AddThread func(ctx context.Context, in *AddThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)

+ CreateRecord func(ctx context.Context, in *CreateRecordRequest, opts ...grpc.CallOption) (*NewRecordReply, error)

+ CreateThread func(ctx context.Context, in *CreateThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)

+ DeleteThread func(ctx context.Context, in *DeleteThreadRequest, opts ...grpc.CallOption) (*DeleteThreadReply, error)

+ GetHostID func(ctx context.Context, in *GetHostIDRequest, opts ...grpc.CallOption) (*GetHostIDReply, error)

+ GetRecord func(ctx context.Context, in *GetRecordRequest, opts ...grpc.CallOption) (*GetRecordReply, error)

+ GetThread func(ctx context.Context, in *GetThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)

+ PullThread func(ctx context.Context, in *PullThreadRequest, opts ...grpc.CallOption) (*PullThreadReply, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ AddRecord func(context.Context, *AddRecordRequest) (*AddRecordReply, error)

+ AddReplicator func(context.Context, *AddReplicatorRequest) (*AddReplicatorReply, error)

+ AddThread func(context.Context, *AddThreadRequest) (*ThreadInfoReply, error)

+ CreateRecord func(context.Context, *CreateRecordRequest) (*NewRecordReply, error)

+ CreateThread func(context.Context, *CreateThreadRequest) (*ThreadInfoReply, error)

+ DeleteThread func(context.Context, *DeleteThreadRequest) (*DeleteThreadReply, error)

+ GetHostID func(context.Context, *GetHostIDRequest) (*GetHostIDReply, error)

+ GetRecord func(context.Context, *GetRecordRequest) (*GetRecordReply, error)

+ GetThread func(context.Context, *GetThreadRequest) (*ThreadInfoReply, error)

+ PullThread func(context.Context, *PullThreadRequest) (*PullThreadReply, error)

+ Subscribe func(*SubscribeRequest, API_SubscribeServer) error

+ type API_SubscribeClient interface

+ Recv func() (*NewRecordReply, error)

+ type API_SubscribeServer interface

+ Send func(*NewRecordReply) error

+ type AddRecordReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AddRecordReply) ProtoMessage()

+ func (m *AddRecordReply) Reset()

+ func (m *AddRecordReply) String() string

+ func (m *AddRecordReply) XXX_DiscardUnknown()

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

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

+ func (m *AddRecordReply) XXX_Size() int

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

+ type AddRecordRequest struct

+ LogID []byte

+ Record *Record

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AddRecordRequest) ProtoMessage()

+ func (m *AddRecordRequest) GetLogID() []byte

+ func (m *AddRecordRequest) GetRecord() *Record

+ func (m *AddRecordRequest) GetThreadID() []byte

+ func (m *AddRecordRequest) Reset()

+ func (m *AddRecordRequest) String() string

+ func (m *AddRecordRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddRecordRequest) XXX_Size() int

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

+ type AddReplicatorReply struct

+ PeerID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AddReplicatorReply) ProtoMessage()

+ func (m *AddReplicatorReply) GetPeerID() []byte

+ func (m *AddReplicatorReply) Reset()

+ func (m *AddReplicatorReply) String() string

+ func (m *AddReplicatorReply) XXX_DiscardUnknown()

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

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

+ func (m *AddReplicatorReply) XXX_Size() int

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

+ type AddReplicatorRequest struct

+ Addr []byte

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AddReplicatorRequest) ProtoMessage()

+ func (m *AddReplicatorRequest) GetAddr() []byte

+ func (m *AddReplicatorRequest) GetThreadID() []byte

+ func (m *AddReplicatorRequest) Reset()

+ func (m *AddReplicatorRequest) String() string

+ func (m *AddReplicatorRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddReplicatorRequest) XXX_Size() int

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

+ type AddThreadRequest struct

+ Addr []byte

+ Keys *Keys

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AddThreadRequest) ProtoMessage()

+ func (m *AddThreadRequest) GetAddr() []byte

+ func (m *AddThreadRequest) GetKeys() *Keys

+ func (m *AddThreadRequest) Reset()

+ func (m *AddThreadRequest) String() string

+ func (m *AddThreadRequest) XXX_DiscardUnknown()

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

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

+ func (m *AddThreadRequest) XXX_Size() int

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

+ type CreateRecordRequest struct

+ Body []byte

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateRecordRequest) ProtoMessage()

+ func (m *CreateRecordRequest) GetBody() []byte

+ func (m *CreateRecordRequest) GetThreadID() []byte

+ func (m *CreateRecordRequest) Reset()

+ func (m *CreateRecordRequest) String() string

+ func (m *CreateRecordRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateRecordRequest) XXX_Size() int

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

+ type CreateThreadRequest struct

+ Keys *Keys

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateThreadRequest) ProtoMessage()

+ func (m *CreateThreadRequest) GetKeys() *Keys

+ func (m *CreateThreadRequest) GetThreadID() []byte

+ func (m *CreateThreadRequest) Reset()

+ func (m *CreateThreadRequest) String() string

+ func (m *CreateThreadRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateThreadRequest) XXX_Size() int

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

+ type DeleteThreadReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteThreadReply) ProtoMessage()

+ func (m *DeleteThreadReply) Reset()

+ func (m *DeleteThreadReply) String() string

+ func (m *DeleteThreadReply) XXX_DiscardUnknown()

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

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

+ func (m *DeleteThreadReply) XXX_Size() int

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

+ type DeleteThreadRequest struct

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteThreadRequest) ProtoMessage()

+ func (m *DeleteThreadRequest) GetThreadID() []byte

+ func (m *DeleteThreadRequest) Reset()

+ func (m *DeleteThreadRequest) String() string

+ func (m *DeleteThreadRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteThreadRequest) XXX_Size() int

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

+ type GetHostIDReply struct

+ PeerID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetHostIDReply) ProtoMessage()

+ func (m *GetHostIDReply) GetPeerID() []byte

+ func (m *GetHostIDReply) Reset()

+ func (m *GetHostIDReply) String() string

+ func (m *GetHostIDReply) XXX_DiscardUnknown()

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

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

+ func (m *GetHostIDReply) XXX_Size() int

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

+ type GetHostIDRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetHostIDRequest) ProtoMessage()

+ func (m *GetHostIDRequest) Reset()

+ func (m *GetHostIDRequest) String() string

+ func (m *GetHostIDRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetHostIDRequest) XXX_Size() int

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

+ type GetRecordReply struct

+ Record *Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetRecordReply) ProtoMessage()

+ func (m *GetRecordReply) GetRecord() *Record

+ func (m *GetRecordReply) Reset()

+ func (m *GetRecordReply) String() string

+ func (m *GetRecordReply) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordReply) XXX_Size() int

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

+ type GetRecordRequest struct

+ RecordID []byte

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetRecordRequest) ProtoMessage()

+ func (m *GetRecordRequest) GetRecordID() []byte

+ func (m *GetRecordRequest) GetThreadID() []byte

+ func (m *GetRecordRequest) Reset()

+ func (m *GetRecordRequest) String() string

+ func (m *GetRecordRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetRecordRequest) XXX_Size() int

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

+ type GetThreadRequest struct

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetThreadRequest) ProtoMessage()

+ func (m *GetThreadRequest) GetThreadID() []byte

+ func (m *GetThreadRequest) Reset()

+ func (m *GetThreadRequest) String() string

+ func (m *GetThreadRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetThreadRequest) XXX_Size() int

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

+ type Keys struct

+ LogKey []byte

+ ThreadKey []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Keys) ProtoMessage()

+ func (m *Keys) GetLogKey() []byte

+ func (m *Keys) GetThreadKey() []byte

+ func (m *Keys) Reset()

+ func (m *Keys) String() string

+ func (m *Keys) XXX_DiscardUnknown()

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

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

+ func (m *Keys) XXX_Size() int

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

+ type LogInfo struct

+ Addrs [][]byte

+ Heads [][]byte

+ ID []byte

+ PrivKey []byte

+ PubKey []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LogInfo) ProtoMessage()

+ func (m *LogInfo) GetAddrs() [][]byte

+ func (m *LogInfo) GetHeads() [][]byte

+ func (m *LogInfo) GetID() []byte

+ func (m *LogInfo) GetPrivKey() []byte

+ func (m *LogInfo) GetPubKey() []byte

+ func (m *LogInfo) Reset()

+ func (m *LogInfo) String() string

+ func (m *LogInfo) XXX_DiscardUnknown()

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

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

+ func (m *LogInfo) XXX_Size() int

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

+ type NewRecordReply struct

+ LogID []byte

+ Record *Record

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NewRecordReply) ProtoMessage()

+ func (m *NewRecordReply) GetLogID() []byte

+ func (m *NewRecordReply) GetRecord() *Record

+ func (m *NewRecordReply) GetThreadID() []byte

+ func (m *NewRecordReply) Reset()

+ func (m *NewRecordReply) String() string

+ func (m *NewRecordReply) XXX_DiscardUnknown()

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

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

+ func (m *NewRecordReply) XXX_Size() int

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

+ type PullThreadReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PullThreadReply) ProtoMessage()

+ func (m *PullThreadReply) Reset()

+ func (m *PullThreadReply) String() string

+ func (m *PullThreadReply) XXX_DiscardUnknown()

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

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

+ func (m *PullThreadReply) XXX_Size() int

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

+ type PullThreadRequest struct

+ ThreadID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PullThreadRequest) ProtoMessage()

+ func (m *PullThreadRequest) GetThreadID() []byte

+ func (m *PullThreadRequest) Reset()

+ func (m *PullThreadRequest) String() string

+ func (m *PullThreadRequest) XXX_DiscardUnknown()

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

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

+ func (m *PullThreadRequest) XXX_Size() int

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

+ type Record struct

+ BodyNode []byte

+ EventNode []byte

+ HeaderNode []byte

+ RecordNode []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Record) ProtoMessage()

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

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

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

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

+ func (m *Record) Reset()

+ func (m *Record) String() string

+ func (m *Record) XXX_DiscardUnknown()

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

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

+ func (m *Record) XXX_Size() int

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

+ type SubscribeRequest struct

+ ThreadIDs [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) GetThreadIDs() [][]byte

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) XXX_DiscardUnknown()

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

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

+ func (m *SubscribeRequest) XXX_Size() int

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

+ type ThreadInfoReply struct

+ ID []byte

+ Logs []*LogInfo

+ ThreadKey []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ThreadInfoReply) ProtoMessage()

+ func (m *ThreadInfoReply) GetID() []byte

+ func (m *ThreadInfoReply) GetLogs() []*LogInfo

+ func (m *ThreadInfoReply) GetThreadKey() []byte

+ func (m *ThreadInfoReply) Reset()

+ func (m *ThreadInfoReply) String() string

+ func (m *ThreadInfoReply) XXX_DiscardUnknown()

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

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

+ func (m *ThreadInfoReply) XXX_Size() int

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

+ type UnimplementedAPIServer struct

+ func (*UnimplementedAPIServer) AddRecord(ctx context.Context, req *AddRecordRequest) (*AddRecordReply, error)

+ func (*UnimplementedAPIServer) AddReplicator(ctx context.Context, req *AddReplicatorRequest) (*AddReplicatorReply, error)

+ func (*UnimplementedAPIServer) AddThread(ctx context.Context, req *AddThreadRequest) (*ThreadInfoReply, error)

+ func (*UnimplementedAPIServer) CreateRecord(ctx context.Context, req *CreateRecordRequest) (*NewRecordReply, error)

+ func (*UnimplementedAPIServer) CreateThread(ctx context.Context, req *CreateThreadRequest) (*ThreadInfoReply, error)

+ func (*UnimplementedAPIServer) DeleteThread(ctx context.Context, req *DeleteThreadRequest) (*DeleteThreadReply, error)

+ func (*UnimplementedAPIServer) GetHostID(ctx context.Context, req *GetHostIDRequest) (*GetHostIDReply, error)

+ func (*UnimplementedAPIServer) GetRecord(ctx context.Context, req *GetRecordRequest) (*GetRecordReply, error)

+ func (*UnimplementedAPIServer) GetThread(ctx context.Context, req *GetThreadRequest) (*ThreadInfoReply, error)

+ func (*UnimplementedAPIServer) PullThread(ctx context.Context, req *PullThreadRequest) (*PullThreadReply, error)

+ func (*UnimplementedAPIServer) Subscribe(req *SubscribeRequest, srv API_SubscribeServer) error