middleware

package
v0.2.18 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 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 File_middleware_proto protoreflect.FileDescriptor
View Source 
var Middleware_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mcc.fred.middleware.Middleware",
	HandlerType: (*MiddlewareServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateKeygroup",
			Handler:    _Middleware_CreateKeygroup_Handler,
		},
		{
			MethodName: "DeleteKeygroup",
			Handler:    _Middleware_DeleteKeygroup_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Middleware_Read_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _Middleware_Scan_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Middleware_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Middleware_Delete_Handler,
		},
		{
			MethodName: "Append",
			Handler:    _Middleware_Append_Handler,
		},
		{
			MethodName: "Notify",
			Handler:    _Middleware_Notify_Handler,
		},
		{
			MethodName: "ChooseReplica",
			Handler:    _Middleware_ChooseReplica_Handler,
		},
		{
			MethodName: "AddReplica",
			Handler:    _Middleware_AddReplica_Handler,
		},
		{
			MethodName: "GetKeygroupInfo",
			Handler:    _Middleware_GetKeygroupInfo_Handler,
		},
		{
			MethodName: "RemoveReplica",
			Handler:    _Middleware_RemoveReplica_Handler,
		},
		{
			MethodName: "GetReplica",
			Handler:    _Middleware_GetReplica_Handler,
		},
		{
			MethodName: "GetAllReplica",
			Handler:    _Middleware_GetAllReplica_Handler,
		},
		{
			MethodName: "GetKeygroupTriggers",
			Handler:    _Middleware_GetKeygroupTriggers_Handler,
		},
		{
			MethodName: "AddTrigger",
			Handler:    _Middleware_AddTrigger_Handler,
		},
		{
			MethodName: "RemoveTrigger",
			Handler:    _Middleware_RemoveTrigger_Handler,
		},
		{
			MethodName: "AddUser",
			Handler:    _Middleware_AddUser_Handler,
		},
		{
			MethodName: "RemoveUser",
			Handler:    _Middleware_RemoveUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "middleware.proto",
}

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

Functions

func RegisterMiddlewareServer 

func RegisterMiddlewareServer(s grpc.ServiceRegistrar, srv MiddlewareServer)

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 ChooseReplicaRequest added in v0.2.3 

type ChooseReplicaRequest 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 (*ChooseReplicaRequest) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use ChooseReplicaRequest.ProtoReflect.Descriptor instead.

func (*ChooseReplicaRequest) GetKeygroup added in v0.2.3 

func (x *ChooseReplicaRequest) GetKeygroup() string

func (*ChooseReplicaRequest) GetNodeId added in v0.2.3 

func (x *ChooseReplicaRequest) GetNodeId() string

func (*ChooseReplicaRequest) ProtoMessage added in v0.2.3 

func (*ChooseReplicaRequest) ProtoMessage()

func (*ChooseReplicaRequest) ProtoReflect added in v0.2.3 

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

func (*ChooseReplicaRequest) Reset added in v0.2.3 

func (x *ChooseReplicaRequest) Reset()

func (*ChooseReplicaRequest) String added in v0.2.3 

func (x *ChooseReplicaRequest) String() string

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"`
	FirstNodeId string `protobuf:"bytes,4,opt,name=firstNodeId,proto3" json:"firstNodeId,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) GetFirstNodeId 

func (x *CreateKeygroupRequest) GetFirstNodeId() string

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"`
	Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetData 

func (x *Data) GetData() string

func (*Data) GetId 

func (x *Data) GetId() 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 Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

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 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 map[string]uint64 `` /* 156-byte string literal not displayed */
	// 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() map[string]uint64

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 MiddlewareClient 

type MiddlewareClient 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) (*Empty, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Empty, error)
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	Notify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*Empty, error)
	ChooseReplica(ctx context.Context, in *ChooseReplicaRequest, opts ...grpc.CallOption) (*Empty, 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 *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) (*Empty, error)
	RemoveTrigger(ctx context.Context, in *RemoveTriggerRequest, opts ...grpc.CallOption) (*Empty, error)
	AddUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*Empty, error)
	RemoveUser(ctx context.Context, in *UserRequest, opts ...grpc.CallOption) (*Empty, error)
}

