client

package
v0.2.16 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	UserRole_name = map[int32]string{
		0: "ReadKeygroup",
		1: "WriteKeygroup",
		2: "ConfigureReplica",
		3: "ConfigureTrigger",
		4: "ConfigureKeygroups",
	}
	UserRole_value = map[string]int32{
		"ReadKeygroup":       0,
		"WriteKeygroup":      1,
		"ConfigureReplica":   2,
		"ConfigureTrigger":   3,
		"ConfigureKeygroups": 4,
	}
)

Enum value maps for UserRole.

View Source
var Client_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mcc.fred.client.Client",
	HandlerType: (*ClientServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateKeygroup",
			Handler:    _Client_CreateKeygroup_Handler,
		},
		{
			MethodName: "DeleteKeygroup",
			Handler:    _Client_DeleteKeygroup_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Client_Read_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _Client_Scan_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Client_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Client_Delete_Handler,
		},
		{
			MethodName: "Append",
			Handler:    _Client_Append_Handler,
		},
		{
			MethodName: "AddReplica",
			Handler:    _Client_AddReplica_Handler,
		},
		{
			MethodName: "GetKeygroupInfo",
			Handler:    _Client_GetKeygroupInfo_Handler,
		},
		{
			MethodName: "RemoveReplica",
			Handler:    _Client_RemoveReplica_Handler,
		},
		{
			MethodName: "GetReplica",
			Handler:    _Client_GetReplica_Handler,
		},
		{
			MethodName: "GetAllReplica",
			Handler:    _Client_GetAllReplica_Handler,
		},
		{
			MethodName: "GetKeygroupTriggers",
			Handler:    _Client_GetKeygroupTriggers_Handler,
		},
		{
			MethodName: "AddTrigger",
			Handler:    _Client_AddTrigger_Handler,
		},
		{
			MethodName: "RemoveTrigger",
			Handler:    _Client_RemoveTrigger_Handler,
		},
		{
			MethodName: "AddUser",
			Handler:    _Client_AddUser_Handler,
		},
		{
			MethodName: "RemoveUser",
			Handler:    _Client_RemoveUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "client.proto",
}

Client_ServiceDesc is the grpc.ServiceDesc for Client 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_client_proto protoreflect.FileDescriptor

Functions

func RegisterClientServer

func RegisterClientServer(s grpc.ServiceRegistrar, srv ClientServer)

Types

type AddReplicaRequest

type AddReplicaRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	NodeId   string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Expiry   int64  `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

func (*AddReplicaRequest) Descriptor deprecated

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

Deprecated: Use AddReplicaRequest.ProtoReflect.Descriptor instead.

func (*AddReplicaRequest) GetExpiry

func (x *AddReplicaRequest) GetExpiry() int64

func (*AddReplicaRequest) GetKeygroup

func (x *AddReplicaRequest) GetKeygroup() string

func (*AddReplicaRequest) GetNodeId

func (x *AddReplicaRequest) GetNodeId() string

func (*AddReplicaRequest) ProtoMessage

func (*AddReplicaRequest) ProtoMessage()

func (*AddReplicaRequest) ProtoReflect

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

func (*AddReplicaRequest) Reset

func (x *AddReplicaRequest) Reset()

func (*AddReplicaRequest) String

func (x *AddReplicaRequest) String() string

type AddTriggerRequest

type AddTriggerRequest struct {
	Keygroup    string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	TriggerId   string `protobuf:"bytes,2,opt,name=triggerId,proto3" json:"triggerId,omitempty"`
	TriggerHost string `protobuf:"bytes,3,opt,name=triggerHost,proto3" json:"triggerHost,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTriggerRequest) Descriptor deprecated

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

Deprecated: Use AddTriggerRequest.ProtoReflect.Descriptor instead.

func (*AddTriggerRequest) GetKeygroup

func (x *AddTriggerRequest) GetKeygroup() string

func (*AddTriggerRequest) GetTriggerHost

