client

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnumStatus_name = map[int32]string{
		0: "OK",
		1: "ERROR",
	}
	EnumStatus_value = map[string]int32{
		"OK":    0,
		"ERROR": 1,
	}
)

Enum value maps for EnumStatus.

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: "GetKeygroupReplica",
			Handler:    _Client_GetKeygroupReplica_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 AppendRequest 

type AppendRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Data     string `protobuf:"bytes,2,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) 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) (*StatusResponse, error)
	DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*StatusResponse, 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) (*StatusResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	AddReplica(ctx context.Context, in *AddReplicaRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	GetKeygroupReplica(ctx context.Context, in *GetKeygroupReplicaRequest, opts ...grpc.CallOption) (*GetKeygroupReplicaResponse, error)
	RemoveReplica(ctx context.Context, in *RemoveReplicaRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	GetReplica(ctx context.Context, in *GetReplicaRequest, opts ...grpc.CallOption) (*GetReplicaResponse, error)
	GetAllReplica(ctx context.Context, in *GetAllReplicaRequest, 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) (*StatusResponse, error)
	RemoveTrigger(ctx context.Context, in *RemoveTriggerRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	AddUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	RemoveUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*StatusResponse, 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) (*StatusResponse, error)
	DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*StatusResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Scan(context.Context, *ScanRequest) (*ScanResponse, error)
	Update(context.Context, *UpdateRequest) (*StatusResponse, error)
	Delete(context.Context, *DeleteRequest) (*StatusResponse, error)
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	AddReplica(context.Context, *AddReplicaRequest) (*StatusResponse, error)
	GetKeygroupReplica(context.Context, *GetKeygroupReplicaRequest) (*GetKeygroupReplicaResponse, error)
	RemoveReplica(context.Context, *RemoveReplicaRequest) (*StatusResponse, error)
	GetReplica(context.Context, *GetReplicaRequest) (*GetReplicaResponse, error)
	GetAllReplica(context.Context, *GetAllReplicaRequest) (*GetAllReplicaResponse, error)
	GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
	AddTrigger(context.Context, *AddTriggerRequest) (*StatusResponse, error)
	RemoveTrigger(context.Context, *RemoveTriggerRequest) (*StatusResponse, error)
	AddUser(context.Context, *UserRequest) (*StatusResponse, error)
	RemoveUser(context.Context, *UserRequest) (*StatusResponse, 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 Data 

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

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetId 

func (x *Data) GetId() string

func (*Data) GetVal 

func (x *Data) GetVal() string

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) 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"`
	// 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) 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 EnumStatus 

type EnumStatus int32
const (
	EnumStatus_OK    EnumStatus = 0
	EnumStatus_ERROR EnumStatus = 1
)

func (EnumStatus) Descriptor 

func (EnumStatus) Descriptor() protoreflect.EnumDescriptor

func (EnumStatus) Enum 

func (x EnumStatus) Enum() *EnumStatus

func (EnumStatus) EnumDescriptor deprecated 

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

Deprecated: Use EnumStatus.Descriptor instead.

func (EnumStatus) Number 

func (x EnumStatus) Number() protoreflect.EnumNumber

func (EnumStatus) String 

func (x EnumStatus) String() string

func (EnumStatus) Type 

func (EnumStatus) Type() protoreflect.EnumType

type GetAllReplicaRequest 

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

func (*GetAllReplicaRequest) Descriptor deprecated 

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

Deprecated: Use GetAllReplicaRequest.ProtoReflect.Descriptor instead.

func (*GetAllReplicaRequest) ProtoMessage 

func (*GetAllReplicaRequest) ProtoMessage()

func (*GetAllReplicaRequest) ProtoReflect 

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

func (*GetAllReplicaRequest) Reset 

func (x *GetAllReplicaRequest) Reset()

func (*GetAllReplicaRequest) String 

func (x *GetAllReplicaRequest) String() string

type GetAllReplicaResponse 

