threads_net_pb

package
v0.1.18 Latest Latest
Warning

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

 Go to latest Published: May 7, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "threads.net.pb.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHostID",
			Handler:    _API_GetHostID_Handler,
		},
		{
			MethodName: "CreateThread",
			Handler:    _API_CreateThread_Handler,
		},
		{
			MethodName: "AddThread",
			Handler:    _API_AddThread_Handler,
		},
		{
			MethodName: "GetThread",
			Handler:    _API_GetThread_Handler,
		},
		{
			MethodName: "PullThread",
			Handler:    _API_PullThread_Handler,
		},
		{
			MethodName: "DeleteThread",
			Handler:    _API_DeleteThread_Handler,
		},
		{
			MethodName: "AddReplicator",
			Handler:    _API_AddReplicator_Handler,
		},
		{
			MethodName: "CreateRecord",
			Handler:    _API_CreateRecord_Handler,
		},
		{
			MethodName: "AddRecord",
			Handler:    _API_AddRecord_Handler,
		},
		{
			MethodName: "GetRecord",
			Handler:    _API_GetRecord_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetToken",
			Handler:       _API_GetToken_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _API_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "threadsnet.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_threadsnet_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServer 

func RegisterAPIServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) 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
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

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 {
	// contains filtered or unexported fields
}

func (*AddRecordReply) Descriptor deprecated 

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

Deprecated: Use AddRecordReply.ProtoReflect.Descriptor instead.

func (*AddRecordReply) ProtoMessage 

func (*AddRecordReply) ProtoMessage()

func (*AddRecordReply) ProtoReflect 

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

func (*AddRecordReply) Reset 

func (x *AddRecordReply) Reset()

func (*AddRecordReply) String 

func (x *AddRecordReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*AddRecordRequest) Descriptor deprecated 

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

Deprecated: Use AddRecordRequest.ProtoReflect.Descriptor instead.

func (*AddRecordRequest) GetLogID 

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

func (*AddRecordRequest) GetRecord 

func (x *AddRecordRequest) GetRecord() *Record

func (*AddRecordRequest) GetThreadID 

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

func (*AddRecordRequest) ProtoMessage 

func (*AddRecordRequest) ProtoMessage()

func (*AddRecordRequest) ProtoReflect 

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

func (*AddRecordRequest) Reset 

func (x *AddRecordRequest) Reset()

func (*AddRecordRequest) String 

func (x *AddRecordRequest) String() string

type AddReplicatorReply 

