useridpb

package module

Go to main page

Versions in this module

v1

v1.0.12

Mar 7, 2023

Changes in this version

+ type AttributeCount struct

+ Count int64

+ Name string

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

+ func (*AttributeCount) ProtoMessage()

+ func (x *AttributeCount) GetCount() int64

+ func (x *AttributeCount) GetName() string

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

+ func (x *AttributeCount) Reset()

+ func (x *AttributeCount) String() string

type DeleteRequest

+ KeepAttributes []string

+ func (x *DeleteRequest) GetKeepAttributes() []string

v1.0.11

Mar 7, 2023

v1.0.10

Mar 7, 2023

Changes in this version

type UserEntity

+ CreatedAt int64

+ func (x *UserEntity) GetCreatedAt() int64

v1.0.9

Mar 7, 2023

Changes in this version

type Attribute

+ Count int64

+ func (x *Attribute) GetCount() int64

+ type Counts struct

+ Attributes []*Attribute

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

+ func (*Counts) ProtoMessage()

+ func (x *Counts) GetAttributes() []*Attribute

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

+ func (x *Counts) Reset()

+ func (x *Counts) String() string

type UnimplementedUserServiceServer

+ func (UnimplementedUserServiceServer) GetCounts(context.Context, *emptypb.Empty) (*Counts, error)

type UserServiceClient

+ GetCounts func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Counts, error)

type UserServiceServer

+ GetCounts func(context.Context, *emptypb.Empty) (*Counts, error)

v1.0.8

Mar 7, 2023

Changes in this version

+ type AttributeEntity struct

+ Name string

+ Ttl int32

+ Value string

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

+ func (*AttributeEntity) ProtoMessage()

+ func (x *AttributeEntity) GetName() string

+ func (x *AttributeEntity) GetTtl() int32

+ func (x *AttributeEntity) GetValue() string

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

+ func (x *AttributeEntity) Reset()

+ func (x *AttributeEntity) String() string

+ type BlockEntity struct

+ UserIds []string

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

+ func (*BlockEntity) ProtoMessage()

+ func (x *BlockEntity) GetUserIds() []string

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

+ func (x *BlockEntity) Reset()

+ func (x *BlockEntity) String() string

+ type FileEntity struct

+ CreatedAt int32

+ Data []byte

+ Name string

+ Size int32

+ Ttl int32

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

+ func (*FileEntity) ProtoMessage()

+ func (x *FileEntity) GetCreatedAt() int32

+ func (x *FileEntity) GetData() []byte

+ func (x *FileEntity) GetName() string

+ func (x *FileEntity) GetSize() int32

+ func (x *FileEntity) GetTtl() int32

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

+ func (x *FileEntity) Reset()

+ func (x *FileEntity) String() string

+ type HeadEntity struct

+ NextBlock int64

+ UserId string

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

+ func (*HeadEntity) ProtoMessage()

+ func (x *HeadEntity) GetNextBlock() int64

+ func (x *HeadEntity) GetUserId() string

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

+ func (x *HeadEntity) Reset()

+ func (x *HeadEntity) String() string

+ type RangeEntity struct

+ Ranges []*Range

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

+ func (*RangeEntity) ProtoMessage()

+ func (x *RangeEntity) GetRanges() []*Range

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

+ func (x *RangeEntity) Reset()

+ func (x *RangeEntity) String() string

+ type UserEntity struct

+ Attributes []*AttributeEntity

+ DeletedAt int64

+ Files []*FileEntity

+ UserId string

+ Version int64

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

+ func (*UserEntity) ProtoMessage()

+ func (x *UserEntity) GetAttributes() []*AttributeEntity

+ func (x *UserEntity) GetDeletedAt() int64

+ func (x *UserEntity) GetFiles() []*FileEntity

+ func (x *UserEntity) GetUserId() string

+ func (x *UserEntity) GetVersion() int64

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

+ func (x *UserEntity) Reset()

+ func (x *UserEntity) String() string

v1.0.7

Mar 7, 2023

