api_service_pb

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAPIServer 

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

Types

type APIClient 

type APIClient interface {
	GetHostID(ctx context.Context, in *GetHostIDRequest, opts ...grpc.CallOption) (*GetHostIDReply, error)
	CreateThread(ctx context.Context, in *CreateThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)
	AddThread(ctx context.Context, in *AddThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)
	GetThread(ctx context.Context, in *GetThreadRequest, opts ...grpc.CallOption) (*ThreadInfoReply, error)
	PullThread(ctx context.Context, in *PullThreadRequest, opts ...grpc.CallOption) (*PullThreadReply, error)
	DeleteThread(ctx context.Context, in *DeleteThreadRequest, opts ...grpc.CallOption) (*DeleteThreadReply, error)
	AddFollower(ctx context.Context, in *AddFollowerRequest, opts ...grpc.CallOption) (*AddFollowerReply, error)
	CreateRecord(ctx context.Context, in *CreateRecordRequest, opts ...grpc.CallOption) (*NewRecordReply, error)
	AddRecord(ctx context.Context, in *AddRecordRequest, opts ...grpc.CallOption) (*AddRecordReply, error)
	GetRecord(ctx context.Context, in *GetRecordRequest, opts ...grpc.CallOption) (*GetRecordReply, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (API_SubscribeClient, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	GetHostID(context.Context, *GetHostIDRequest) (*GetHostIDReply, error)
	CreateThread(context.Context, *CreateThreadRequest) (*ThreadInfoReply, error)
	AddThread(context.Context, *AddThreadRequest) (*ThreadInfoReply, error)
	GetThread(context.Context, *GetThreadRequest) (*ThreadInfoReply, error)
	PullThread(context.Context, *PullThreadRequest) (*PullThreadReply, error)
	DeleteThread(context.Context, *DeleteThreadRequest) (*DeleteThreadReply, error)
	AddFollower(context.Context, *AddFollowerRequest) (*AddFollowerReply, error)
	CreateRecord(context.Context, *CreateRecordRequest) (*NewRecordReply, error)
	AddRecord(context.Context, *AddRecordRequest) (*AddRecordReply, error)
	GetRecord(context.Context, *GetRecordRequest) (*GetRecordReply, error)
	Subscribe(*SubscribeRequest, API_SubscribeServer) error
}

APIServer is the server API for API service.

type API_SubscribeClient 

type API_SubscribeClient interface {
	Recv() (*NewRecordReply, error)
	grpc.ClientStream
}

type API_SubscribeServer 

type API_SubscribeServer interface {
	Send(*NewRecordReply) error
	grpc.ServerStream
}

type AddFollowerReply 

type AddFollowerReply struct {
	PeerID               []byte   `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFollowerReply) Descriptor 

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

func (*AddFollowerReply) GetPeerID 

func (m *AddFollowerReply) GetPeerID() []byte

func (*AddFollowerReply) ProtoMessage 

func (*AddFollowerReply) ProtoMessage()

func (*AddFollowerReply) Reset 

func (m *AddFollowerReply) Reset()

func (*AddFollowerReply) String 

func (m *AddFollowerReply) String() string

func (*AddFollowerReply) XXX_DiscardUnknown 

func (m *AddFollowerReply) XXX_DiscardUnknown()

func (*AddFollowerReply) XXX_Marshal 

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

func (*AddFollowerReply) XXX_Merge 

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

func (*AddFollowerReply) XXX_Size 

func (m *AddFollowerReply) XXX_Size() int

func (*AddFollowerReply) XXX_Unmarshal 

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

type AddFollowerRequest 

type AddFollowerRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	Addr                 []byte   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFollowerRequest) Descriptor 

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

func (*AddFollowerRequest) GetAddr 

func (m *AddFollowerRequest) GetAddr() []byte

func (*AddFollowerRequest) GetThreadID 

func (m *AddFollowerRequest) GetThreadID() []byte

func (*AddFollowerRequest) ProtoMessage 

func (*AddFollowerRequest) ProtoMessage()

func (*AddFollowerRequest) Reset 

func (m *AddFollowerRequest) Reset()

func (*AddFollowerRequest) String 

func (m *AddFollowerRequest) String() string

func (*AddFollowerRequest) XXX_DiscardUnknown 

func (m *AddFollowerRequest) XXX_DiscardUnknown()

func (*AddFollowerRequest) XXX_Marshal 

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

func (*AddFollowerRequest) XXX_Merge 

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

func (*AddFollowerRequest) XXX_Size 

func (m *AddFollowerRequest) XXX_Size() int

func (*AddFollowerRequest) XXX_Unmarshal 

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

type AddRecordReply 

type AddRecordReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRecordReply) Descriptor 

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

func (*AddRecordReply) ProtoMessage 

func (*AddRecordReply) ProtoMessage()

func (*AddRecordReply) Reset 

func (m *AddRecordReply) Reset()

func (*AddRecordReply) String 

func (m *AddRecordReply) String() string

func (*AddRecordReply) XXX_DiscardUnknown 

func (m *AddRecordReply) XXX_DiscardUnknown()

func (*AddRecordReply) XXX_Marshal 

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

func (*AddRecordReply) XXX_Merge 

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

func (*AddRecordReply) XXX_Size 

func (m *AddRecordReply) XXX_Size() int

func (*AddRecordReply) XXX_Unmarshal 

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

type AddRecordRequest 

type AddRecordRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	LogID                []byte   `protobuf:"bytes,2,opt,name=logID,proto3" json:"logID,omitempty"`
	Record               *Record  `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRecordRequest) Descriptor 

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

func (*AddRecordRequest) GetLogID 

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

func (*AddRecordRequest) GetRecord 

func (m *AddRecordRequest) GetRecord() *Record

func (*AddRecordRequest) GetThreadID 

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

func (*AddRecordRequest) ProtoMessage 

func (*AddRecordRequest) ProtoMessage()

func (*AddRecordRequest) Reset 

func (m *AddRecordRequest) Reset()

func (*AddRecordRequest) String 

func (m *AddRecordRequest) String() string

func (*AddRecordRequest) XXX_DiscardUnknown 

func (m *AddRecordRequest) XXX_DiscardUnknown()

func (*AddRecordRequest) XXX_Marshal 

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

func (*AddRecordRequest) XXX_Merge 

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

func (*AddRecordRequest) XXX_Size 

func (m *AddRecordRequest) XXX_Size() int

func (*AddRecordRequest) XXX_Unmarshal 

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

type AddThreadRequest 

type AddThreadRequest struct {
	Addr                 []byte      `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Keys                 *ThreadKeys `protobuf:"bytes,2,opt,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AddThreadRequest) Descriptor 

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

func (*AddThreadRequest) GetAddr 

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

func (*AddThreadRequest) GetKeys 

func (m *AddThreadRequest) GetKeys() *ThreadKeys

func (*AddThreadRequest) ProtoMessage 

func (*AddThreadRequest) ProtoMessage()

func (*AddThreadRequest) Reset 

func (m *AddThreadRequest) Reset()

func (*AddThreadRequest) String 

func (m *AddThreadRequest) String() string

func (*AddThreadRequest) XXX_DiscardUnknown 

func (m *AddThreadRequest) XXX_DiscardUnknown()

func (*AddThreadRequest) XXX_Marshal 

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

func (*AddThreadRequest) XXX_Merge 

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

func (*AddThreadRequest) XXX_Size 

func (m *AddThreadRequest) XXX_Size() int

func (*AddThreadRequest) XXX_Unmarshal 

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

type CreateRecordRequest 

type CreateRecordRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	Body                 []byte   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRecordRequest) Descriptor 

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

func (*CreateRecordRequest) GetBody 

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

func (*CreateRecordRequest) GetThreadID 

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

func (*CreateRecordRequest) ProtoMessage 

func (*CreateRecordRequest) ProtoMessage()

func (*CreateRecordRequest) Reset 

func (m *CreateRecordRequest) Reset()

func (*CreateRecordRequest) String 

func (m *CreateRecordRequest) String() string

func (*CreateRecordRequest) XXX_DiscardUnknown 

func (m *CreateRecordRequest) XXX_DiscardUnknown()

func (*CreateRecordRequest) XXX_Marshal 

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

func (*CreateRecordRequest) XXX_Merge 

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

func (*CreateRecordRequest) XXX_Size 

func (m *CreateRecordRequest) XXX_Size() int

func (*CreateRecordRequest) XXX_Unmarshal 

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

type CreateThreadRequest 

type CreateThreadRequest struct {
	ThreadID             []byte      `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	Keys                 *ThreadKeys `protobuf:"bytes,2,opt,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateThreadRequest) Descriptor 

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

func (*CreateThreadRequest) GetKeys 

func (m *CreateThreadRequest) GetKeys() *ThreadKeys

func (*CreateThreadRequest) GetThreadID 

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

func (*CreateThreadRequest) ProtoMessage 

func (*CreateThreadRequest) ProtoMessage()

func (*CreateThreadRequest) Reset 

func (m *CreateThreadRequest) Reset()

func (*CreateThreadRequest) String 

func (m *CreateThreadRequest) String() string

func (*CreateThreadRequest) XXX_DiscardUnknown 

func (m *CreateThreadRequest) XXX_DiscardUnknown()

func (*CreateThreadRequest) XXX_Marshal 

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

func (*CreateThreadRequest) XXX_Merge 

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

func (*CreateThreadRequest) XXX_Size 

func (m *CreateThreadRequest) XXX_Size() int

func (*CreateThreadRequest) XXX_Unmarshal 

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

type DeleteThreadReply 

type DeleteThreadReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteThreadReply) Descriptor 

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

func (*DeleteThreadReply) ProtoMessage 

func (*DeleteThreadReply) ProtoMessage()

func (*DeleteThreadReply) Reset 

func (m *DeleteThreadReply) Reset()

func (*DeleteThreadReply) String 

func (m *DeleteThreadReply) String() string

func (*DeleteThreadReply) XXX_DiscardUnknown 

func (m *DeleteThreadReply) XXX_DiscardUnknown()

func (*DeleteThreadReply) XXX_Marshal 

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

func (*DeleteThreadReply) XXX_Merge 

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

func (*DeleteThreadReply) XXX_Size 

func (m *DeleteThreadReply) XXX_Size() int

func (*DeleteThreadReply) XXX_Unmarshal 

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

type DeleteThreadRequest 

type DeleteThreadRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteThreadRequest) Descriptor 

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

func (*DeleteThreadRequest) GetThreadID 

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

func (*DeleteThreadRequest) ProtoMessage 

func (*DeleteThreadRequest) ProtoMessage()

func (*DeleteThreadRequest) Reset 

func (m *DeleteThreadRequest) Reset()

func (*DeleteThreadRequest) String 

func (m *DeleteThreadRequest) String() string

func (*DeleteThreadRequest) XXX_DiscardUnknown 

func (m *DeleteThreadRequest) XXX_DiscardUnknown()

func (*DeleteThreadRequest) XXX_Marshal 

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

func (*DeleteThreadRequest) XXX_Merge 

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

func (*DeleteThreadRequest) XXX_Size 

func (m *DeleteThreadRequest) XXX_Size() int

func (*DeleteThreadRequest) XXX_Unmarshal 

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

type GetHostIDReply 

type GetHostIDReply struct {
	PeerID               []byte   `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetHostIDReply) Descriptor 

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

func (*GetHostIDReply) GetPeerID 

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

func (*GetHostIDReply) ProtoMessage 

func (*GetHostIDReply) ProtoMessage()

func (*GetHostIDReply) Reset 

func (m *GetHostIDReply) Reset()

func (*GetHostIDReply) String 

func (m *GetHostIDReply) String() string

func (*GetHostIDReply) XXX_DiscardUnknown 

func (m *GetHostIDReply) XXX_DiscardUnknown()

func (*GetHostIDReply) XXX_Marshal 

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

func (*GetHostIDReply) XXX_Merge 

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

func (*GetHostIDReply) XXX_Size 

func (m *GetHostIDReply) XXX_Size() int

func (*GetHostIDReply) XXX_Unmarshal 

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

type GetHostIDRequest 

type GetHostIDRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetHostIDRequest) Descriptor 

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

func (*GetHostIDRequest) ProtoMessage 

func (*GetHostIDRequest) ProtoMessage()

func (*GetHostIDRequest) Reset 

func (m *GetHostIDRequest) Reset()

func (*GetHostIDRequest) String 

func (m *GetHostIDRequest) String() string

func (*GetHostIDRequest) XXX_DiscardUnknown 

func (m *GetHostIDRequest) XXX_DiscardUnknown()

func (*GetHostIDRequest) XXX_Marshal 

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

func (*GetHostIDRequest) XXX_Merge 

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

func (*GetHostIDRequest) XXX_Size 

func (m *GetHostIDRequest) XXX_Size() int

func (*GetHostIDRequest) XXX_Unmarshal 

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

type GetRecordReply 

type GetRecordReply struct {
	Record               *Record  `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRecordReply) Descriptor 

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

func (*GetRecordReply) GetRecord 

func (m *GetRecordReply) GetRecord() *Record

func (*GetRecordReply) ProtoMessage 

func (*GetRecordReply) ProtoMessage()

func (*GetRecordReply) Reset 

func (m *GetRecordReply) Reset()

func (*GetRecordReply) String 

func (m *GetRecordReply) String() string

func (*GetRecordReply) XXX_DiscardUnknown 

func (m *GetRecordReply) XXX_DiscardUnknown()

func (*GetRecordReply) XXX_Marshal 

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

func (*GetRecordReply) XXX_Merge 

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

func (*GetRecordReply) XXX_Size 

func (m *GetRecordReply) XXX_Size() int

func (*GetRecordReply) XXX_Unmarshal 

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

type GetRecordRequest 

type GetRecordRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	RecordID             []byte   `protobuf:"bytes,2,opt,name=recordID,proto3" json:"recordID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRecordRequest) Descriptor 

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

func (*GetRecordRequest) GetRecordID 

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

func (*GetRecordRequest) GetThreadID 

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

func (*GetRecordRequest) ProtoMessage 

func (*GetRecordRequest) ProtoMessage()

func (*GetRecordRequest) Reset 

func (m *GetRecordRequest) Reset()

func (*GetRecordRequest) String 

func (m *GetRecordRequest) String() string

func (*GetRecordRequest) XXX_DiscardUnknown 

func (m *GetRecordRequest) XXX_DiscardUnknown()

func (*GetRecordRequest) XXX_Marshal 

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

func (*GetRecordRequest) XXX_Merge 

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

func (*GetRecordRequest) XXX_Size 

func (m *GetRecordRequest) XXX_Size() int

func (*GetRecordRequest) XXX_Unmarshal 

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

type GetThreadRequest 

type GetThreadRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetThreadRequest) Descriptor 

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

func (*GetThreadRequest) GetThreadID 

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

func (*GetThreadRequest) ProtoMessage 

func (*GetThreadRequest) ProtoMessage()

func (*GetThreadRequest) Reset 

func (m *GetThreadRequest) Reset()

func (*GetThreadRequest) String 

func (m *GetThreadRequest) String() string

func (*GetThreadRequest) XXX_DiscardUnknown 

func (m *GetThreadRequest) XXX_DiscardUnknown()

func (*GetThreadRequest) XXX_Marshal 

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

func (*GetThreadRequest) XXX_Merge 

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

func (*GetThreadRequest) XXX_Size 

func (m *GetThreadRequest) XXX_Size() int

func (*GetThreadRequest) XXX_Unmarshal 

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

type LogInfo 

type LogInfo struct {
	ID                   []byte   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	PubKey               []byte   `protobuf:"bytes,2,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
	PrivKey              []byte   `protobuf:"bytes,3,opt,name=privKey,proto3" json:"privKey,omitempty"`
	Addrs                [][]byte `protobuf:"bytes,4,rep,name=addrs,proto3" json:"addrs,omitempty"`
	Heads                [][]byte `protobuf:"bytes,5,rep,name=heads,proto3" json:"heads,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogInfo) Descriptor 

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

func (*LogInfo) GetAddrs 

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

func (*LogInfo) GetHeads 

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

func (*LogInfo) GetID 

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

func (*LogInfo) GetPrivKey 

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

func (*LogInfo) GetPubKey 

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

func (*LogInfo) ProtoMessage 

func (*LogInfo) ProtoMessage()

func (*LogInfo) Reset 

func (m *LogInfo) Reset()

func (*LogInfo) String 

func (m *LogInfo) String() string

func (*LogInfo) XXX_DiscardUnknown 

func (m *LogInfo) XXX_DiscardUnknown()

func (*LogInfo) XXX_Marshal 

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

func (*LogInfo) XXX_Merge 

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

func (*LogInfo) XXX_Size 

func (m *LogInfo) XXX_Size() int

func (*LogInfo) XXX_Unmarshal 

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

type NewRecordReply 

type NewRecordReply struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	LogID                []byte   `protobuf:"bytes,2,opt,name=logID,proto3" json:"logID,omitempty"`
	Record               *Record  `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewRecordReply) Descriptor 

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