type AddReplicatorReply struct {
	PeerID []byte `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	// contains filtered or unexported fields
}

func (*AddReplicatorReply) Descriptor deprecated 

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

Deprecated: Use AddReplicatorReply.ProtoReflect.Descriptor instead.

func (*AddReplicatorReply) GetPeerID 

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

func (*AddReplicatorReply) ProtoMessage 

func (*AddReplicatorReply) ProtoMessage()

func (*AddReplicatorReply) ProtoReflect 

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

func (*AddReplicatorReply) Reset 

func (x *AddReplicatorReply) Reset()

func (*AddReplicatorReply) String 

func (x *AddReplicatorReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*AddReplicatorRequest) Descriptor deprecated 

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

Deprecated: Use AddReplicatorRequest.ProtoReflect.Descriptor instead.

func (*AddReplicatorRequest) GetAddr 

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

func (*AddReplicatorRequest) GetThreadID 

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

func (*AddReplicatorRequest) ProtoMessage 

func (*AddReplicatorRequest) ProtoMessage()

func (*AddReplicatorRequest) ProtoReflect 

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

func (*AddReplicatorRequest) Reset 

func (x *AddReplicatorRequest) Reset()

func (*AddReplicatorRequest) String 

func (x *AddReplicatorRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*AddThreadRequest) Descriptor deprecated 

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

Deprecated: Use AddThreadRequest.ProtoReflect.Descriptor instead.

func (*AddThreadRequest) GetAddr 

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

func (*AddThreadRequest) GetKeys 

func (x *AddThreadRequest) GetKeys() *Keys

func (*AddThreadRequest) ProtoMessage 

func (*AddThreadRequest) ProtoMessage()

func (*AddThreadRequest) ProtoReflect 

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

func (*AddThreadRequest) Reset 

func (x *AddThreadRequest) Reset()

func (*AddThreadRequest) String 

func (x *AddThreadRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateRecordRequest) Descriptor deprecated 

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

Deprecated: Use CreateRecordRequest.ProtoReflect.Descriptor instead.

func (*CreateRecordRequest) GetBody 

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

func (*CreateRecordRequest) GetThreadID 

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

func (*CreateRecordRequest) ProtoMessage 

func (*CreateRecordRequest) ProtoMessage()

func (*CreateRecordRequest) ProtoReflect 

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

func (*CreateRecordRequest) Reset 

func (x *CreateRecordRequest) Reset()

func (*CreateRecordRequest) String 

func (x *CreateRecordRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateThreadRequest) Descriptor deprecated 

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

Deprecated: Use CreateThreadRequest.ProtoReflect.Descriptor instead.

func (*CreateThreadRequest) GetKeys 

func (x *CreateThreadRequest) GetKeys() *Keys

func (*CreateThreadRequest) GetThreadID 

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

func (*CreateThreadRequest) ProtoMessage 

func (*CreateThreadRequest) ProtoMessage()

func (*CreateThreadRequest) ProtoReflect 

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

func (*CreateThreadRequest) Reset 

func (x *CreateThreadRequest) Reset()

func (*CreateThreadRequest) String 

func (x *CreateThreadRequest) String() string

type DeleteThreadReply 

type DeleteThreadReply struct {
	// contains filtered or unexported fields
}

func (*DeleteThreadReply) Descriptor deprecated 

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

Deprecated: Use DeleteThreadReply.ProtoReflect.Descriptor instead.

func (*DeleteThreadReply) ProtoMessage 

func (*DeleteThreadReply) ProtoMessage()

func (*DeleteThreadReply) ProtoReflect 

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

func (*DeleteThreadReply) Reset 

func (x *DeleteThreadReply) Reset()

func (*DeleteThreadReply) String 

func (x *DeleteThreadReply) String() string

type DeleteThreadRequest 

type DeleteThreadRequest struct {
	ThreadID []byte `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteThreadRequest) Descriptor deprecated 

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

Deprecated: Use DeleteThreadRequest.ProtoReflect.Descriptor instead.

func (*DeleteThreadRequest) GetThreadID 

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

func (*DeleteThreadRequest) ProtoMessage 

func (*DeleteThreadRequest) ProtoMessage()

func (*DeleteThreadRequest) ProtoReflect 

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

func (*DeleteThreadRequest) Reset 

func (x *DeleteThreadRequest) Reset()

func (*DeleteThreadRequest) String 

func (x *DeleteThreadRequest) String() string

type GetHostIDReply 

type GetHostIDReply struct {
	PeerID []byte `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHostIDReply) Descriptor deprecated 

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

Deprecated: Use GetHostIDReply.ProtoReflect.Descriptor instead.

func (*GetHostIDReply) GetPeerID 

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

func (*GetHostIDReply) ProtoMessage 

func (*GetHostIDReply) ProtoMessage()

func (*GetHostIDReply) ProtoReflect 

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

func (*GetHostIDReply) Reset 

func (x *GetHostIDReply) Reset()

func (*GetHostIDReply) String 

func (x *GetHostIDReply) String() string

type GetHostIDRequest 

type GetHostIDRequest struct {
	// contains filtered or unexported fields
}

func (*GetHostIDRequest) Descriptor deprecated 

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

Deprecated: Use GetHostIDRequest.ProtoReflect.Descriptor instead.

func (*GetHostIDRequest) ProtoMessage 

func (*GetHostIDRequest) ProtoMessage()

func (*GetHostIDRequest) ProtoReflect 

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

func (*GetHostIDRequest) Reset 

func (x *GetHostIDRequest) Reset()

func (*GetHostIDRequest) String 

func (x *GetHostIDRequest) String() string

type GetRecordReply 

type GetRecordReply struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordReply) Descriptor deprecated 

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

Deprecated: Use GetRecordReply.ProtoReflect.Descriptor instead.

func (*GetRecordReply) GetRecord 

func (x *GetRecordReply) GetRecord() *Record

func (*GetRecordReply) ProtoMessage 

func (*GetRecordReply) ProtoMessage()

func (*GetRecordReply) ProtoReflect 

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

func (*GetRecordReply) Reset 

func (x *GetRecordReply) Reset()

func (*GetRecordReply) String 

func (x *GetRecordReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetRecordRequest) Descriptor deprecated 

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

Deprecated: Use GetRecordRequest.ProtoReflect.Descriptor instead.

func (*GetRecordRequest) GetRecordID 

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

func (*GetRecordRequest) GetThreadID 

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

func (*GetRecordRequest) ProtoMessage 

func (*GetRecordRequest) ProtoMessage()

func (*GetRecordRequest) ProtoReflect 

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

func (*GetRecordRequest) Reset 

func (x *GetRecordRequest) Reset()

func (*GetRecordRequest) String 

func (x *GetRecordRequest) String() string

type GetThreadRequest 

type GetThreadRequest struct {
	ThreadID []byte `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetThreadRequest) Descriptor deprecated 

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

