storage

package
v0.2.16 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Database_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mcc.fred.storage.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _Database_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Database_Delete_Handler,
		},
		{
			MethodName: "Append",
			Handler:    _Database_Append_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Database_Read_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _Database_Scan_Handler,
		},
		{
			MethodName: "ReadAll",
			Handler:    _Database_ReadAll_Handler,
		},
		{
			MethodName: "IDs",
			Handler:    _Database_IDs_Handler,
		},
		{
			MethodName: "Exists",
			Handler:    _Database_Exists_Handler,
		},
		{
			MethodName: "CreateKeygroup",
			Handler:    _Database_CreateKeygroup_Handler,
		},
		{
			MethodName: "DeleteKeygroup",
			Handler:    _Database_DeleteKeygroup_Handler,
		},
		{
			MethodName: "ExistsKeygroup",
			Handler:    _Database_ExistsKeygroup_Handler,
		},
		{
			MethodName: "AddKeygroupTrigger",
			Handler:    _Database_AddKeygroupTrigger_Handler,
		},
		{
			MethodName: "DeleteKeygroupTrigger",
			Handler:    _Database_DeleteKeygroupTrigger_Handler,
		},
		{
			MethodName: "GetKeygroupTrigger",
			Handler:    _Database_GetKeygroupTrigger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "storage.proto",
}

Database_ServiceDesc is the grpc.ServiceDesc for Database 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_storage_proto protoreflect.FileDescriptor

Functions

func RegisterDatabaseServer 

func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

Types

type AddKeygroupTriggerRequest added in v0.2.1 

type AddKeygroupTriggerRequest 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"`
	Host     string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AddKeygroupTriggerRequest.ProtoReflect.Descriptor instead.

func (*AddKeygroupTriggerRequest) GetHost added in v0.2.1 

func (x *AddKeygroupTriggerRequest) GetHost() string

func (*AddKeygroupTriggerRequest) GetId added in v0.2.1 

func (x *AddKeygroupTriggerRequest) GetId() string

func (*AddKeygroupTriggerRequest) GetKeygroup added in v0.2.1 

func (x *AddKeygroupTriggerRequest) GetKeygroup() string

func (*AddKeygroupTriggerRequest) ProtoMessage added in v0.2.1 

func (*AddKeygroupTriggerRequest) ProtoMessage()

func (*AddKeygroupTriggerRequest) ProtoReflect added in v0.2.1 

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

func (*AddKeygroupTriggerRequest) Reset added in v0.2.1 

func (x *AddKeygroupTriggerRequest) Reset()

func (*AddKeygroupTriggerRequest) String added in v0.2.1 

func (x *AddKeygroupTriggerRequest) String() string

type AddKeygroupTriggerResponse added in v0.2.1 

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

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

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

Deprecated: Use AddKeygroupTriggerResponse.ProtoReflect.Descriptor instead.

func (*AddKeygroupTriggerResponse) ProtoMessage added in v0.2.1 

func (*AddKeygroupTriggerResponse) ProtoMessage()

func (*AddKeygroupTriggerResponse) ProtoReflect added in v0.2.1 

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

func (*AddKeygroupTriggerResponse) Reset added in v0.2.1 

func (x *AddKeygroupTriggerResponse) Reset()

func (*AddKeygroupTriggerResponse) String added in v0.2.1 

func (x *AddKeygroupTriggerResponse) String() string

type AppendRequest added in v0.2.1 

type AppendRequest 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"`
	Val      string `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	Expiry   int64  `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.

func (*AppendRequest) GetExpiry added in v0.2.1 

func (x *AppendRequest) GetExpiry() int64

func (*AppendRequest) GetId added in v0.2.1 

func (x *AppendRequest) GetId() string

func (*AppendRequest) GetKeygroup added in v0.2.1 

func (x *AppendRequest) GetKeygroup() string

func (*AppendRequest) GetVal added in v0.2.1 

func (x *AppendRequest) GetVal() string

func (*AppendRequest) ProtoMessage added in v0.2.1 

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoReflect added in v0.2.1 

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