func (*NewRecordReply) GetLogID 

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

func (*NewRecordReply) GetRecord 

func (m *NewRecordReply) GetRecord() *Record

func (*NewRecordReply) GetThreadID 

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

func (*NewRecordReply) ProtoMessage 

func (*NewRecordReply) ProtoMessage()

func (*NewRecordReply) Reset 

func (m *NewRecordReply) Reset()

func (*NewRecordReply) String 

func (m *NewRecordReply) String() string

func (*NewRecordReply) XXX_DiscardUnknown 

func (m *NewRecordReply) XXX_DiscardUnknown()

func (*NewRecordReply) XXX_Marshal 

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

func (*NewRecordReply) XXX_Merge 

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

func (*NewRecordReply) XXX_Size 

func (m *NewRecordReply) XXX_Size() int

func (*NewRecordReply) XXX_Unmarshal 

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

type PullThreadReply 

type PullThreadReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullThreadReply) Descriptor 

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

func (*PullThreadReply) ProtoMessage 

func (*PullThreadReply) ProtoMessage()

func (*PullThreadReply) Reset 

func (m *PullThreadReply) Reset()

func (*PullThreadReply) String 

func (m *PullThreadReply) String() string

func (*PullThreadReply) XXX_DiscardUnknown 

func (m *PullThreadReply) XXX_DiscardUnknown()