v1.0.6

Mar 7, 2023

Changes in this version

type GetRequest

+ FileContents bool

+ func (x *GetRequest) GetFileContents() bool

type LookupRequest

+ FileContents bool

+ func (x *LookupRequest) GetFileContents() bool

v1.0.5

Mar 7, 2023

Changes in this version

+ type Capacity struct

+ PendingIds int64

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

+ func (*Capacity) ProtoMessage()

+ func (x *Capacity) GetPendingIds() int64

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

+ func (x *Capacity) Reset()

+ func (x *Capacity) String() string

v1.0.4

Mar 7, 2023

Changes in this version

+ type CapacityResponse struct

+ PendingIds int64

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

+ func (*CapacityResponse) ProtoMessage()

+ func (x *CapacityResponse) GetPendingIds() int64

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

+ func (x *CapacityResponse) Reset()

+ func (x *CapacityResponse) String() string

type Command

+ Range *Range

+ func (x *Command) GetRange() *Range

type CommandOperation

+ const CommandOperation_ADD_RANGE_OP

type CreateRequest

+ Files []*FileEntry

+ UserId string

+ func (x *CreateRequest) GetFiles() []*FileEntry

+ func (x *CreateRequest) GetUserId() string

+ type CreateResponse struct

+ UserId string

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

+ func (*CreateResponse) ProtoMessage()

+ func (x *CreateResponse) GetUserId() string

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

+ func (x *CreateResponse) Reset()

+ func (x *CreateResponse) String() string

+ type FileEntry struct

+ CreatedAt int32

+ Data []byte

+ Name string

+ Size int32

+ Ttl int32

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

+ func (*FileEntry) ProtoMessage()

+ func (x *FileEntry) GetCreatedAt() int32

+ func (x *FileEntry) GetData() []byte

+ func (x *FileEntry) GetName() string

+ func (x *FileEntry) GetSize() int32

+ func (x *FileEntry) GetTtl() int32

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

+ func (x *FileEntry) Reset()

+ func (x *FileEntry) String() string

type GetRequest

+ SelectAttributes string

+ SelectFiles string

+ func (x *GetRequest) GetSelectAttributes() string

+ func (x *GetRequest) GetSelectFiles() string

+ type HeadRequest struct

+ UserId string

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

+ func (*HeadRequest) ProtoMessage()

+ func (x *HeadRequest) GetUserId() string

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

+ func (x *HeadRequest) Reset()

+ func (x *HeadRequest) String() string

type LookupRequest

+ SelectFiles string

+ func (x *LookupRequest) GetSelectFiles() string

+ type Range struct

+ EndId int64

+ StartId int64

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

+ func (*Range) ProtoMessage()

+ func (x *Range) GetEndId() int64

+ func (x *Range) GetStartId() int64

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

+ func (x *Range) Reset()

+ func (x *Range) String() string

type ScanRequest

+ Offset string

+ SelectFiles string

+ func (x *ScanRequest) GetOffset() string

+ func (x *ScanRequest) GetSelectFiles() string

type SchemeRequest

+ UpdateAttributes []*Attribute

+ func (x *SchemeRequest) GetUpdateAttributes() []*Attribute

type UnimplementedUserServiceServer

+ func (UnimplementedUserServiceServer) AddRange(context.Context, *Range) (*emptypb.Empty, error)

+ func (UnimplementedUserServiceServer) GetCapacity(context.Context, *emptypb.Empty) (*CapacityResponse, error)

+ func (UnimplementedUserServiceServer) Head(context.Context, *HeadRequest) (*UserEntry, error)

type UpdateRequest

+ Files []*FileEntry

+ func (x *UpdateRequest) GetFiles() []*FileEntry

type UserEntry

+ DeletedAt int64

+ Files []*FileEntry

+ func (x *UserEntry) GetDeletedAt() int64

+ func (x *UserEntry) GetFiles() []*FileEntry

type UserServiceClient

+ AddRange func(ctx context.Context, in *Range, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetCapacity func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CapacityResponse, error)