func (x *AddTriggerRequest) GetTriggerHost() string

func (*AddTriggerRequest) GetTriggerId

func (x *AddTriggerRequest) GetTriggerId() string

func (*AddTriggerRequest) ProtoMessage

func (*AddTriggerRequest) ProtoMessage()

func (*AddTriggerRequest) ProtoReflect

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

func (*AddTriggerRequest) Reset

func (x *AddTriggerRequest) Reset()

func (*AddTriggerRequest) String

func (x *AddTriggerRequest) String() string

type AddUserRequest added in v0.2.1

type AddUserRequest struct {
	User     string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Keygroup string   `protobuf:"bytes,2,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Role     UserRole `protobuf:"varint,3,opt,name=role,proto3,enum=mcc.fred.client.UserRole" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*AddUserRequest) Descriptor deprecated added in v0.2.1

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

Deprecated: Use AddUserRequest.ProtoReflect.Descriptor instead.

func (*AddUserRequest) GetKeygroup added in v0.2.1

func (x *AddUserRequest) GetKeygroup() string

func (*AddUserRequest) GetRole added in v0.2.1

func (x *AddUserRequest) GetRole() UserRole

func (*AddUserRequest) GetUser added in v0.2.1

func (x *AddUserRequest) GetUser() string

func (*AddUserRequest) ProtoMessage added in v0.2.1

func (*AddUserRequest) ProtoMessage()

func (*AddUserRequest) ProtoReflect added in v0.2.1

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

func (*AddUserRequest) Reset added in v0.2.1

func (x *AddUserRequest) Reset()

func (*AddUserRequest) String added in v0.2.1

func (x *AddUserRequest) String() string

type AppendRequest

type AppendRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Data     string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendRequest) Descriptor deprecated

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

Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.

func (*AppendRequest) GetData

func (x *AppendRequest) GetData() string

func (*AppendRequest) GetId added in v0.2.1

func (x *AppendRequest) GetId() uint64

func (*AppendRequest) GetKeygroup

func (x *AppendRequest) GetKeygroup() string

func (*AppendRequest) ProtoMessage

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoReflect

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

func (*AppendRequest) Reset

func (x *AppendRequest) Reset()

func (*AppendRequest) String

func (x *AppendRequest) String() string

type AppendResponse

type AppendResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendResponse) Descriptor deprecated

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

Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.

func (*AppendResponse) GetId

func (x *AppendResponse) GetId() string

func (*AppendResponse) ProtoMessage

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoReflect

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

func (*AppendResponse) Reset

func (x *AppendResponse) Reset()

func (*AppendResponse) String

func (x *AppendResponse) String() string

type ClientClient

type ClientClient interface {
	CreateKeygroup(ctx context.Context, in *CreateKeygroupRequest, opts ...grpc.CallOption) (*Empty, error)
	DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*Empty, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	AddReplica(ctx context.Context, in *AddReplicaRequest, opts ...grpc.CallOption) (*Empty, error)
	GetKeygroupInfo(ctx context.Context, in *GetKeygroupInfoRequest, opts ...grpc.CallOption) (*GetKeygroupInfoResponse, error)
	RemoveReplica(ctx context.Context, in *RemoveReplicaRequest, opts ...grpc.CallOption) (*Empty, error)
	GetReplica(ctx context.Context, in *GetReplicaRequest, opts ...grpc.CallOption) (*GetReplicaResponse, error)
	GetAllReplica(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetAllReplicaResponse, error)
	GetKeygroupTriggers(ctx context.Context, in *GetKeygroupTriggerRequest, opts ...grpc.CallOption) (*GetKeygroupTriggerResponse, error)
	AddTrigger(ctx context.Context, in *AddTriggerRequest, opts ...grpc.CallOption) (*Empty, error)
	RemoveTrigger(ctx context.Context, in *RemoveTriggerRequest, opts ...grpc.CallOption) (*Empty, error)
	AddUser(ctx context.Context, in *AddUserRequest, opts ...grpc.CallOption) (*Empty, error)
	RemoveUser(ctx context.Context, in *RemoveUserRequest, opts ...grpc.CallOption) (*Empty, error)
}