func (*AppendRequest) Reset added in v0.2.1 

func (x *AppendRequest) Reset()

func (*AppendRequest) String added in v0.2.1 

func (x *AppendRequest) String() string

type AppendResponse added in v0.2.1 

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

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

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

Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.

func (*AppendResponse) ProtoMessage added in v0.2.1 

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoReflect added in v0.2.1 

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

func (*AppendResponse) Reset added in v0.2.1 

func (x *AppendResponse) Reset()

func (*AppendResponse) String added in v0.2.1 

func (x *AppendResponse) String() string

type CreateKeygroupRequest added in v0.2.1 

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

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

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

Deprecated: Use CreateKeygroupRequest.ProtoReflect.Descriptor instead.

func (*CreateKeygroupRequest) GetKeygroup added in v0.2.1 

func (x *CreateKeygroupRequest) GetKeygroup() string

func (*CreateKeygroupRequest) ProtoMessage added in v0.2.1 

func (*CreateKeygroupRequest) ProtoMessage()

func (*CreateKeygroupRequest) ProtoReflect added in v0.2.1 

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

func (*CreateKeygroupRequest) Reset added in v0.2.1 

func (x *CreateKeygroupRequest) Reset()

func (*CreateKeygroupRequest) String added in v0.2.1 

func (x *CreateKeygroupRequest) String() string

type CreateKeygroupResponse added in v0.2.1 

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

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

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

Deprecated: Use CreateKeygroupResponse.ProtoReflect.Descriptor instead.

func (*CreateKeygroupResponse) ProtoMessage added in v0.2.1 

func (*CreateKeygroupResponse) ProtoMessage()

func (*CreateKeygroupResponse) ProtoReflect added in v0.2.1 

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

func (*CreateKeygroupResponse) Reset added in v0.2.1 

func (x *CreateKeygroupResponse) Reset()

func (*CreateKeygroupResponse) String added in v0.2.1 

func (x *CreateKeygroupResponse) String() string

type DatabaseClient 

type DatabaseClient interface {
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error)
	ReadAll(ctx context.Context, in *ReadAllRequest, opts ...grpc.CallOption) (*ReadAllResponse, error)
	IDs(ctx context.Context, in *IDsRequest, opts ...grpc.CallOption) (*IDsResponse, error)
	Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error)
	CreateKeygroup(ctx context.Context, in *CreateKeygroupRequest, opts ...grpc.CallOption) (*CreateKeygroupResponse, error)
	DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*DeleteKeygroupResponse, error)
	ExistsKeygroup(ctx context.Context, in *ExistsKeygroupRequest, opts ...grpc.CallOption) (*ExistsKeygroupResponse, error)
	AddKeygroupTrigger(ctx context.Context, in *AddKeygroupTriggerRequest, opts ...grpc.CallOption) (*AddKeygroupTriggerResponse, error)
	DeleteKeygroupTrigger(ctx context.Context, in *DeleteKeygroupTriggerRequest, opts ...grpc.CallOption) (*DeleteKeygroupTriggerResponse, error)
	GetKeygroupTrigger(ctx context.Context, in *GetKeygroupTriggerRequest, opts ...grpc.CallOption) (*GetKeygroupTriggerResponse, error)
}

DatabaseClient is the client API for Database 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 NewDatabaseClient 

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseServer 

type DatabaseServer interface {
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Scan(context.Context, *ScanRequest) (*ScanResponse, error)
	ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)
	IDs(context.Context, *IDsRequest) (*IDsResponse, error)
	Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
	CreateKeygroup(context.Context, *CreateKeygroupRequest) (*CreateKeygroupResponse, error)
	DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*DeleteKeygroupResponse, error)
	ExistsKeygroup(context.Context, *ExistsKeygroupRequest) (*ExistsKeygroupResponse, error)
	AddKeygroupTrigger(context.Context, *AddKeygroupTriggerRequest) (*AddKeygroupTriggerResponse, error)
	DeleteKeygroupTrigger(context.Context, *DeleteKeygroupTriggerRequest) (*DeleteKeygroupTriggerResponse, error)
	GetKeygroupTrigger(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
}

