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 

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

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 (x *GetKeygroupTriggerRequest) ProtoReflect() protoreflect.Message

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 (x *GetKeygroupTriggerResponse) ProtoReflect() protoreflect.Message

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) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error)

func (UnimplementedClientServer) AddTrigger 

func (UnimplementedClientServer) AddTrigger(context.Context, *AddTriggerRequest) (*Empty, error)

func (UnimplementedClientServer) AddUser 

func (UnimplementedClientServer) AddUser(context.Context, *AddUserRequest) (*Empty, error)

func (UnimplementedClientServer) Append 

func (UnimplementedClientServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)

func (UnimplementedClientServer) CreateKeygroup 

func (UnimplementedClientServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*Empty, error)

func (UnimplementedClientServer) Delete 

func (UnimplementedClientServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedClientServer) DeleteKeygroup 

func (UnimplementedClientServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*Empty, error)

func (UnimplementedClientServer) GetAllReplica 

func (UnimplementedClientServer) GetAllReplica(context.Context, *Empty) (*GetAllReplicaResponse, error)

func (UnimplementedClientServer) GetKeygroupInfo added in v0.2.2 

func (UnimplementedClientServer) GetKeygroupInfo(context.Context, *GetKeygroupInfoRequest) (*GetKeygroupInfoResponse, error)

func (UnimplementedClientServer) GetKeygroupTriggers 

func (UnimplementedClientServer) GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)

func (UnimplementedClientServer) GetReplica 

func (UnimplementedClientServer) GetReplica(context.Context, *GetReplicaRequest) (*GetReplicaResponse, error)

func (UnimplementedClientServer) Read 

func (UnimplementedClientServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

func (UnimplementedClientServer) RemoveReplica 

func (UnimplementedClientServer) RemoveReplica(context.Context, *RemoveReplicaRequest) (*Empty, error)

func (UnimplementedClientServer) RemoveTrigger 

func (UnimplementedClientServer) RemoveTrigger(context.Context, *RemoveTriggerRequest) (*Empty, error)

func (UnimplementedClientServer) RemoveUser 

func (UnimplementedClientServer) RemoveUser(context.Context, *RemoveUserRequest) (*Empty, error)

func (UnimplementedClientServer) Scan 

func (UnimplementedClientServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)

func (UnimplementedClientServer) Update 

func (UnimplementedClientServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

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 

func (UserRole) Type() protoreflect.EnumType

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

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.