ClientClient is the client API for Client 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 NewClientClient

func NewClientClient(cc grpc.ClientConnInterface) ClientClient

type ClientServer

ClientServer is the server API for Client service. All implementations should embed UnimplementedClientServer for forward compatibility

type CreateKeygroupRequest

type CreateKeygroupRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Mutable  bool   `protobuf:"varint,2,opt,name=mutable,proto3" json:"mutable,omitempty"`
	Expiry   int64  `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeygroupRequest) Descriptor deprecated

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

Deprecated: Use CreateKeygroupRequest.ProtoReflect.Descriptor instead.

func (*CreateKeygroupRequest) GetExpiry

func (x *CreateKeygroupRequest) GetExpiry() int64

func (*CreateKeygroupRequest) GetKeygroup

func (x *CreateKeygroupRequest) GetKeygroup() string

func (*CreateKeygroupRequest) GetMutable

func (x *CreateKeygroupRequest) GetMutable() bool

func (*CreateKeygroupRequest) ProtoMessage

func (*CreateKeygroupRequest) ProtoMessage()

func (*CreateKeygroupRequest) ProtoReflect

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

func (*CreateKeygroupRequest) Reset

func (x *CreateKeygroupRequest) Reset()

func (*CreateKeygroupRequest) String

func (x *CreateKeygroupRequest) String() string

type DeleteKeygroupRequest

type DeleteKeygroupRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeygroupRequest) Descriptor deprecated

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

Deprecated: Use DeleteKeygroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupRequest) GetKeygroup

func (x *DeleteKeygroupRequest) GetKeygroup() string

func (*DeleteKeygroupRequest) ProtoMessage

func (*DeleteKeygroupRequest) ProtoMessage()

func (*DeleteKeygroupRequest) ProtoReflect

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

func (*DeleteKeygroupRequest) Reset

func (x *DeleteKeygroupRequest) Reset()

func (*DeleteKeygroupRequest) String

func (x *DeleteKeygroupRequest) String() string

type DeleteRequest

type DeleteRequest struct {
	Keygroup string     `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Versions []*Version `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetKeygroup

func (x *DeleteRequest) GetKeygroup() string

func (*DeleteRequest) GetVersions added in v0.2.1

func (x *DeleteRequest) GetVersions() []*Version

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type DeleteResponse added in v0.2.1

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

func (*DeleteResponse) Descriptor deprecated added in v0.2.1

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetVersion added in v0.2.1

func (x *DeleteResponse) GetVersion() *Version

func (*DeleteResponse) ProtoMessage added in v0.2.1

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.2.1

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

func (*DeleteResponse) Reset added in v0.2.1

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String added in v0.2.1

func (x *DeleteResponse) String() string

type Empty added in v0.2.1

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

func (*Empty) Descriptor deprecated added in v0.2.1

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage added in v0.2.1

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v0.2.1

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

func (*Empty) Reset added in v0.2.1

func (x *Empty) Reset()

func (*Empty) String added in v0.2.1

func (x *Empty) String() string

type GetAllReplicaResponse

type GetAllReplicaResponse struct {
	Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllReplicaResponse) Descriptor deprecated

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

Deprecated: Use GetAllReplicaResponse.ProtoReflect.Descriptor instead.

func (*GetAllReplicaResponse) GetReplicas

func (x *GetAllReplicaResponse) GetReplicas() []*Replica

func (*GetAllReplicaResponse) ProtoMessage

func (*GetAllReplicaResponse) ProtoMessage()

func (*GetAllReplicaResponse) ProtoReflect

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

func (*GetAllReplicaResponse) Reset

func (x *GetAllReplicaResponse) Reset()

func (*GetAllReplicaResponse) String

func (x *GetAllReplicaResponse) String() string

type GetKeygroupInfoRequest added in v0.2.2

type GetKeygroupInfoRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeygroupInfoRequest) Descriptor deprecated added in v0.2.2

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

Deprecated: Use GetKeygroupInfoRequest.ProtoReflect.Descriptor instead.

func (*GetKeygroupInfoRequest) GetKeygroup added in v0.2.2

func (x *GetKeygroupInfoRequest) GetKeygroup() string

func (*GetKeygroupInfoRequest) ProtoMessage added in v0.2.2

func (*GetKeygroupInfoRequest) ProtoMessage()

func (*GetKeygroupInfoRequest) ProtoReflect added in v0.2.2

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

func (*GetKeygroupInfoRequest) Reset added in v0.2.2

func (x *GetKeygroupInfoRequest) Reset()

func (*GetKeygroupInfoRequest) String added in v0.2.2

func (x *GetKeygroupInfoRequest) String() string

type GetKeygroupInfoResponse added in v0.2.2

type GetKeygroupInfoResponse struct {
	Mutable bool               `protobuf:"varint,1,opt,name=mutable,proto3" json:"mutable,omitempty"`
	Replica []*KeygroupReplica `protobuf:"bytes,2,rep,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeygroupInfoResponse) Descriptor deprecated added in v0.2.2

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