+ Head func(ctx context.Context, in *HeadRequest, opts ...grpc.CallOption) (*UserEntry, error)

type UserServiceServer

+ AddRange func(context.Context, *Range) (*emptypb.Empty, error)

+ GetCapacity func(context.Context, *emptypb.Empty) (*CapacityResponse, error)

+ Head func(context.Context, *HeadRequest) (*UserEntry, error)

v1.0.3

Mar 6, 2023

v1.0.2

Mar 5, 2023

v1.0.1

Mar 5, 2023

Changes in this version

+ var RaftService_ServiceDesc = grpc.ServiceDesc

+ func RegisterRaftServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterRaftServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RaftServiceClient) error

+ func RegisterRaftServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterRaftServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RaftServiceServer) error

+ func RegisterRaftServiceServer(s grpc.ServiceRegistrar, srv RaftServiceServer)

+ type RaftServiceClient interface

+ ApplyCommand func(ctx context.Context, in *Command, opts ...grpc.CallOption) (*Status, error)

+ Bootstrap func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetConfiguration func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RaftConfiguration, error)

+ Join func(ctx context.Context, in *RaftNode, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Recover func(ctx context.Context, opts ...grpc.CallOption) (RaftService_RecoverClient, error)

+ func NewRaftServiceClient(cc grpc.ClientConnInterface) RaftServiceClient

+ type RaftServiceServer interface

+ ApplyCommand func(context.Context, *Command) (*Status, error)

+ Bootstrap func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ GetConfiguration func(context.Context, *emptypb.Empty) (*RaftConfiguration, error)

+ Join func(context.Context, *RaftNode) (*emptypb.Empty, error)

+ Recover func(RaftService_RecoverServer) error

+ type RaftService_RecoverClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*Content) error

+ type RaftService_RecoverServer interface

+ Recv func() (*Content, error)

+ SendAndClose func(*emptypb.Empty) error

+ type UnimplementedRaftServiceServer struct

+ func (UnimplementedRaftServiceServer) ApplyCommand(context.Context, *Command) (*Status, error)

+ func (UnimplementedRaftServiceServer) Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedRaftServiceServer) GetConfiguration(context.Context, *emptypb.Empty) (*RaftConfiguration, error)

+ func (UnimplementedRaftServiceServer) Join(context.Context, *RaftNode) (*emptypb.Empty, error)

+ func (UnimplementedRaftServiceServer) Recover(RaftService_RecoverServer) error

+ type UnsafeRaftServiceServer interface

v1.0.0

Mar 5, 2023

Changes in this version

+ var CommandOperation_name = map[int32]string

+ var CommandOperation_value = map[string]int32

+ var File_user_service_proto protoreflect.FileDescriptor

+ var LookupType_name = map[int32]string

+ var LookupType_value = map[string]int32

+ var UpdateType_name = map[int32]string

+ var UpdateType_value = map[string]int32

+ var UserRaftService_ServiceDesc = grpc.ServiceDesc

+ var UserService_ServiceDesc = grpc.ServiceDesc

+ func RegisterUserRaftServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterUserRaftServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserRaftServiceClient) error

+ func RegisterUserRaftServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterUserRaftServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserRaftServiceServer) error

+ func RegisterUserRaftServiceServer(s grpc.ServiceRegistrar, srv UserRaftServiceServer)

+ func RegisterUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserServiceClient) error

+ func RegisterUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServiceServer) error

+ func RegisterUserServiceServer(s grpc.ServiceRegistrar, srv UserServiceServer)

+ type Attribute struct

+ DefaultTtl int32

+ Indexed bool

+ Name string

+ Pii bool

+ Unique bool

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

+ func (*Attribute) ProtoMessage()

+ func (x *Attribute) GetDefaultTtl() int32

+ func (x *Attribute) GetIndexed() bool

+ func (x *Attribute) GetName() string

+ func (x *Attribute) GetPii() bool

+ func (x *Attribute) GetUnique() bool

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

