middleware

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2021 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: "AddReplica",
			Handler:    _Middleware_AddReplica_Handler,
		},
		{
			MethodName: "GetKeygroupReplica",
			Handler:    _Middleware_GetKeygroupReplica_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 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 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 (*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 (*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 (*GetKeygroupTriggerRequest) Reset

func (x *GetKeygroupTriggerRequest) Reset()

func (*GetKeygroupTriggerRequest) String

func (x *GetKeygroupTriggerRequest) String() string

type GetKeygroupTriggerResponse

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

func (*GetKeygroupTriggerResponse) Descriptor deprecated

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

Deprecated: Use GetKeygroupTriggerResponse.ProtoReflect.Descriptor instead.

func (*GetKeygroupTriggerResponse) GetTriggers

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

func (*GetKeygroupTriggerResponse) ProtoMessage

func (*GetKeygroupTriggerResponse) ProtoMessage()

func (*GetKeygroupTriggerResponse) ProtoReflect

func (*GetKeygroupTriggerResponse) Reset

func (x *GetKeygroupTriggerResponse) Reset()

func (*GetKeygroupTriggerResponse) String

func (x *GetKeygroupTriggerResponse) String() string

type GetReplicaRequest

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

func (*GetReplicaRequest) Descriptor deprecated

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

Deprecated: Use GetReplicaRequest.ProtoReflect.Descriptor instead.

func (*GetReplicaRequest) GetNodeId

func (x *GetReplicaRequest) GetNodeId() string

func (*GetReplicaRequest) ProtoMessage

func (*GetReplicaRequest) ProtoMessage()

func (*GetReplicaRequest) ProtoReflect

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

func (*GetReplicaRequest) Reset

func (x *GetReplicaRequest) Reset()

func (*GetReplicaRequest) String

func (x *GetReplicaRequest) String() string

type GetReplicaResponse

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

func (*GetReplicaResponse) Descriptor deprecated

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

Deprecated: Use GetReplicaResponse.ProtoReflect.Descriptor instead.

func (*GetReplicaResponse) GetHost

func (x *GetReplicaResponse) GetHost() string

func (*GetReplicaResponse) GetNodeId

func (x *GetReplicaResponse) GetNodeId() string

func (*GetReplicaResponse) ProtoMessage

func (*GetReplicaResponse) ProtoMessage()

func (*GetReplicaResponse) ProtoReflect

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

func (*GetReplicaResponse) Reset

func (x *GetReplicaResponse) Reset()

func (*GetReplicaResponse) String

func (x *GetReplicaResponse) String() string

type Item added in v0.2.1

type Item struct {
	Id      string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Val     string            `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	Version 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) (*NotifyResponse, error)
	AddReplica(ctx context.Context, in *AddReplicaRequest, opts ...grpc.CallOption) (*Empty, error)
	GetKeygroupReplica(ctx context.Context, in *GetKeygroupReplicaRequest, opts ...grpc.CallOption) (*GetKeygroupReplicaResponse, 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

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 NotifyResponse added in v0.2.1

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

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

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

Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.

func (*NotifyResponse) ProtoMessage added in v0.2.1

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) ProtoReflect added in v0.2.1

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

func (*NotifyResponse) Reset added in v0.2.1

func (x *NotifyResponse) Reset()

func (*NotifyResponse) String added in v0.2.1

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

func (UnimplementedMiddlewareServer) AddUser

func (UnimplementedMiddlewareServer) Append

func (UnimplementedMiddlewareServer) CreateKeygroup

func (UnimplementedMiddlewareServer) Delete

func (UnimplementedMiddlewareServer) DeleteKeygroup

func (UnimplementedMiddlewareServer) GetAllReplica

func (UnimplementedMiddlewareServer) GetKeygroupTriggers

func (UnimplementedMiddlewareServer) GetReplica

func (UnimplementedMiddlewareServer) Notify added in v0.2.1

func (UnimplementedMiddlewareServer) Read

func (UnimplementedMiddlewareServer) RemoveReplica

func (UnimplementedMiddlewareServer) RemoveTrigger

func (UnimplementedMiddlewareServer) RemoveUser

func (UnimplementedMiddlewareServer) Scan

func (UnimplementedMiddlewareServer) Update

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

Jump to

Keyboard shortcuts

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