Deprecated: Use GetKeygroupInfoResponse.ProtoReflect.Descriptor instead.

func (*GetKeygroupInfoResponse) GetMutable added in v0.2.2

func (x *GetKeygroupInfoResponse) GetMutable() bool

func (*GetKeygroupInfoResponse) GetReplica added in v0.2.2

func (x *GetKeygroupInfoResponse) GetReplica() []*KeygroupReplica

func (*GetKeygroupInfoResponse) ProtoMessage added in v0.2.2

func (*GetKeygroupInfoResponse) ProtoMessage()

func (*GetKeygroupInfoResponse) ProtoReflect added in v0.2.2

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

func (*GetKeygroupInfoResponse) Reset added in v0.2.2

func (x *GetKeygroupInfoResponse) Reset()

func (*GetKeygroupInfoResponse) String added in v0.2.2

func (x *GetKeygroupInfoResponse) String() string

type GetKeygroupTriggerRequest

type GetKeygroupTriggerRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeygroupTriggerRequest) Descriptor deprecated

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

Deprecated: Use GetKeygroupTriggerRequest.ProtoReflect.Descriptor instead.

func (*GetKeygroupTriggerRequest) GetKeygroup

func (x *GetKeygroupTriggerRequest) GetKeygroup() string

func (*GetKeygroupTriggerRequest) ProtoMessage

func (*GetKeygroupTriggerRequest) ProtoMessage()

func (*GetKeygroupTriggerRequest) ProtoReflect

func (*GetKeygroupTriggerRequest) Reset

func (x *GetKeygroupTriggerRequest) Reset()

func (*GetKeygroupTriggerRequest) String

func (x *GetKeygroupTriggerRequest) String() string

type GetKeygroupTriggerResponse

type GetKeygroupTriggerResponse struct {
	Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeygroupTriggerResponse) Descriptor deprecated

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

Deprecated: Use GetKeygroupTriggerResponse.ProtoReflect.Descriptor instead.

func (*GetKeygroupTriggerResponse) GetTriggers

func (x *GetKeygroupTriggerResponse) GetTriggers() []*Trigger

func (*GetKeygroupTriggerResponse) ProtoMessage

func (*GetKeygroupTriggerResponse) ProtoMessage()

func (*GetKeygroupTriggerResponse) ProtoReflect

func (*GetKeygroupTriggerResponse) Reset

func (x *GetKeygroupTriggerResponse) Reset()

func (*GetKeygroupTriggerResponse) String

func (x *GetKeygroupTriggerResponse) String() string

type GetReplicaRequest

type GetReplicaRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicaRequest) Descriptor deprecated

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

Deprecated: Use GetReplicaRequest.ProtoReflect.Descriptor instead.