func (*PullThreadReply) XXX_Marshal 

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

func (*PullThreadReply) XXX_Merge 

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

func (*PullThreadReply) XXX_Size 

func (m *PullThreadReply) XXX_Size() int

func (*PullThreadReply) XXX_Unmarshal 

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

type PullThreadRequest 

type PullThreadRequest struct {
	ThreadID             []byte   `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullThreadRequest) Descriptor 

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

func (*PullThreadRequest) GetThreadID 

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

func (*PullThreadRequest) ProtoMessage 

func (*PullThreadRequest) ProtoMessage()

func (*PullThreadRequest) Reset 

func (m *PullThreadRequest) Reset()

func (*PullThreadRequest) String 

func (m *PullThreadRequest) String() string

func (*PullThreadRequest) XXX_DiscardUnknown 

func (m *PullThreadRequest) XXX_DiscardUnknown()

func (*PullThreadRequest) XXX_Marshal 

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

func (*PullThreadRequest) XXX_Merge 

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

func (*PullThreadRequest) XXX_Size 

func (m *PullThreadRequest) XXX_Size() int

func (*PullThreadRequest) XXX_Unmarshal 

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

type Record 

type Record struct {
	RecordNode           []byte   `protobuf:"bytes,1,opt,name=recordNode,proto3" json:"recordNode,omitempty"`
	EventNode            []byte   `protobuf:"bytes,2,opt,name=eventNode,proto3" json:"eventNode,omitempty"`
	HeaderNode           []byte   `protobuf:"bytes,3,opt,name=headerNode,proto3" json:"headerNode,omitempty"`
	BodyNode             []byte   `protobuf:"bytes,4,opt,name=bodyNode,proto3" json:"bodyNode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Record) Descriptor 

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

func (*Record) GetBodyNode 

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

func (*Record) GetEventNode 

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

func (*Record) GetHeaderNode 

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

func (*Record) GetRecordNode 

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

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) String 