DatabaseServer is the server API for Database service. All implementations should embed UnimplementedDatabaseServer for forward compatibility

type DeleteKeygroupRequest added in v0.2.1 

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

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

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

Deprecated: Use DeleteKeygroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupRequest) GetKeygroup added in v0.2.1 

func (x *DeleteKeygroupRequest) GetKeygroup() string

func (*DeleteKeygroupRequest) ProtoMessage added in v0.2.1 

func (*DeleteKeygroupRequest) ProtoMessage()

func (*DeleteKeygroupRequest) ProtoReflect added in v0.2.1 

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

func (*DeleteKeygroupRequest) Reset added in v0.2.1 

func (x *DeleteKeygroupRequest) Reset()

func (*DeleteKeygroupRequest) String added in v0.2.1 

func (x *DeleteKeygroupRequest) String() string

type DeleteKeygroupResponse added in v0.2.1 

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

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

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

Deprecated: Use DeleteKeygroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupResponse) ProtoMessage added in v0.2.1 

func (*DeleteKeygroupResponse) ProtoMessage()

func (*DeleteKeygroupResponse) ProtoReflect added in v0.2.1 

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

func (*DeleteKeygroupResponse) Reset added in v0.2.1 

func (x *DeleteKeygroupResponse) Reset()

func (*DeleteKeygroupResponse) String added in v0.2.1 

func (x *DeleteKeygroupResponse) String() string

type DeleteKeygroupTriggerRequest added in v0.2.1 

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

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

Deprecated: Use DeleteKeygroupTriggerRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupTriggerRequest) GetId added in v0.2.1 

func (x *DeleteKeygroupTriggerRequest) GetId() string

func (*DeleteKeygroupTriggerRequest) GetKeygroup added in v0.2.1 

func (x *DeleteKeygroupTriggerRequest) GetKeygroup() string

func (*DeleteKeygroupTriggerRequest) ProtoMessage added in v0.2.1 

func (*DeleteKeygroupTriggerRequest) ProtoMessage()

func (*DeleteKeygroupTriggerRequest) ProtoReflect added in v0.2.1 

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

func (*DeleteKeygroupTriggerRequest) Reset added in v0.2.1 

func (x *DeleteKeygroupTriggerRequest) Reset()

func (*DeleteKeygroupTriggerRequest) String added in v0.2.1 

func (x *DeleteKeygroupTriggerRequest) String() string

type DeleteKeygroupTriggerResponse added in v0.2.1 

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

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

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

Deprecated: Use DeleteKeygroupTriggerResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupTriggerResponse) ProtoMessage added in v0.2.1 

func (*DeleteKeygroupTriggerResponse) ProtoMessage()

func (*DeleteKeygroupTriggerResponse) ProtoReflect added in v0.2.1 

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

func (*DeleteKeygroupTriggerResponse) Reset added in v0.2.1 

func (x *DeleteKeygroupTriggerResponse) Reset()

func (*DeleteKeygroupTriggerResponse) String added in v0.2.1 

func (x *DeleteKeygroupTriggerResponse) String() string

type DeleteRequest added in v0.2.1 

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

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

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId added in v0.2.1 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetKeygroup added in v0.2.1 

func (x *DeleteRequest) GetKeygroup() string

func (*DeleteRequest) GetVersion added in v0.2.1 

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

func (*DeleteRequest) ProtoMessage added in v0.2.1 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v0.2.1 

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

func (*DeleteRequest) Reset added in v0.2.1 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String added in v0.2.1 

func (x *DeleteRequest) String() string

type DeleteResponse added in v0.2.1 

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

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

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage added in v0.2.1 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.2.1 

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

func (*DeleteResponse) Reset added in v0.2.1 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String added in v0.2.1 

func (x *DeleteResponse) String() string

type ExistsKeygroupRequest added in v0.2.1 

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

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

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

Deprecated: Use ExistsKeygroupRequest.ProtoReflect.Descriptor instead.