type GetAllReplicaResponse struct {
	Replicas []*GetReplicaResponse `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() []*GetReplicaResponse

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 GetKeygroupReplicaRequest 

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

func (*GetKeygroupReplicaRequest) Descriptor deprecated 

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

Deprecated: Use GetKeygroupReplicaRequest.ProtoReflect.Descriptor instead.

func (*GetKeygroupReplicaRequest) GetKeygroup 

func (x *GetKeygroupReplicaRequest) GetKeygroup() string

func (*GetKeygroupReplicaRequest) ProtoMessage 

func (*GetKeygroupReplicaRequest) ProtoMessage()

func (*GetKeygroupReplicaRequest) ProtoReflect 

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

func (*GetKeygroupReplicaRequest) Reset 

func (x *GetKeygroupReplicaRequest) Reset()

func (*GetKeygroupReplicaRequest) String 

func (x *GetKeygroupReplicaRequest) String() string

type GetKeygroupReplicaResponse 

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

func (*GetKeygroupReplicaResponse) Descriptor deprecated 

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

Deprecated: Use GetKeygroupReplicaResponse.ProtoReflect.Descriptor instead.

func (*GetKeygroupReplicaResponse) GetReplica 

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

func (*GetKeygroupReplicaResponse) ProtoMessage 

func (*GetKeygroupReplicaResponse) ProtoMessage()

func (*GetKeygroupReplicaResponse) ProtoReflect 

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

func (*GetKeygroupReplicaResponse) Reset 

func (x *GetKeygroupReplicaResponse) Reset()

func (*GetKeygroupReplicaResponse) String 

func (x *GetKeygroupReplicaResponse) 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 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"`
	// 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) 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 string `protobuf:"bytes,1,opt,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() string

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 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 []*Data `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() []*Data

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 StatusResponse 

type StatusResponse struct {
	Status EnumStatus `protobuf:"varint,1,opt,name=status,proto3,enum=mcc.fred.client.EnumStatus" json:"status,omitempty"`
	// This is an optional message, only to be sent if the status is not OK
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetErrorMessage 

func (x *StatusResponse) GetErrorMessage() string

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() EnumStatus

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) 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) (*StatusResponse, error)

func (UnimplementedClientServer) AddTrigger 

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

func (UnimplementedClientServer) AddUser 

func (UnimplementedClientServer) AddUser(context.Context, *UserRequest) (*StatusResponse, error)

func (UnimplementedClientServer) Append 

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

func (UnimplementedClientServer) CreateKeygroup 

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

func (UnimplementedClientServer) Delete 

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

func (UnimplementedClientServer) DeleteKeygroup 

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

func (UnimplementedClientServer) GetAllReplica 

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

func (UnimplementedClientServer) GetKeygroupReplica 

func (UnimplementedClientServer) GetKeygroupReplica(context.Context, *GetKeygroupReplicaRequest) (*GetKeygroupReplicaResponse, 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) (*StatusResponse, error)

func (UnimplementedClientServer) RemoveTrigger 

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

func (UnimplementedClientServer) RemoveUser 

func (UnimplementedClientServer) RemoveUser(context.Context, *UserRequest) (*StatusResponse, error)

func (UnimplementedClientServer) Scan 

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

func (UnimplementedClientServer) Update 

func (UnimplementedClientServer) Update(context.Context, *UpdateRequest) (*StatusResponse, 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"`
	// 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) 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 UserRequest 

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

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

Deprecated: Use UserRequest.ProtoReflect.Descriptor instead.

func (*UserRequest) GetKeygroup 

func (x *UserRequest) GetKeygroup() string

func (*UserRequest) GetRole 

func (x *UserRequest) GetRole() UserRole

func (*UserRequest) GetUser 

func (x *UserRequest) GetUser() string

func (*UserRequest) ProtoMessage 

func (*UserRequest) ProtoMessage()

func (*UserRequest) ProtoReflect 

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

func (*UserRequest) Reset 

func (x *UserRequest) Reset()

func (*UserRequest) String 

func (x *UserRequest) 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

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.