+ func (x *Attribute) Reset()

+ func (x *Attribute) String() string

+ type AttributeEntry struct

+ Name string

+ Ttl int32

+ Value string

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

+ func (*AttributeEntry) ProtoMessage()

+ func (x *AttributeEntry) GetName() string

+ func (x *AttributeEntry) GetTtl() int32

+ func (x *AttributeEntry) GetValue() string

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

+ func (x *AttributeEntry) Reset()

+ func (x *AttributeEntry) String() string

+ type Command struct

+ CreateReq *CreateRequest

+ DeleteReq *DeleteRequest

+ Operation CommandOperation

+ SchemeReq *SchemeRequest

+ UpdateReq *UpdateRequest

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

+ func (*Command) ProtoMessage()

+ func (x *Command) GetCreateReq() *CreateRequest

+ func (x *Command) GetDeleteReq() *DeleteRequest

+ func (x *Command) GetOperation() CommandOperation

+ func (x *Command) GetSchemeReq() *SchemeRequest

+ func (x *Command) GetUpdateReq() *UpdateRequest

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

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type CommandOperation int32

+ const CommandOperation_CREATE_OP

+ const CommandOperation_DELETE_OP

+ const CommandOperation_SCHEME_OP

+ const CommandOperation_UNKNOWN_OP

+ const CommandOperation_UPDATE_OP

+ func (CommandOperation) Descriptor() protoreflect.EnumDescriptor

+ func (CommandOperation) EnumDescriptor() ([]byte, []int)

+ func (CommandOperation) Type() protoreflect.EnumType

+ func (x CommandOperation) Enum() *CommandOperation

+ func (x CommandOperation) Number() protoreflect.EnumNumber

+ func (x CommandOperation) String() string

+ type Content struct

+ Content []byte

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

+ func (*Content) ProtoMessage()

+ func (x *Content) GetContent() []byte

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

+ func (x *Content) Reset()

+ func (x *Content) String() string

+ type CreateRequest struct

+ Attributes []*AttributeEntry

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

+ func (*CreateRequest) ProtoMessage()

+ func (x *CreateRequest) GetAttributes() []*AttributeEntry

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

+ func (x *CreateRequest) Reset()

+ func (x *CreateRequest) String() string

+ type DeleteRequest struct

+ UserId string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetUserId() string

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

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type GetRequest struct

+ UserId string

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

+ func (*GetRequest) ProtoMessage()

+ func (x *GetRequest) GetUserId() string

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

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ type LookupRequest struct

+ Attribute string

+ Key string

+ LookupType LookupType

+ SelectAttributes []string

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

+ func (*LookupRequest) ProtoMessage()

+ func (x *LookupRequest) GetAttribute() string

+ func (x *LookupRequest) GetKey() string

+ func (x *LookupRequest) GetLookupType() LookupType

+ func (x *LookupRequest) GetSelectAttributes() []string

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

+ func (x *LookupRequest) Reset()

+ func (x *LookupRequest) String() string

+ type LookupType int32

+ const LookupType_BY_ATTRIBUTE

+ const LookupType_BY_USER

+ const LookupType_UNKNOWN_LOOKUP

+ func (LookupType) Descriptor() protoreflect.EnumDescriptor

+ func (LookupType) EnumDescriptor() ([]byte, []int)

+ func (LookupType) Type() protoreflect.EnumType

+ func (x LookupType) Enum() *LookupType

+ func (x LookupType) Number() protoreflect.EnumNumber

+ func (x LookupType) String() string

+ type Metadata struct

+ Attributes []*Attribute

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

+ func (*Metadata) ProtoMessage()

+ func (x *Metadata) GetAttributes() []*Attribute

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

+ func (x *Metadata) Reset()

+ func (x *Metadata) String() string

+ type RaftConfiguration struct

+ LastIndex uint64

+ ServerList []*RaftServer

+ State string

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

+ func (*RaftConfiguration) ProtoMessage()

+ func (x *RaftConfiguration) GetLastIndex() uint64