func (*ExistsKeygroupRequest) GetKeygroup added in v0.2.1 

func (x *ExistsKeygroupRequest) GetKeygroup() string

func (*ExistsKeygroupRequest) ProtoMessage added in v0.2.1 

func (*ExistsKeygroupRequest) ProtoMessage()

func (*ExistsKeygroupRequest) ProtoReflect added in v0.2.1 

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

func (*ExistsKeygroupRequest) Reset added in v0.2.1 

func (x *ExistsKeygroupRequest) Reset()

func (*ExistsKeygroupRequest) String added in v0.2.1 

func (x *ExistsKeygroupRequest) String() string

type ExistsKeygroupResponse added in v0.2.1 

type ExistsKeygroupResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ExistsKeygroupResponse.ProtoReflect.Descriptor instead.

func (*ExistsKeygroupResponse) GetExists added in v0.2.1 

func (x *ExistsKeygroupResponse) GetExists() bool

func (*ExistsKeygroupResponse) ProtoMessage added in v0.2.1 

func (*ExistsKeygroupResponse) ProtoMessage()

func (*ExistsKeygroupResponse) ProtoReflect added in v0.2.1 

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

func (*ExistsKeygroupResponse) Reset added in v0.2.1 

func (x *ExistsKeygroupResponse) Reset()

func (*ExistsKeygroupResponse) String added in v0.2.1 

func (x *ExistsKeygroupResponse) String() string

type ExistsRequest added in v0.2.1 

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

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

Deprecated: Use ExistsRequest.ProtoReflect.Descriptor instead.

func (*ExistsRequest) GetId added in v0.2.1 

func (x *ExistsRequest) GetId() string

func (*ExistsRequest) GetKeygroup added in v0.2.1 

func (x *ExistsRequest) GetKeygroup() string

func (*ExistsRequest) ProtoMessage added in v0.2.1 

func (*ExistsRequest) ProtoMessage()

func (*ExistsRequest) ProtoReflect added in v0.2.1 

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

func (*ExistsRequest) Reset added in v0.2.1 

func (x *ExistsRequest) Reset()

func (*ExistsRequest) String added in v0.2.1 

func (x *ExistsRequest) String() string

type ExistsResponse added in v0.2.1 

type ExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ExistsResponse.ProtoReflect.Descriptor instead.

func (*ExistsResponse) GetExists added in v0.2.1 

func (x *ExistsResponse) GetExists() bool

func (*ExistsResponse) ProtoMessage added in v0.2.1 

func (*ExistsResponse) ProtoMessage()

func (*ExistsResponse) ProtoReflect added in v0.2.1 

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

func (*ExistsResponse) Reset added in v0.2.1 

func (x *ExistsResponse) Reset()

func (*ExistsResponse) String added in v0.2.1 

func (x *ExistsResponse) String() string

type GetKeygroupTriggerRequest added in v0.2.1 

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

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

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

Deprecated: Use GetKeygroupTriggerRequest.ProtoReflect.Descriptor instead.

func (*GetKeygroupTriggerRequest) GetKeygroup added in v0.2.1 

func (x *GetKeygroupTriggerRequest) GetKeygroup() string

func (*GetKeygroupTriggerRequest) ProtoMessage added in v0.2.1 

func (*GetKeygroupTriggerRequest) ProtoMessage()

func (*GetKeygroupTriggerRequest) ProtoReflect added in v0.2.1 

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

func (*GetKeygroupTriggerRequest) Reset added in v0.2.1 

func (x *GetKeygroupTriggerRequest) Reset()

func (*GetKeygroupTriggerRequest) String added in v0.2.1 

func (x *GetKeygroupTriggerRequest) String() string

type GetKeygroupTriggerResponse added in v0.2.1 

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

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

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

Deprecated: Use GetKeygroupTriggerResponse.ProtoReflect.Descriptor instead.

func (*GetKeygroupTriggerResponse) GetTriggers added in v0.2.1 

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

func (*GetKeygroupTriggerResponse) ProtoMessage added in v0.2.1 