func (*GetReplicaRequest) GetNodeId

func (x *GetReplicaRequest) GetNodeId() string

func (*GetReplicaRequest) ProtoMessage

func (*GetReplicaRequest) ProtoMessage()

func (*GetReplicaRequest) ProtoReflect

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

func (*GetReplicaRequest) Reset

func (x *GetReplicaRequest) Reset()

func (*GetReplicaRequest) String

func (x *GetReplicaRequest) String() string

type GetReplicaResponse

type GetReplicaResponse struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Host   string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicaResponse) Descriptor deprecated

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

Deprecated: Use GetReplicaResponse.ProtoReflect.Descriptor instead.

func (*GetReplicaResponse) GetHost

func (x *GetReplicaResponse) GetHost() string

func (*GetReplicaResponse) GetNodeId

func (x *GetReplicaResponse) GetNodeId() string

func (*GetReplicaResponse) ProtoMessage

func (*GetReplicaResponse) ProtoMessage()

func (*GetReplicaResponse) ProtoReflect

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

func (*GetReplicaResponse) Reset

func (x *GetReplicaResponse) Reset()

func (*GetReplicaResponse) String

func (x *GetReplicaResponse) String() string

type Item added in v0.2.1

type Item struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Val     string   `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	Version *Version `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Item) Descriptor deprecated added in v0.2.1

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetId added in v0.2.1

func (x *Item) GetId() string

func (*Item) GetVal added in v0.2.1

func (x *Item) GetVal() string

func (*Item) GetVersion added in v0.2.1

func (x *Item) GetVersion() *Version

func (*Item) ProtoMessage added in v0.2.1

func (*Item) ProtoMessage()

func (*Item) ProtoReflect added in v0.2.1

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

func (*Item) Reset added in v0.2.1

func (x *Item) Reset()

func (*Item) String added in v0.2.1

func (x *Item) String() string

type KeygroupReplica

type KeygroupReplica struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Expiry int64  `protobuf:"varint,2,opt,name=expiry,proto3" json:"expiry,omitempty"`
	Host   string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*KeygroupReplica) Descriptor deprecated

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

Deprecated: Use KeygroupReplica.ProtoReflect.Descriptor instead.

func (*KeygroupReplica) GetExpiry

func (x *KeygroupReplica) GetExpiry() int64

func (*KeygroupReplica) GetHost

func (x *KeygroupReplica) GetHost() string

func (*KeygroupReplica) GetNodeId

func (x *KeygroupReplica) GetNodeId() string

func (*KeygroupReplica) ProtoMessage

func (*KeygroupReplica) ProtoMessage()

func (*KeygroupReplica) ProtoReflect

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

func (*KeygroupReplica) Reset

func (x *KeygroupReplica) Reset()

func (*KeygroupReplica) String

func (x *KeygroupReplica) String() string

type ReadRequest

