system

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SystemPluginID  = "opni.System"
	KVServiceID     = "system.KeyValueStore"
	SystemServiceID = "system.System"
)
View Source 
const (
	System_UseManagementAPI_FullMethodName   = "/system.System/UseManagementAPI"
	System_UseKeyValueStore_FullMethodName   = "/system.System/UseKeyValueStore"
	System_UseAPIExtensions_FullMethodName   = "/system.System/UseAPIExtensions"
	System_UseCachingProvider_FullMethodName = "/system.System/UseCachingProvider"
)
View Source 
const (
	KeyValueStore_Put_FullMethodName      = "/system.KeyValueStore/Put"
	KeyValueStore_Get_FullMethodName      = "/system.KeyValueStore/Get"
	KeyValueStore_Watch_FullMethodName    = "/system.KeyValueStore/Watch"
	KeyValueStore_Delete_FullMethodName   = "/system.KeyValueStore/Delete"
	KeyValueStore_ListKeys_FullMethodName = "/system.KeyValueStore/ListKeys"
	KeyValueStore_History_FullMethodName  = "/system.KeyValueStore/History"
)

Variables

View Source 
var (
	WatchResponse_EventType_name = map[int32]string{
		0: "Put",
		1: "Delete",
	}
	WatchResponse_EventType_value = map[string]int32{
		"Put":    0,
		"Delete": 1,
	}
)

Enum value maps for WatchResponse_EventType.

View Source 
var File_github_com_rancher_opni_pkg_plugins_apis_system_system_proto protoreflect.FileDescriptor
View Source 
var KeyValueStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "system.KeyValueStore",
	HandlerType: (*KeyValueStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _KeyValueStore_Put_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _KeyValueStore_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _KeyValueStore_Delete_Handler,
		},
		{
			MethodName: "ListKeys",
			Handler:    _KeyValueStore_ListKeys_Handler,
		},
		{
			MethodName: "History",
			Handler:    _KeyValueStore_History_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _KeyValueStore_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/system/system.proto",
}

KeyValueStore_ServiceDesc is the grpc.ServiceDesc for KeyValueStore 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 System_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "system.System",
	HandlerType: (*SystemServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UseManagementAPI",
			Handler:    _System_UseManagementAPI_Handler,
		},
		{
			MethodName: "UseKeyValueStore",
			Handler:    _System_UseKeyValueStore_Handler,
		},
		{
			MethodName: "UseAPIExtensions",
			Handler:    _System_UseAPIExtensions_Handler,
		},
		{
			MethodName: "UseCachingProvider",
			Handler:    _System_UseCachingProvider_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/system/system.proto",
}

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

Functions

func FromKeyRevisionProto added in v0.12.0 

func FromKeyRevisionProto[T proto.Message](krProto *KeyRevision) storage.KeyRevision[T]

func NewKVStoreClient added in v0.5.4 

func NewKVStoreClient[T proto.Message](client KeyValueStoreClient) storage.KeyValueStoreT[T]

func NewPlugin 

func NewPlugin(client SystemPluginClient) plugin.Plugin

func RegisterKeyValueStoreServer 

func RegisterKeyValueStoreServer(s grpc.ServiceRegistrar, srv KeyValueStoreServer)

func RegisterSystemServer 

func RegisterSystemServer(s grpc.ServiceRegistrar, srv SystemServer)

Types

type BrokerID 

type BrokerID struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerID) Descriptor deprecated 

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

Deprecated: Use BrokerID.ProtoReflect.Descriptor instead.

func (*BrokerID) GetId 

func (x *BrokerID) GetId() uint32

func (*BrokerID) ProtoMessage 

func (*BrokerID) ProtoMessage()

func (*BrokerID) ProtoReflect 

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

func (*BrokerID) Reset 

func (x *BrokerID) Reset()

func (*BrokerID) String 

func (x *BrokerID) String() string

type DeleteRequest added in v0.12.0 

type DeleteRequest struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Revision *int64 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey added in v0.12.0 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetRevision added in v0.12.0 

func (x *DeleteRequest) GetRevision() int64

