keyvalue

package

v0.0.0-...-5cd5cfe Latest Latest Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nitrictech/nitric

Documentation ¶

Index ¶

type AztableEntity
type AzureStorageClientFactory
type AzureStorageTableKeyValueService
- func New() (*AzureStorageTableKeyValueService, error)
- func NewWithClient(clientFactory AzureStorageClientFactory) (*AzureStorageTableKeyValueService, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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
}

DynamoKeyValueService - an AWS DynamoDB implementation of the Nitric Document Service

func New ¶

func New() (*AzureStorageTableKeyValueService, error)

New creates a new AWS DynamoDB implementation of a DocumentServiceServer

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

Source Files ¶

View all Source files

keyvalue.go

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