threads_net_pb

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 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)
	GetToken(ctx context.Context, opts ...grpc.CallOption) (API_GetTokenClient, 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)
	AddReplicator(ctx context.Context, in *AddReplicatorRequest, opts ...grpc.CallOption) (*AddReplicatorReply, 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)
	GetToken(API_GetTokenServer) 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)
	AddReplicator(context.Context, *AddReplicatorRequest) (*AddReplicatorReply, 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_GetTokenClient 

type API_GetTokenClient interface {
	Send(*GetTokenRequest) error
	Recv() (*GetTokenReply, error)
	grpc.ClientStream
}

type API_GetTokenServer 

type API_GetTokenServer interface {
	Send(*GetTokenReply) error
	Recv() (*GetTokenRequest, error)
	grpc.ServerStream
}

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 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 AddReplicatorReply 

type AddReplicatorReply 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 (*AddReplicatorReply) Descriptor 

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

func (*AddReplicatorReply) GetPeerID 

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

func (*AddReplicatorReply) ProtoMessage 

func (*AddReplicatorReply) ProtoMessage()

func (*AddReplicatorReply) Reset 

func (m *AddReplicatorReply) Reset()

func (*AddReplicatorReply) String 

func (m *AddReplicatorReply) String() string

func (*AddReplicatorReply) XXX_DiscardUnknown 

func (m *AddReplicatorReply) XXX_DiscardUnknown()

func (*AddReplicatorReply) XXX_Marshal 

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

func (*AddReplicatorReply) XXX_Merge 

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

func (*AddReplicatorReply) XXX_Size 

func (m *AddReplicatorReply) XXX_Size() int

func (*AddReplicatorReply) XXX_Unmarshal 

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

type AddReplicatorRequest 

type AddReplicatorRequest 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 (*AddReplicatorRequest) Descriptor 

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

func (*AddReplicatorRequest) GetAddr 

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

func (*AddReplicatorRequest) GetThreadID 

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

func (*AddReplicatorRequest) ProtoMessage 

func (*AddReplicatorRequest) ProtoMessage()

func (*AddReplicatorRequest) Reset 

func (m *AddReplicatorRequest) Reset()

func (*AddReplicatorRequest) String 

func (m *AddReplicatorRequest) String() string

func (*AddReplicatorRequest) XXX_DiscardUnknown 

func (m *AddReplicatorRequest) XXX_DiscardUnknown()

func (*AddReplicatorRequest) XXX_Marshal 

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

func (*AddReplicatorRequest) XXX_Merge 

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

func (*AddReplicatorRequest) XXX_Size 

func (m *AddReplicatorRequest) XXX_Size() int

func (*AddReplicatorRequest) XXX_Unmarshal 

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

type AddThreadRequest 

type AddThreadRequest struct {
	Addr                 []byte   `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Keys                 *Keys    `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() *Keys

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                 *Keys    `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() *Keys

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 GetTokenReply 

type GetTokenReply struct {
	// Types that are valid to be assigned to Payload:
	//	*GetTokenReply_Challenge
	//	*GetTokenReply_Token
	Payload              isGetTokenReply_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetTokenReply) Descriptor 

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

func (*GetTokenReply) GetChallenge 

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

func (*GetTokenReply) GetPayload 

func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload

func (*GetTokenReply) GetToken 

func (m *GetTokenReply) GetToken() string

func (*GetTokenReply) ProtoMessage 

func (*GetTokenReply) ProtoMessage()

func (*GetTokenReply) Reset 

func (m *GetTokenReply) Reset()

func (*GetTokenReply) String 

func (m *GetTokenReply) String() string

func (*GetTokenReply) XXX_DiscardUnknown 

func (m *GetTokenReply) XXX_DiscardUnknown()

func (*GetTokenReply) XXX_Marshal 

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

func (*GetTokenReply) XXX_Merge 

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

func (*GetTokenReply) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenReply) XXX_Size 

func (m *GetTokenReply) XXX_Size() int

func (*GetTokenReply) XXX_Unmarshal 

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

type GetTokenReply_Challenge 

type GetTokenReply_Challenge struct {
	Challenge []byte `protobuf:"bytes,1,opt,name=challenge,proto3,oneof"`
}

type GetTokenReply_Token 

type GetTokenReply_Token struct {
	Token string `protobuf:"bytes,2,opt,name=token,proto3,oneof"`
}

type GetTokenRequest 

type GetTokenRequest struct {
	// Types that are valid to be assigned to Payload:
	//	*GetTokenRequest_Key
	//	*GetTokenRequest_Signature
	Payload              isGetTokenRequest_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetTokenRequest) Descriptor 

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

func (*GetTokenRequest) GetKey 

func (m *GetTokenRequest) GetKey() string

func (*GetTokenRequest) GetPayload 

func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload

func (*GetTokenRequest) GetSignature 

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

func (*GetTokenRequest) ProtoMessage 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) Reset 

func (m *GetTokenRequest) Reset()

func (*GetTokenRequest) String 

func (m *GetTokenRequest) String() string

func (*GetTokenRequest) XXX_DiscardUnknown 

func (m *GetTokenRequest) XXX_DiscardUnknown()

func (*GetTokenRequest) XXX_Marshal 

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

func (*GetTokenRequest) XXX_Merge 

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

func (*GetTokenRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetTokenRequest) XXX_Size 

func (m *GetTokenRequest) XXX_Size() int

func (*GetTokenRequest) XXX_Unmarshal 

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

type GetTokenRequest_Key 

type GetTokenRequest_Key struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}

type GetTokenRequest_Signature 

type GetTokenRequest_Signature struct {
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3,oneof"`
}

type Keys 

type Keys struct {
	ThreadKey            []byte   `protobuf:"bytes,1,opt,name=threadKey,proto3" json:"threadKey,omitempty"`
	LogKey               []byte   `protobuf:"bytes,2,opt,name=logKey,proto3" json:"logKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Keys) Descriptor 

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

func (*Keys) GetLogKey 

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

func (*Keys) GetThreadKey 

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

func (*Keys) ProtoMessage 

func (*Keys) ProtoMessage()

func (*Keys) Reset 

func (m *Keys) Reset()

func (*Keys) String 

func (m *Keys) String() string

func (*Keys) XXX_DiscardUnknown 

func (m *Keys) XXX_DiscardUnknown()

func (*Keys) XXX_Marshal 

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

func (*Keys) XXX_Merge 

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

func (*Keys) XXX_Size 

func (m *Keys) XXX_Size() int

func (*Keys) XXX_Unmarshal 

func (m *Keys) 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"`
	Head                 []byte   `protobuf:"bytes,5,opt,name=head,proto3" json:"head,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) GetHead 

func (m *LogInfo) GetHead() []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 {
	ThreadID             []byte     `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	ThreadKey            []byte     `protobuf:"bytes,2,opt,name=threadKey,proto3" json:"threadKey,omitempty"`
	Logs                 []*LogInfo `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	Addrs                [][]byte   `protobuf:"bytes,4,rep,name=addrs,proto3" json:"addrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ThreadInfoReply) Descriptor 

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

func (*ThreadInfoReply) GetAddrs 

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

func (*ThreadInfoReply) GetLogs 

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

func (*ThreadInfoReply) GetThreadID 

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

func (*ThreadInfoReply) GetThreadKey 

func (m *ThreadInfoReply) GetThreadKey() []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 UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) AddRecord 

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

func (*UnimplementedAPIServer) AddReplicator 

func (*UnimplementedAPIServer) AddReplicator(ctx context.Context, req *AddReplicatorRequest) (*AddReplicatorReply, 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) GetToken 

func (*UnimplementedAPIServer) GetToken(srv API_GetTokenServer) 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.