func (*GetKeygroupTriggerResponse) ProtoMessage()

func (*GetKeygroupTriggerResponse) ProtoReflect added in v0.2.1 

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

func (*GetKeygroupTriggerResponse) Reset added in v0.2.1 

func (x *GetKeygroupTriggerResponse) Reset()

func (*GetKeygroupTriggerResponse) String added in v0.2.1 

func (x *GetKeygroupTriggerResponse) String() string

type IDsRequest added in v0.2.1 

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

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

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

Deprecated: Use IDsRequest.ProtoReflect.Descriptor instead.

func (*IDsRequest) GetKeygroup added in v0.2.1 

func (x *IDsRequest) GetKeygroup() string

func (*IDsRequest) ProtoMessage added in v0.2.1 

func (*IDsRequest) ProtoMessage()

func (*IDsRequest) ProtoReflect added in v0.2.1 

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

func (*IDsRequest) Reset added in v0.2.1 

func (x *IDsRequest) Reset()

func (*IDsRequest) String added in v0.2.1 

func (x *IDsRequest) String() string

type IDsResponse added in v0.2.1 

type IDsResponse struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use IDsResponse.ProtoReflect.Descriptor instead.

func (*IDsResponse) GetIds added in v0.2.1 

func (x *IDsResponse) GetIds() []string

func (*IDsResponse) ProtoMessage added in v0.2.1 

func (*IDsResponse) ProtoMessage()

func (*IDsResponse) ProtoReflect added in v0.2.1 

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

func (*IDsResponse) Reset added in v0.2.1 

func (x *IDsResponse) Reset()

func (*IDsResponse) String added in v0.2.1 

func (x *IDsResponse) String() string

type Item 