MiddlewareClient is the client API for Middleware 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 NewMiddlewareClient 

func NewMiddlewareClient(cc grpc.ClientConnInterface) MiddlewareClient

type MiddlewareServer 

type MiddlewareServer 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) (*Empty, error)
	Delete(context.Context, *DeleteRequest) (*Empty, error)
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	Notify(context.Context, *NotifyRequest) (*Empty, error)
	ChooseReplica(context.Context, *ChooseReplicaRequest) (*Empty, 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, *GetAllReplicaRequest) (*GetAllReplicaResponse, error)
	GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
	AddTrigger(context.Context, *AddTriggerRequest) (*Empty, error)
	RemoveTrigger(context.Context, *RemoveTriggerRequest) (*Empty, error)
	AddUser(context.Context, *UserRequest) (*Empty, error)
	RemoveUser(context.Context, *UserRequest) (*Empty, error)
}

MiddlewareServer is the server API for Middleware service. All implementations should embed UnimplementedMiddlewareServer for forward compatibility

type NotifyRequest added in v0.2.1 

type NotifyRequest 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"`
	Version  map[string]uint64 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.

func (*NotifyRequest) GetId added in v0.2.1 

func (x *NotifyRequest) GetId() string

func (*NotifyRequest) GetKeygroup added in v0.2.1 

func (x *NotifyRequest) GetKeygroup() string

func (*NotifyRequest) GetVersion added in v0.2.1 

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

func (*NotifyRequest) ProtoMessage added in v0.2.1 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) ProtoReflect added in v0.2.1 

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

func (*NotifyRequest) Reset added in v0.2.1 

func (x *NotifyRequest) Reset()

func (*NotifyRequest) String added in v0.2.1 

func (x *NotifyRequest) 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"`
	MinExpiry int64  `protobuf:"varint,3,opt,name=minExpiry,proto3" json:"minExpiry,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) GetMinExpiry 

func (x *ReadRequest) GetMinExpiry() int64

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 {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated 

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetItems added in v0.2.1 

func (x *ReadResponse) GetItems() []*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 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 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 UnimplementedMiddlewareServer 

type UnimplementedMiddlewareServer struct {
}

UnimplementedMiddlewareServer should be embedded to have forward compatible implementations.

func (UnimplementedMiddlewareServer) AddReplica 

func (UnimplementedMiddlewareServer) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error)

func (UnimplementedMiddlewareServer) AddTrigger 

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

func (UnimplementedMiddlewareServer) AddUser 

func (UnimplementedMiddlewareServer) AddUser(context.Context, *UserRequest) (*Empty, error)

func (UnimplementedMiddlewareServer) Append 

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

func (UnimplementedMiddlewareServer) ChooseReplica added in v0.2.3 

func (UnimplementedMiddlewareServer) ChooseReplica(context.Context, *ChooseReplicaRequest) (*Empty, error)

func (UnimplementedMiddlewareServer) CreateKeygroup 

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

func (UnimplementedMiddlewareServer) Delete 

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

func (UnimplementedMiddlewareServer) DeleteKeygroup 

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

func (UnimplementedMiddlewareServer) GetAllReplica 

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

func (UnimplementedMiddlewareServer) GetKeygroupInfo added in v0.2.2 

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

func (UnimplementedMiddlewareServer) GetKeygroupTriggers 

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

func (UnimplementedMiddlewareServer) GetReplica 

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

func (UnimplementedMiddlewareServer) Notify added in v0.2.1 

func (UnimplementedMiddlewareServer) Notify(context.Context, *NotifyRequest) (*Empty, error)

func (UnimplementedMiddlewareServer) Read 

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

func (UnimplementedMiddlewareServer) RemoveReplica 

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

func (UnimplementedMiddlewareServer) RemoveTrigger 

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

func (UnimplementedMiddlewareServer) RemoveUser 

func (UnimplementedMiddlewareServer) RemoveUser(context.Context, *UserRequest) (*Empty, error)

func (UnimplementedMiddlewareServer) Scan 

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

func (UnimplementedMiddlewareServer) Update 

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

type UnsafeMiddlewareServer 

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

UnsafeMiddlewareServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MiddlewareServer 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.middleware.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.