func (*DeleteRequest) ProtoMessage added in v0.12.0 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v0.12.0 

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

func (*DeleteRequest) Reset added in v0.12.0 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String added in v0.12.0 

func (x *DeleteRequest) String() string

func (*DeleteRequest) Validate added in v0.12.0 

func (dr *DeleteRequest) Validate() error

type DeleteResponse added in v0.12.0 

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

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

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage added in v0.12.0 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.12.0 

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

func (*DeleteResponse) Reset added in v0.12.0 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String added in v0.12.0 

func (x *DeleteResponse) String() string

type DialAddress added in v0.5.4 

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

func (*DialAddress) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use DialAddress.ProtoReflect.Descriptor instead.

func (*DialAddress) GetValue added in v0.5.4 

func (x *DialAddress) GetValue() string

func (*DialAddress) ProtoMessage added in v0.5.4 

func (*DialAddress) ProtoMessage()

func (*DialAddress) ProtoReflect added in v0.5.4 

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

func (*DialAddress) Reset added in v0.5.4 

func (x *DialAddress) Reset()

func (*DialAddress) String added in v0.5.4 

func (x *DialAddress) String() string

type ExtensionClientInterface added in v0.5.4 

type ExtensionClientInterface interface {
	// Attempt to obtain a ClientConn such that the API extensions with the given
	// names will be available on that client. If the requested extension is not
	// available, it will retry until it becomes available, or until the context
	// is canceled.
	GetClientConn(ctx context.Context, serviceNames ...string) (grpc.ClientConnInterface, error)
}

ExtensionClientInterface allows plugins to obtain clients to API extensions implemented by other plugins.

type GetRequest added in v0.12.0 

type GetRequest struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Revision *int64 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey added in v0.12.0 

func (x *GetRequest) GetKey() string

func (*GetRequest) GetRevision added in v0.12.0 

func (x *GetRequest) GetRevision() int64

func (*GetRequest) ProtoMessage added in v0.12.0 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect added in v0.12.0 

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

func (*GetRequest) Reset added in v0.12.0 

func (x *GetRequest) Reset()

func (*GetRequest) String added in v0.12.0 

func (x *GetRequest) String() string

func (*GetRequest) Validate added in v0.12.0 

func (gr *GetRequest) Validate() error

type GetResponse added in v0.12.0 