type Item 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"`
	Val      string            `protobuf:"bytes,3,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 

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetId 

func (x *Item) GetId() string

func (*Item) GetKeygroup 

func (x *Item) GetKeygroup() string

func (*Item) GetVal 

func (x *Item) GetVal() string

func (*Item) GetVersion added in v0.2.1 

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

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect 

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

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) String 

func (x *Item) String() string

type ReadAllRequest added in v0.2.1 

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

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

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

Deprecated: Use ReadAllRequest.ProtoReflect.Descriptor instead.

func (*ReadAllRequest) GetKeygroup added in v0.2.1 

func (x *ReadAllRequest) GetKeygroup() string

func (*ReadAllRequest) ProtoMessage added in v0.2.1 

func (*ReadAllRequest) ProtoMessage()

func (*ReadAllRequest) ProtoReflect added in v0.2.1 

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

func (*ReadAllRequest) Reset added in v0.2.1 

func (x *ReadAllRequest) Reset()

func (*ReadAllRequest) String added in v0.2.1 

func (x *ReadAllRequest) String() string

type ReadAllResponse added in v0.2.1 

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

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

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

Deprecated: Use ReadAllResponse.ProtoReflect.Descriptor instead.

func (*ReadAllResponse) GetItems added in v0.2.1 

func (x *ReadAllResponse) GetItems() []*Item

func (*ReadAllResponse) ProtoMessage added in v0.2.1 

func (*ReadAllResponse) ProtoMessage()

func (*ReadAllResponse) ProtoReflect added in v0.2.1 

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

func (*ReadAllResponse) Reset added in v0.2.1 

func (x *ReadAllResponse) Reset()

func (*ReadAllResponse) String added in v0.2.1 

func (x *ReadAllResponse) String() string

type ReadRequest added in v0.2.1 

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

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetId added in v0.2.1 

func (x *ReadRequest) GetId() string

func (*ReadRequest) GetKeygroup added in v0.2.1 

func (x *ReadRequest) GetKeygroup() string

func (*ReadRequest) ProtoMessage added in v0.2.1 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect added in v0.2.1 

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

func (*ReadRequest) Reset added in v0.2.1 

func (x *ReadRequest) Reset()

func (*ReadRequest) String added in v0.2.1 

func (x *ReadRequest) String() string

type ReadResponse added in v0.2.1 

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

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

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

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect added in v0.2.1 

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

func (*ReadResponse) Reset added in v0.2.1 

func (x *ReadResponse) Reset()

func (*ReadResponse) String added in v0.2.1 

func (x *ReadResponse) String() string

type ScanRequest 

type ScanRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Start    string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,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) GetKeygroup added in v0.2.1 

func (x *ScanRequest) GetKeygroup() string

func (*ScanRequest) GetStart added in v0.2.1 

func (x *ScanRequest) GetStart() 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 added in v0.2.1 

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

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

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

Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.

func (*ScanResponse) GetItems added in v0.2.1 

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

func (*ScanResponse) ProtoMessage added in v0.2.1 

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) ProtoReflect added in v0.2.1 

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

func (*ScanResponse) Reset added in v0.2.1 

func (x *ScanResponse) Reset()

func (*ScanResponse) String added in v0.2.1 

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 UnimplementedDatabaseServer 

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer should be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServer) AddKeygroupTrigger 

func (UnimplementedDatabaseServer) AddKeygroupTrigger(context.Context, *AddKeygroupTriggerRequest) (*AddKeygroupTriggerResponse, error)

func (UnimplementedDatabaseServer) Append 

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

func (UnimplementedDatabaseServer) CreateKeygroup 

func (UnimplementedDatabaseServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*CreateKeygroupResponse, error)

func (UnimplementedDatabaseServer) Delete 

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

func (UnimplementedDatabaseServer) DeleteKeygroup 

func (UnimplementedDatabaseServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*DeleteKeygroupResponse, error)

func (UnimplementedDatabaseServer) DeleteKeygroupTrigger 

func (UnimplementedDatabaseServer) DeleteKeygroupTrigger(context.Context, *DeleteKeygroupTriggerRequest) (*DeleteKeygroupTriggerResponse, error)

func (UnimplementedDatabaseServer) Exists 

func (UnimplementedDatabaseServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)

func (UnimplementedDatabaseServer) ExistsKeygroup 

func (UnimplementedDatabaseServer) ExistsKeygroup(context.Context, *ExistsKeygroupRequest) (*ExistsKeygroupResponse, error)

func (UnimplementedDatabaseServer) GetKeygroupTrigger 

func (UnimplementedDatabaseServer) GetKeygroupTrigger(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)

func (UnimplementedDatabaseServer) IDs 

func (UnimplementedDatabaseServer) IDs(context.Context, *IDsRequest) (*IDsResponse, error)

func (UnimplementedDatabaseServer) Read 

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

func (UnimplementedDatabaseServer) ReadAll 

func (UnimplementedDatabaseServer) ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)

func (UnimplementedDatabaseServer) Scan 

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

func (UnimplementedDatabaseServer) Update 

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

type UnsafeDatabaseServer 

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

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

type UpdateRequest added in v0.2.1 

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"`
	Val      string            `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	Expiry   int64             `protobuf:"varint,5,opt,name=expiry,proto3" json:"expiry,omitempty"`
	Version  map[string]uint64 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetExpiry added in v0.2.1 

func (x *UpdateRequest) GetExpiry() int64

func (*UpdateRequest) GetId added in v0.2.1 

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetKeygroup added in v0.2.1 

func (x *UpdateRequest) GetKeygroup() string

func (*UpdateRequest) GetVal added in v0.2.1 

func (x *UpdateRequest) GetVal() string

func (*UpdateRequest) GetVersion added in v0.2.1 

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

func (*UpdateRequest) ProtoMessage added in v0.2.1 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect added in v0.2.1 

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

func (*UpdateRequest) Reset added in v0.2.1 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String added in v0.2.1 

func (x *UpdateRequest) String() string

type UpdateResponse added in v0.2.1 

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

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

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) ProtoMessage added in v0.2.1 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect added in v0.2.1 

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

func (*UpdateResponse) Reset added in v0.2.1 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String added in v0.2.1 

func (x *UpdateResponse) String() string

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.