+ func (x *RaftConfiguration) GetServerList() []*RaftServer

+ func (x *RaftConfiguration) GetState() string

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

+ func (x *RaftConfiguration) Reset()

+ func (x *RaftConfiguration) String() string

+ type RaftNode struct

+ NodeAddr string

+ NodeId string

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

+ func (*RaftNode) ProtoMessage()

+ func (x *RaftNode) GetNodeAddr() string

+ func (x *RaftNode) GetNodeId() string

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

+ func (x *RaftNode) Reset()

+ func (x *RaftNode) String() string

+ type RaftServer struct

+ GrpcAddr string

+ NodeId string

+ RaftAddr string

+ Suffrage string

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

+ func (*RaftServer) ProtoMessage()

+ func (x *RaftServer) GetGrpcAddr() string

+ func (x *RaftServer) GetNodeId() string

+ func (x *RaftServer) GetRaftAddr() string

+ func (x *RaftServer) GetSuffrage() string

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

+ func (x *RaftServer) Reset()

+ func (x *RaftServer) String() string

+ type ScanRequest struct

+ Limit int32

+ Prefix string

+ Seek string

+ SelectAttributes []string

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

+ func (*ScanRequest) ProtoMessage()

+ func (x *ScanRequest) GetLimit() int32

+ func (x *ScanRequest) GetPrefix() string

+ func (x *ScanRequest) GetSeek() string

+ func (x *ScanRequest) GetSelectAttributes() []string

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

+ func (x *ScanRequest) Reset()

+ func (x *ScanRequest) String() string

+ type SchemeRequest struct

+ Attributes []*Attribute

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

+ func (*SchemeRequest) ProtoMessage()

+ func (x *SchemeRequest) GetAttributes() []*Attribute

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

+ func (x *SchemeRequest) Reset()

+ func (x *SchemeRequest) String() string

+ type SearchRequest struct

+ Attribute string

+ Key string

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

+ func (*SearchRequest) ProtoMessage()

+ func (x *SearchRequest) GetAttribute() string

+ func (x *SearchRequest) GetKey() string

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

+ func (x *SearchRequest) Reset()

+ func (x *SearchRequest) String() string

+ type Status struct

+ Elapsed float64

+ Updated bool

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

+ func (*Status) ProtoMessage()

+ func (x *Status) GetElapsed() float64

+ func (x *Status) GetUpdated() bool

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

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type UnimplementedUserRaftServiceServer struct

+ func (UnimplementedUserRaftServiceServer) ApplyCommand(context.Context, *Command) (*Status, error)

+ func (UnimplementedUserRaftServiceServer) Bootstrap(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedUserRaftServiceServer) GetConfiguration(context.Context, *emptypb.Empty) (*RaftConfiguration, error)

+ func (UnimplementedUserRaftServiceServer) Join(context.Context, *RaftNode) (*emptypb.Empty, error)

+ func (UnimplementedUserRaftServiceServer) Recover(UserRaftService_RecoverServer) error

+ type UnimplementedUserServiceServer struct

+ func (UnimplementedUserServiceServer) Create(context.Context, *CreateRequest) (*UserEntry, error)