type GetResponse struct {
	Value    []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Revision int64  `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetRevision added in v0.12.0 

func (x *GetResponse) GetRevision() int64

func (*GetResponse) GetValue added in v0.12.0 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage added in v0.12.0 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect added in v0.12.0 

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

func (*GetResponse) Reset added in v0.12.0 

func (x *GetResponse) Reset()

func (*GetResponse) String added in v0.12.0 

func (x *GetResponse) String() string

type HistoryRequest added in v0.12.0 

type HistoryRequest struct {
	Key           string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IncludeValues bool   `protobuf:"varint,3,opt,name=includeValues,proto3" json:"includeValues,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetIncludeValues added in v0.12.0 

func (x *HistoryRequest) GetIncludeValues() bool

func (*HistoryRequest) GetKey added in v0.12.0 

func (x *HistoryRequest) GetKey() string

func (*HistoryRequest) ProtoMessage added in v0.12.0 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect added in v0.12.0 

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

func (*HistoryRequest) Reset added in v0.12.0 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String added in v0.12.0 

func (x *HistoryRequest) String() string

func (*HistoryRequest) Validate added in v0.12.0 

func (hr *HistoryRequest) Validate() error

type HistoryResponse added in v0.12.0 

type HistoryResponse struct {
	Revisions []*KeyRevision `protobuf:"bytes,1,rep,name=revisions,proto3" json:"revisions,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetRevisions added in v0.12.0 

func (x *HistoryResponse) GetRevisions() []*KeyRevision

func (*HistoryResponse) ProtoMessage added in v0.12.0 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect added in v0.12.0 

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

func (*HistoryResponse) Reset added in v0.12.0 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String added in v0.12.0 

func (x *HistoryResponse) String() string

type KeyRevision added in v0.12.0 

type KeyRevision struct {
	Key       string                 `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte                 `protobuf:"bytes,2,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Revision  int64                  `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func ToKeyRevisionProto added in v0.12.0 

func ToKeyRevisionProto[T proto.Message](kr storage.KeyRevision[T]) *KeyRevision

func (*KeyRevision) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use KeyRevision.ProtoReflect.Descriptor instead.

func (*KeyRevision) GetKey added in v0.12.0 

func (x *KeyRevision) GetKey() string

func (*KeyRevision) GetRevision added in v0.12.0 

func (x *KeyRevision) GetRevision() int64

func (*KeyRevision) GetTimestamp added in v0.12.0 

func (x *KeyRevision) GetTimestamp() *timestamppb.Timestamp

func (*KeyRevision) GetValue added in v0.12.0 

func (x *KeyRevision) GetValue() []byte

func (*KeyRevision) ProtoMessage added in v0.12.0 

func (*KeyRevision) ProtoMessage()

func (*KeyRevision) ProtoReflect added in v0.12.0 

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

func (*KeyRevision) Reset added in v0.12.0 

func (x *KeyRevision) Reset()

func (*KeyRevision) String added in v0.12.0 

func (x *KeyRevision) String() string

type KeyValueStoreClient 

type KeyValueStoreClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (KeyValueStore_WatchClient, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	ListKeys(ctx context.Context, in *ListKeysRequest, opts ...grpc.CallOption) (*ListKeysResponse, error)
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*HistoryResponse, error)
}

KeyValueStoreClient is the client API for KeyValueStore 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 NewKeyValueStoreClient 

func NewKeyValueStoreClient(cc grpc.ClientConnInterface) KeyValueStoreClient

type KeyValueStoreServer 

type KeyValueStoreServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Watch(*WatchRequest, KeyValueStore_WatchServer) error
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	ListKeys(context.Context, *ListKeysRequest) (*ListKeysResponse, error)
	History(context.Context, *HistoryRequest) (*HistoryResponse, error)
	// contains filtered or unexported methods
}

KeyValueStoreServer is the server API for KeyValueStore service. All implementations must embed UnimplementedKeyValueStoreServer for forward compatibility

func NewKVStoreServer added in v0.12.0 

func NewKVStoreServer(store storage.KeyValueStore) KeyValueStoreServer

type KeyValueStore_WatchClient added in v0.12.0 

type KeyValueStore_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type KeyValueStore_WatchServer added in v0.12.0 

type KeyValueStore_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type ListKeysRequest added in v0.12.0 

type ListKeysRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Limit *int64 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeysRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use ListKeysRequest.ProtoReflect.Descriptor instead.

func (*ListKeysRequest) GetKey added in v0.12.0 

func (x *ListKeysRequest) GetKey() string

func (*ListKeysRequest) GetLimit added in v0.12.0 

func (x *ListKeysRequest) GetLimit() int64

func (*ListKeysRequest) ProtoMessage added in v0.12.0 

func (*ListKeysRequest) ProtoMessage()

func (*ListKeysRequest) ProtoReflect added in v0.12.0 

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

func (*ListKeysRequest) Reset added in v0.12.0 

func (x *ListKeysRequest) Reset()

func (*ListKeysRequest) String added in v0.12.0 

func (x *ListKeysRequest) String() string

func (*ListKeysRequest) Validate added in v0.12.0 

func (lr *ListKeysRequest) Validate() error

type ListKeysResponse added in v0.12.0 

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