type ReadRequest struct {
	Keygroup string     `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Versions []*Version `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetId

func (x *ReadRequest) GetId() string

func (*ReadRequest) GetKeygroup

func (x *ReadRequest) GetKeygroup() string

func (*ReadRequest) GetVersions added in v0.2.1

func (x *ReadRequest) GetVersions() []*Version

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect

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

func (*ReadRequest) Reset

func (x *ReadRequest) Reset()

func (*ReadRequest) String

func (x *ReadRequest) String() string

type ReadResponse

type ReadResponse struct {
	Data []*Item `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetData

func (x *ReadResponse) GetData() []*Item

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

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

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) String

func (x *ReadResponse) String() string

type RemoveReplicaRequest

type RemoveReplicaRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	NodeId   string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveReplicaRequest) Descriptor deprecated

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

Deprecated: Use RemoveReplicaRequest.ProtoReflect.Descriptor instead.

func (*RemoveReplicaRequest) GetKeygroup

func (x *RemoveReplicaRequest) GetKeygroup() string

func (*RemoveReplicaRequest) GetNodeId

func (x *RemoveReplicaRequest) GetNodeId() string

func (*RemoveReplicaRequest) ProtoMessage

func (*RemoveReplicaRequest) ProtoMessage()

func (*RemoveReplicaRequest) ProtoReflect

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

func (*RemoveReplicaRequest) Reset

func (x *RemoveReplicaRequest) Reset()

func (*RemoveReplicaRequest) String

func (x *RemoveReplicaRequest) String() string

type RemoveTriggerRequest

type RemoveTriggerRequest struct {
	Keygroup  string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	TriggerId string `protobuf:"bytes,2,opt,name=triggerId,proto3" json:"triggerId,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveTriggerRequest) Descriptor deprecated

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

Deprecated: Use RemoveTriggerRequest.ProtoReflect.Descriptor instead.

func (*RemoveTriggerRequest) GetKeygroup

func (x *RemoveTriggerRequest) GetKeygroup() string

func (*RemoveTriggerRequest) GetTriggerId

func (x *RemoveTriggerRequest) GetTriggerId() string

func (*RemoveTriggerRequest) ProtoMessage

func (*RemoveTriggerRequest) ProtoMessage()

func (*RemoveTriggerRequest) ProtoReflect

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

func (*RemoveTriggerRequest) Reset

func (x *RemoveTriggerRequest) Reset()

func (*RemoveTriggerRequest) String

func (x *RemoveTriggerRequest) String() string

type RemoveUserRequest added in v0.2.1

type RemoveUserRequest struct {
	User     string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Keygroup string   `protobuf:"bytes,2,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Role     UserRole `protobuf:"varint,3,opt,name=role,proto3,enum=mcc.fred.client.UserRole" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveUserRequest) Descriptor deprecated added in v0.2.1

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

Deprecated: Use RemoveUserRequest.ProtoReflect.Descriptor instead.

func (*RemoveUserRequest) GetKeygroup added in v0.2.1

func (x *RemoveUserRequest) GetKeygroup() string

func (*RemoveUserRequest) GetRole added in v0.2.1

func (x *RemoveUserRequest) GetRole() UserRole

func (*RemoveUserRequest) GetUser added in v0.2.1

func (x *RemoveUserRequest) GetUser() string

func (*RemoveUserRequest) ProtoMessage added in v0.2.1

func (*RemoveUserRequest) ProtoMessage()

func (*RemoveUserRequest) ProtoReflect added in v0.2.1

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

func (*RemoveUserRequest) Reset added in v0.2.1

func (x *RemoveUserRequest) Reset()

func (*RemoveUserRequest) String added in v0.2.1

func (x *RemoveUserRequest) String() string

type Replica added in v0.2.1

type Replica struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Host   string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*Replica) Descriptor deprecated added in v0.2.1

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

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetHost added in v0.2.1

func (x *Replica) GetHost() string

func (*Replica) GetNodeId added in v0.2.1

func (x *Replica) GetNodeId() string

func (*Replica) ProtoMessage added in v0.2.1

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect added in v0.2.1

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

func (*Replica) Reset added in v0.2.1

func (x *Replica) Reset()

func (*Replica) String added in v0.2.1

func (x *Replica) String() string

type ScanRequest

type ScanRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Count    uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRequest) Descriptor deprecated

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

Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.

func (*ScanRequest) GetCount

func (x *ScanRequest) GetCount() uint64

func (*ScanRequest) GetId

func (x *ScanRequest) GetId() string

func (*ScanRequest) GetKeygroup

func (x *ScanRequest) GetKeygroup() string

func (*ScanRequest) ProtoMessage

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) ProtoReflect

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

func (*ScanRequest) Reset

func (x *ScanRequest) Reset()

func (*ScanRequest) String

func (x *ScanRequest) String() string

type ScanResponse