+ func (UnimplementedUserServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ func (UnimplementedUserServiceServer) Get(context.Context, *GetRequest) (*UserEntry, error)

+ func (UnimplementedUserServiceServer) GetMetadata(context.Context, *emptypb.Empty) (*Metadata, error)

+ func (UnimplementedUserServiceServer) Lookup(context.Context, *LookupRequest) (*UserEntry, error)

+ func (UnimplementedUserServiceServer) Scan(*ScanRequest, UserService_ScanServer) error

+ func (UnimplementedUserServiceServer) Search(*SearchRequest, UserService_SearchServer) error

+ func (UnimplementedUserServiceServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)

+ func (UnimplementedUserServiceServer) UpdateScheme(context.Context, *SchemeRequest) (*emptypb.Empty, error)

+ type UnsafeUserRaftServiceServer interface

+ type UnsafeUserServiceServer interface

+ type UpdateRequest struct

+ Attributes []*AttributeEntry

+ Cas bool

+ CasVersion int64

+ UpdateType UpdateType

+ UserId string

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

+ func (*UpdateRequest) ProtoMessage()

+ func (x *UpdateRequest) GetAttributes() []*AttributeEntry

+ func (x *UpdateRequest) GetCas() bool

+ func (x *UpdateRequest) GetCasVersion() int64

+ func (x *UpdateRequest) GetUpdateType() UpdateType

+ func (x *UpdateRequest) GetUserId() string

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

+ func (x *UpdateRequest) Reset()

+ func (x *UpdateRequest) String() string

+ type UpdateType int32

+ const UpdateType_MERGE

+ const UpdateType_REPLACE

+ const UpdateType_UNKNOWN_TYPE

+ func (UpdateType) Descriptor() protoreflect.EnumDescriptor

+ func (UpdateType) EnumDescriptor() ([]byte, []int)

+ func (UpdateType) Type() protoreflect.EnumType

+ func (x UpdateType) Enum() *UpdateType

+ func (x UpdateType) Number() protoreflect.EnumNumber

+ func (x UpdateType) String() string

+ type UserEntry struct

+ Attributes []*AttributeEntry

+ UserId string

+ Version int64

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

+ func (*UserEntry) ProtoMessage()

+ func (x *UserEntry) GetAttributes() []*AttributeEntry

+ func (x *UserEntry) GetUserId() string

+ func (x *UserEntry) GetVersion() int64

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

+ func (x *UserEntry) Reset()

+ func (x *UserEntry) String() string

+ type UserRaftServiceClient interface

+ ApplyCommand func(ctx context.Context, in *Command, opts ...grpc.CallOption) (*Status, error)

+ Bootstrap func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetConfiguration func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RaftConfiguration, error)

+ Join func(ctx context.Context, in *RaftNode, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Recover func(ctx context.Context, opts ...grpc.CallOption) (UserRaftService_RecoverClient, error)

+ func NewUserRaftServiceClient(cc grpc.ClientConnInterface) UserRaftServiceClient

+ type UserRaftServiceServer interface

+ ApplyCommand func(context.Context, *Command) (*Status, error)

+ Bootstrap func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ GetConfiguration func(context.Context, *emptypb.Empty) (*RaftConfiguration, error)

+ Join func(context.Context, *RaftNode) (*emptypb.Empty, error)

+ Recover func(UserRaftService_RecoverServer) error

+ type UserRaftService_RecoverClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*Content) error

+ type UserRaftService_RecoverServer interface

+ Recv func() (*Content, error)

+ SendAndClose func(*emptypb.Empty) error

+ type UserServiceClient interface

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*UserEntry, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*UserEntry, error)

+ GetMetadata func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Metadata, error)

+ Lookup func(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*UserEntry, error)

+ Scan func(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (UserService_ScanClient, error)

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (UserService_SearchClient, error)

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateScheme func(ctx context.Context, in *SchemeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient

+ type UserServiceServer interface

+ Create func(context.Context, *CreateRequest) (*UserEntry, error)

+ Delete func(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ Get func(context.Context, *GetRequest) (*UserEntry, error)

+ GetMetadata func(context.Context, *emptypb.Empty) (*Metadata, error)

+ Lookup func(context.Context, *LookupRequest) (*UserEntry, error)

+ Scan func(*ScanRequest, UserService_ScanServer) error

+ Search func(*SearchRequest, UserService_SearchServer) error

+ Update func(context.Context, *UpdateRequest) (*emptypb.Empty, error)

+ UpdateScheme func(context.Context, *SchemeRequest) (*emptypb.Empty, error)

+ type UserService_ScanClient interface

+ Recv func() (*UserEntry, error)

+ type UserService_ScanServer interface

+ Send func(*UserEntry) error

+ type UserService_SearchClient interface

+ Recv func() (*UserEntry, error)

+ type UserService_SearchServer interface

+ Send func(*UserEntry) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL