keyvalue

Documentation

Index

• type AztableEntity
• type AzureStorageClientFactory
• type AzureStorageTableKeyValueService
  • func New() (*AzureStorageTableKeyValueService, error)
  • func NewWithClient(clientFactory AzureStorageClientFactory) (*AzureStorageTableKeyValueService, error)
  • func (s *AzureStorageTableKeyValueService) DeleteKey(ctx context.Context, req *kvstorepb.KvStoreDeleteKeyRequest) (*kvstorepb.KvStoreDeleteKeyResponse, error)
  • func (s *AzureStorageTableKeyValueService) GetValue(ctx context.Context, req *kvstorepb.KvStoreGetValueRequest) (*kvstorepb.KvStoreGetValueResponse, error)
  • func (s *AzureStorageTableKeyValueService) ScanKeys(req *kvstorepb.KvStoreScanKeysRequest, stream kvstorepb.KvStore_ScanKeysServer) error
  • func (s *AzureStorageTableKeyValueService) SetValue(ctx context.Context, req *kvstorepb.KvStoreSetValueRequest) (*kvstorepb.KvStoreSetValueResponse, error)

Types

type AztableEntity

type AztableEntity struct {
	aztables.Entity

	Content aztables.EDMBinary
}

type AzureStorageClientFactory

type AzureStorageClientFactory func(tableName string) (*aztables.Client, error)

type AzureStorageTableKeyValueService

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

AzureStorageTableKeyValueService - an Azure Storage Table implementation of the Nitric Key/Value Service

func New

func New() (*AzureStorageTableKeyValueService, error)

New creates a new Azure Storage Table implementation of a KeyValueServer

func NewWithClient

func NewWithClient(clientFactory AzureStorageClientFactory) (*AzureStorageTableKeyValueService, error)

NewWithClient creates a DocumentServiceServer with an given DynamoDB client instance.

Primarily used for testing

func (*AzureStorageTableKeyValueService) DeleteKey

func (s *AzureStorageTableKeyValueService) DeleteKey(ctx context.Context, req *kvstorepb.KvStoreDeleteKeyRequest) (*kvstorepb.KvStoreDeleteKeyResponse, error)

Delete a key/value pair from the Azure Storage table

func (*AzureStorageTableKeyValueService) GetValue

func (s *AzureStorageTableKeyValueService) GetValue(ctx context.Context, req *kvstorepb.KvStoreGetValueRequest) (*kvstorepb.KvStoreGetValueResponse, error)

Get a value from the Azure Storage table

func (*AzureStorageTableKeyValueService) ScanKeys

func (s *AzureStorageTableKeyValueService) ScanKeys(req *kvstorepb.KvStoreScanKeysRequest, stream kvstorepb.KvStore_ScanKeysServer) error

Return all keys in the Azure Storage table for a key/value store

func (*AzureStorageTableKeyValueService) SetValue

func (s *AzureStorageTableKeyValueService) SetValue(ctx context.Context, req *kvstorepb.KvStoreSetValueRequest) (*kvstorepb.KvStoreSetValueResponse, error)

Set a value in the Azure Storage table