Deprecated: Use GetThreadRequest.ProtoReflect.Descriptor instead.

func (*GetThreadRequest) GetThreadID 

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

func (*GetThreadRequest) ProtoMessage 

func (*GetThreadRequest) ProtoMessage()

func (*GetThreadRequest) ProtoReflect 

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

func (*GetThreadRequest) Reset 

func (x *GetThreadRequest) Reset()

func (*GetThreadRequest) String 

func (x *GetThreadRequest) String() string

type GetTokenReply 

type GetTokenReply struct {

	// Types that are assignable to Payload:
	//	*GetTokenReply_Challenge
	//	*GetTokenReply_Token
	Payload isGetTokenReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*GetTokenReply) Descriptor deprecated 

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

Deprecated: Use GetTokenReply.ProtoReflect.Descriptor instead.

func (*GetTokenReply) GetChallenge 

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

func (*GetTokenReply) GetPayload 

func (m *GetTokenReply) GetPayload() isGetTokenReply_Payload

func (*GetTokenReply) GetToken 

func (x *GetTokenReply) GetToken() string

func (*GetTokenReply) ProtoMessage 

func (*GetTokenReply) ProtoMessage()

func (*GetTokenReply) ProtoReflect 

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

func (*GetTokenReply) Reset 

func (x *GetTokenReply) Reset()

func (*GetTokenReply) String 

func (x *GetTokenReply) String() string

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 assignable to Payload:
	//	*GetTokenRequest_Key
	//	*GetTokenRequest_Signature
	Payload isGetTokenRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*GetTokenRequest) Descriptor deprecated 

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

Deprecated: Use GetTokenRequest.ProtoReflect.Descriptor instead.

func (*GetTokenRequest) GetKey 

func (x *GetTokenRequest) GetKey() string

func (*GetTokenRequest) GetPayload 

func (m *GetTokenRequest) GetPayload() isGetTokenRequest_Payload

func (*GetTokenRequest) GetSignature 

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

func (*GetTokenRequest) ProtoMessage 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) ProtoReflect 

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

func (*GetTokenRequest) Reset 

func (x *GetTokenRequest) Reset()

func (*GetTokenRequest) String 

func (x *GetTokenRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*Keys) Descriptor deprecated 

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

Deprecated: Use Keys.ProtoReflect.Descriptor instead.

func (*Keys) GetLogKey 

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

func (*Keys) GetThreadKey 

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

func (*Keys) ProtoMessage 

func (*Keys) ProtoMessage()

func (*Keys) ProtoReflect 

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

func (*Keys) Reset 

func (x *Keys) Reset()

func (*Keys) String 

func (x *Keys) String() string

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"`
	Counter []byte   `protobuf:"bytes,6,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*LogInfo) Descriptor deprecated 

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

Deprecated: Use LogInfo.ProtoReflect.Descriptor instead.

func (*LogInfo) GetAddrs 

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

func (*LogInfo) GetCounter 

func (x *LogInfo) GetCounter() []byte

func (*LogInfo) GetHead 

func (x *LogInfo) GetHead() []byte

func (*LogInfo) GetID 

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

func (*LogInfo) GetPrivKey 

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

func (*LogInfo) GetPubKey 

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

func (*LogInfo) ProtoMessage 

func (*LogInfo) ProtoMessage()

func (*LogInfo) ProtoReflect 

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

func (*LogInfo) Reset 

func (x *LogInfo) Reset()

func (*LogInfo) String 

func (x *LogInfo) String() string

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"`
	// contains filtered or unexported fields
}