type ScanResponse struct {
	Data []*Item `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanResponse) Descriptor deprecated

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

Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.

func (*ScanResponse) GetData

func (x *ScanResponse) GetData() []*Item

func (*ScanResponse) ProtoMessage

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) ProtoReflect

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

func (*ScanResponse) Reset

func (x *ScanResponse) Reset()

func (*ScanResponse) String

func (x *ScanResponse) String() string

type Trigger

type Trigger struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor deprecated

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetHost

func (x *Trigger) GetHost() string

func (*Trigger) GetId

func (x *Trigger) GetId() string

func (*Trigger) ProtoMessage

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect

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

func (*Trigger) Reset

func (x *Trigger) Reset()

func (*Trigger) String

func (x *Trigger) String() string

type UnimplementedClientServer

type UnimplementedClientServer struct {
}

UnimplementedClientServer should be embedded to have forward compatible implementations.

func (UnimplementedClientServer) AddReplica

func (UnimplementedClientServer) AddTrigger

func (UnimplementedClientServer) AddUser

func (UnimplementedClientServer) Append

func (UnimplementedClientServer) CreateKeygroup

func (UnimplementedClientServer) Delete

func (UnimplementedClientServer) DeleteKeygroup

func (UnimplementedClientServer) GetAllReplica

func (UnimplementedClientServer) GetKeygroupInfo added in v0.2.2

func (UnimplementedClientServer) GetReplica

func (UnimplementedClientServer) Read

func (UnimplementedClientServer) RemoveReplica

func (UnimplementedClientServer) RemoveTrigger

func (UnimplementedClientServer) RemoveUser

func (UnimplementedClientServer) Scan

func (UnimplementedClientServer) Update

type UnsafeClientServer

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

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

type UpdateRequest

type UpdateRequest struct {
	Keygroup string     `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Data     string     `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Versions []*Version `protobuf:"bytes,4,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetData

func (x *UpdateRequest) GetData() string

func (*UpdateRequest) GetId

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetKeygroup

func (x *UpdateRequest) GetKeygroup() string

func (*UpdateRequest) GetVersions added in v0.2.1

func (x *UpdateRequest) GetVersions() []*Version

func (*UpdateRequest) ProtoMessage

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect

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

func (*UpdateRequest) Reset

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String

func (x *UpdateRequest) String() string

type UpdateResponse added in v0.2.1

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

func (*UpdateResponse) Descriptor deprecated added in v0.2.1

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) GetVersion added in v0.2.1

func (x *UpdateResponse) GetVersion() *Version

func (*UpdateResponse) ProtoMessage added in v0.2.1

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect added in v0.2.1

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

func (*UpdateResponse) Reset added in v0.2.1

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String added in v0.2.1

func (x *UpdateResponse) String() string

type UserRole

type UserRole int32
const (
	UserRole_ReadKeygroup       UserRole = 0
	UserRole_WriteKeygroup      UserRole = 1
	UserRole_ConfigureReplica   UserRole = 2
	UserRole_ConfigureTrigger   UserRole = 3
	UserRole_ConfigureKeygroups UserRole = 4
)

func (UserRole) Descriptor

func (UserRole) Descriptor() protoreflect.EnumDescriptor

func (UserRole) Enum

func (x UserRole) Enum() *UserRole

func (UserRole) EnumDescriptor deprecated

func (UserRole) EnumDescriptor() ([]byte, []int)

Deprecated: Use UserRole.Descriptor instead.

func (UserRole) Number

func (x UserRole) Number() protoreflect.EnumNumber

func (UserRole) String

func (x UserRole) String() string

func (UserRole) Type

type Version added in v0.2.1

type Version struct {
	Version map[string]uint64 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Version) Descriptor deprecated added in v0.2.1

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetVersion added in v0.2.1

func (x *Version) GetVersion() map[string]uint64

func (*Version) ProtoMessage added in v0.2.1

func (*Version) ProtoMessage()

func (*Version) ProtoReflect added in v0.2.1

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

func (*Version) Reset added in v0.2.1

func (x *Version) Reset()

func (*Version) String added in v0.2.1

func (x *Version) String() string

Jump to

Keyboard shortcuts

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