func (m *Record) String() string

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

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

func (*Record) XXX_Merge 

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

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

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

type SubscribeRequest 

type SubscribeRequest struct {
	ThreadIDs            [][]byte `protobuf:"bytes,1,rep,name=threadIDs,proto3" json:"threadIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetThreadIDs 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type ThreadInfoReply 

type ThreadInfoReply struct {
	ID                   []byte     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Logs                 []*LogInfo `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	ReadKey              []byte     `protobuf:"bytes,3,opt,name=readKey,proto3" json:"readKey,omitempty"`
	FollowKey            []byte     `protobuf:"bytes,4,opt,name=followKey,proto3" json:"followKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ThreadInfoReply) Descriptor 

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

func (*ThreadInfoReply) GetFollowKey 

func (m *ThreadInfoReply) GetFollowKey() []byte

func (*ThreadInfoReply) GetID 

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

func (*ThreadInfoReply) GetLogs 

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

func (*ThreadInfoReply) GetReadKey 

func (m *ThreadInfoReply) GetReadKey() []byte

func (*ThreadInfoReply) ProtoMessage 

func (*ThreadInfoReply) ProtoMessage()

func (*ThreadInfoReply) Reset 

func (m *ThreadInfoReply) Reset()

func (*ThreadInfoReply) String 

func (m *ThreadInfoReply) String() string

func (*ThreadInfoReply) XXX_DiscardUnknown 

func (m *ThreadInfoReply) XXX_DiscardUnknown()

func (*ThreadInfoReply) XXX_Marshal 

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

func (*ThreadInfoReply) XXX_Merge 

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

func (*ThreadInfoReply) XXX_Size 

func (m *ThreadInfoReply) XXX_Size() int

func (*ThreadInfoReply) XXX_Unmarshal 

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

type ThreadKeys 

type ThreadKeys struct {
	ReadKey              []byte   `protobuf:"bytes,1,opt,name=readKey,proto3" json:"readKey,omitempty"`
	FollowKey            []byte   `protobuf:"bytes,2,opt,name=followKey,proto3" json:"followKey,omitempty"`
	LogKey               []byte   `protobuf:"bytes,3,opt,name=logKey,proto3" json:"logKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThreadKeys) Descriptor 

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

func (*ThreadKeys) GetFollowKey 

func (m *ThreadKeys) GetFollowKey() []byte

func (*ThreadKeys) GetLogKey 

func (m *ThreadKeys) GetLogKey() []byte

func (*ThreadKeys) GetReadKey 

func (m *ThreadKeys) GetReadKey() []byte

func (*ThreadKeys) ProtoMessage 

func (*ThreadKeys) ProtoMessage()

func (*ThreadKeys) Reset 

func (m *ThreadKeys) Reset()

func (*ThreadKeys) String 

func (m *ThreadKeys) String() string

func (*ThreadKeys) XXX_DiscardUnknown 

func (m *ThreadKeys) XXX_DiscardUnknown()

func (*ThreadKeys) XXX_Marshal 

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

func (*ThreadKeys) XXX_Merge 

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

func (*ThreadKeys) XXX_Size 

func (m *ThreadKeys) XXX_Size() int

func (*ThreadKeys) XXX_Unmarshal 

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

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) AddFollower 

func (*UnimplementedAPIServer) AddFollower(ctx context.Context, req *AddFollowerRequest) (*AddFollowerReply, error)

func (*UnimplementedAPIServer) AddRecord 

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

func (*UnimplementedAPIServer) AddThread 

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

func (*UnimplementedAPIServer) CreateRecord 

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

func (*UnimplementedAPIServer) CreateThread 

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

func (*UnimplementedAPIServer) DeleteThread 

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

func (*UnimplementedAPIServer) GetHostID 

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

func (*UnimplementedAPIServer) GetRecord 

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

func (*UnimplementedAPIServer) GetThread 

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

func (*UnimplementedAPIServer) PullThread 

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

func (*UnimplementedAPIServer) Subscribe 

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

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.