func (*NewRecordReply) Descriptor deprecated 

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

Deprecated: Use NewRecordReply.ProtoReflect.Descriptor instead.

func (*NewRecordReply) GetLogID 

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

func (*NewRecordReply) GetRecord 

func (x *NewRecordReply) GetRecord() *Record

func (*NewRecordReply) GetThreadID 

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

func (*NewRecordReply) ProtoMessage 

func (*NewRecordReply) ProtoMessage()

func (*NewRecordReply) ProtoReflect 

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

func (*NewRecordReply) Reset 

func (x *NewRecordReply) Reset()

func (*NewRecordReply) String 

func (x *NewRecordReply) String() string

type PullThreadReply 

type PullThreadReply struct {
	// contains filtered or unexported fields
}

func (*PullThreadReply) Descriptor deprecated 

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

Deprecated: Use PullThreadReply.ProtoReflect.Descriptor instead.

func (*PullThreadReply) ProtoMessage 

func (*PullThreadReply) ProtoMessage()

func (*PullThreadReply) ProtoReflect 

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

func (*PullThreadReply) Reset 

func (x *PullThreadReply) Reset()

func (*PullThreadReply) String 

func (x *PullThreadReply) String() string

type PullThreadRequest 

type PullThreadRequest struct {
	ThreadID []byte `protobuf:"bytes,1,opt,name=threadID,proto3" json:"threadID,omitempty"`
	// contains filtered or unexported fields
}

func (*PullThreadRequest) Descriptor deprecated 

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

Deprecated: Use PullThreadRequest.ProtoReflect.Descriptor instead.

func (*PullThreadRequest) GetThreadID 

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

func (*PullThreadRequest) ProtoMessage 

func (*PullThreadRequest) ProtoMessage()

func (*PullThreadRequest) ProtoReflect 

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

func (*PullThreadRequest) Reset 

func (x *PullThreadRequest) Reset()

func (*PullThreadRequest) String 

func (x *PullThreadRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetBodyNode 

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

func (*Record) GetEventNode 

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

func (*Record) GetHeaderNode 

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

func (*Record) GetRecordNode 

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

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	ThreadIDs [][]byte `protobuf:"bytes,1,rep,name=threadIDs,proto3" json:"threadIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetThreadIDs 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ThreadInfoReply) Descriptor deprecated 

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

Deprecated: Use ThreadInfoReply.ProtoReflect.Descriptor instead.

func (*ThreadInfoReply) GetAddrs 

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

func (*ThreadInfoReply) GetLogs 

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

func (*ThreadInfoReply) GetThreadID 

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

func (*ThreadInfoReply) GetThreadKey 

func (x *ThreadInfoReply) GetThreadKey() []byte

func (*ThreadInfoReply) ProtoMessage 

func (*ThreadInfoReply) ProtoMessage()

func (*ThreadInfoReply) ProtoReflect 

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

func (*ThreadInfoReply) Reset 

func (x *ThreadInfoReply) Reset()

func (*ThreadInfoReply) String 

func (x *ThreadInfoReply) String() string

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) AddRecord 

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

func (UnimplementedAPIServer) AddReplicator 

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

func (UnimplementedAPIServer) AddThread 

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

func (UnimplementedAPIServer) CreateRecord 

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

func (UnimplementedAPIServer) CreateThread 

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

func (UnimplementedAPIServer) DeleteThread 

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

func (UnimplementedAPIServer) GetHostID 

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

func (UnimplementedAPIServer) GetRecord 

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

func (UnimplementedAPIServer) GetThread 

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

func (UnimplementedAPIServer) GetToken 

func (UnimplementedAPIServer) GetToken(API_GetTokenServer) error

func (UnimplementedAPIServer) PullThread 

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

func (UnimplementedAPIServer) Subscribe 

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

type UnsafeAPIServer 

type UnsafeAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.

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.