func (*ListKeysResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use ListKeysResponse.ProtoReflect.Descriptor instead.

func (*ListKeysResponse) GetKeys added in v0.12.0 

func (x *ListKeysResponse) GetKeys() []string

func (*ListKeysResponse) ProtoMessage added in v0.12.0 

func (*ListKeysResponse) ProtoMessage()

func (*ListKeysResponse) ProtoReflect added in v0.12.0 

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

func (*ListKeysResponse) Reset added in v0.12.0 

func (x *ListKeysResponse) Reset()

func (*ListKeysResponse) String added in v0.12.0 

func (x *ListKeysResponse) String() string

type PutRequest added in v0.12.0 

type PutRequest struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Revision *int64 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey added in v0.12.0 

func (x *PutRequest) GetKey() string

func (*PutRequest) GetRevision added in v0.12.0 

func (x *PutRequest) GetRevision() int64

func (*PutRequest) GetValue added in v0.12.0 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage added in v0.12.0 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect added in v0.12.0 

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

func (*PutRequest) Reset added in v0.12.0 

func (x *PutRequest) Reset()

func (*PutRequest) String added in v0.12.0 

func (x *PutRequest) String() string

func (*PutRequest) Validate added in v0.12.0 

func (pr *PutRequest) Validate() error

type PutResponse added in v0.12.0 

type PutResponse struct {
	Revision int64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetRevision added in v0.12.0 

func (x *PutResponse) GetRevision() int64

func (*PutResponse) ProtoMessage added in v0.12.0 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect added in v0.12.0 

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

func (*PutResponse) Reset added in v0.12.0 

func (x *PutResponse) Reset()

func (*PutResponse) String added in v0.12.0 

func (x *PutResponse) String() string

type SystemClient 

type SystemClient interface {
	UseManagementAPI(ctx context.Context, in *BrokerID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UseKeyValueStore(ctx context.Context, in *BrokerID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UseAPIExtensions(ctx context.Context, in *DialAddress, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UseCachingProvider(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SystemClient is the client API for System 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 NewSystemClient 

func NewSystemClient(cc grpc.ClientConnInterface) SystemClient

type SystemPluginClient 

type SystemPluginClient interface {
	UseManagementAPI(managementv1.ManagementClient)
	UseCachingProvider(caching.CachingProvider[proto.Message])
	UseKeyValueStore(KeyValueStoreClient)
	UseAPIExtensions(ExtensionClientInterface)
	// contains filtered or unexported methods
}

type SystemPluginServer 

type SystemPluginServer interface {
	ServeManagementAPI(managementv1.ManagementServer)
	ServeKeyValueStore(storage.KeyValueStore)
	ServeAPIExtensions(dialAddress string) error
	ServeCachingProvider()
}

type SystemServer 

type SystemServer interface {
	UseManagementAPI(context.Context, *BrokerID) (*emptypb.Empty, error)
	UseKeyValueStore(context.Context, *BrokerID) (*emptypb.Empty, error)
	UseAPIExtensions(context.Context, *DialAddress) (*emptypb.Empty, error)
	UseCachingProvider(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

SystemServer is the server API for System service. All implementations must embed UnimplementedSystemServer for forward compatibility

type UnimplementedKeyValueStoreServer 

type UnimplementedKeyValueStoreServer struct {
}

UnimplementedKeyValueStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedKeyValueStoreServer) Delete added in v0.5.4 

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

func (UnimplementedKeyValueStoreServer) Get 

func (UnimplementedKeyValueStoreServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedKeyValueStoreServer) History added in v0.12.0 

func (UnimplementedKeyValueStoreServer) History(context.Context, *HistoryRequest) (*HistoryResponse, error)

func (UnimplementedKeyValueStoreServer) ListKeys 

func (UnimplementedKeyValueStoreServer) ListKeys(context.Context, *ListKeysRequest) (*ListKeysResponse, error)

func (UnimplementedKeyValueStoreServer) Put 

func (UnimplementedKeyValueStoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedKeyValueStoreServer) Watch added in v0.12.0 

func (UnimplementedKeyValueStoreServer) Watch(*WatchRequest, KeyValueStore_WatchServer) error

type UnimplementedSystemPluginClient added in v0.5.4 

type UnimplementedSystemPluginClient struct{}

UnimplementedSystemPluginClient must be embedded to have forward compatible implementations.

func (UnimplementedSystemPluginClient) UseAPIExtensions added in v0.5.4 

func (UnimplementedSystemPluginClient) UseAPIExtensions(ExtensionClientInterface)

func (UnimplementedSystemPluginClient) UseCachingProvider added in v0.9.2 

func (UnimplementedSystemPluginClient) UseCachingProvider(caching.CachingProvider[proto.Message])

func (UnimplementedSystemPluginClient) UseKeyValueStore added in v0.5.4 

func (UnimplementedSystemPluginClient) UseKeyValueStore(KeyValueStoreClient)

func (UnimplementedSystemPluginClient) UseManagementAPI added in v0.5.4 

func (UnimplementedSystemPluginClient) UseManagementAPI(managementv1.ManagementClient)

type UnimplementedSystemServer 

type UnimplementedSystemServer struct {
}

UnimplementedSystemServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemServer) UseAPIExtensions added in v0.5.4 

func (UnimplementedSystemServer) UseAPIExtensions(context.Context, *DialAddress) (*emptypb.Empty, error)

func (UnimplementedSystemServer) UseCachingProvider added in v0.9.2 

func (UnimplementedSystemServer) UseCachingProvider(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedSystemServer) UseKeyValueStore 

func (UnimplementedSystemServer) UseKeyValueStore(context.Context, *BrokerID) (*emptypb.Empty, error)

func (UnimplementedSystemServer) UseManagementAPI 

func (UnimplementedSystemServer) UseManagementAPI(context.Context, *BrokerID) (*emptypb.Empty, error)

type UnsafeKeyValueStoreServer 

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

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

type UnsafeSystemServer 

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

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

type WatchRequest added in v0.12.0 

type WatchRequest struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Revision *int64 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Prefix   bool   `protobuf:"varint,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetKey added in v0.12.0 

func (x *WatchRequest) GetKey() string

func (*WatchRequest) GetPrefix added in v0.12.0 

func (x *WatchRequest) GetPrefix() bool

func (*WatchRequest) GetRevision added in v0.12.0 

func (x *WatchRequest) GetRevision() int64

func (*WatchRequest) ProtoMessage added in v0.12.0 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect added in v0.12.0 

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

func (*WatchRequest) Reset added in v0.12.0 

func (x *WatchRequest) Reset()

func (*WatchRequest) String added in v0.12.0 

func (x *WatchRequest) String() string

type WatchResponse added in v0.12.0 

type WatchResponse struct {
	EventType WatchResponse_EventType `protobuf:"varint,1,opt,name=eventType,proto3,enum=system.WatchResponse_EventType" json:"eventType,omitempty"`
	Current   *KeyRevision            `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	Previous  *KeyRevision            `protobuf:"bytes,3,opt,name=previous,proto3" json:"previous,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetCurrent added in v0.12.0 

func (x *WatchResponse) GetCurrent() *KeyRevision

func (*WatchResponse) GetEventType added in v0.12.0 

func (x *WatchResponse) GetEventType() WatchResponse_EventType

func (*WatchResponse) GetPrevious added in v0.12.0 

func (x *WatchResponse) GetPrevious() *KeyRevision

func (*WatchResponse) ProtoMessage added in v0.12.0 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect added in v0.12.0 

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

func (*WatchResponse) Reset added in v0.12.0 

func (x *WatchResponse) Reset()

func (*WatchResponse) String added in v0.12.0 

func (x *WatchResponse) String() string

type WatchResponse_EventType added in v0.12.0 

type WatchResponse_EventType int32
const (
	WatchResponse_Put    WatchResponse_EventType = 0
	WatchResponse_Delete WatchResponse_EventType = 1
)

func (WatchResponse_EventType) Descriptor added in v0.12.0 

func (WatchResponse_EventType) Descriptor() protoreflect.EnumDescriptor

func (WatchResponse_EventType) Enum added in v0.12.0 

func (x WatchResponse_EventType) Enum() *WatchResponse_EventType

func (WatchResponse_EventType) EnumDescriptor deprecated added in v0.12.0 

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

Deprecated: Use WatchResponse_EventType.Descriptor instead.

func (WatchResponse_EventType) Number added in v0.12.0 

func (x WatchResponse_EventType) Number() protoreflect.EnumNumber

func (WatchResponse_EventType) String added in v0.12.0 

func (x WatchResponse_EventType) String() string

func (WatchResponse_EventType) Type added in v0.12.0 

func (WatchResponse_EventType) 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.