etcd

package

v1.13.1 Latest Latest Go to latest Published: Apr 1, 2024 License: Apache-2.0 Imports: 22 Imported by: 1

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/dapr/components-contrib

Links

Open Source Insights

Documentation ¶

Index ¶

func NewEtcdStateStoreV1(logger logger.Logger) state.Store
func NewEtcdStateStoreV2(logger logger.Logger) state.Store
func NewTLSConfig(clientCert, clientKey, caCert string) (*tls.Config, error)
type Etcd

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewEtcdStateStoreV1 ¶ added in v1.12.0

func NewEtcdStateStoreV1(logger logger.Logger) state.Store

NewEtcdStateStoreV1 returns a new etcd state store for schema V1.

func NewEtcdStateStoreV2 ¶ added in v1.12.0

func NewEtcdStateStoreV2(logger logger.Logger) state.Store

NewEtcdStateStoreV2 returns a new etcd state store for schema V2.

func NewTLSConfig ¶ added in v1.11.0

func NewTLSConfig(clientCert, clientKey, caCert string) (*tls.Config, error)

Types ¶

type Etcd ¶ added in v1.11.0

type Etcd struct {
	state.BulkStore
	// contains filtered or unexported fields
}

Etcd is a state store implementation for Etcd.

func (*Etcd) Close ¶ added in v1.11.0

func (e *Etcd) Close() error

func (*Etcd) Delete ¶ added in v1.11.0

func (e *Etcd) Delete(ctx context.Context, req *state.DeleteRequest) error

Delete performes a Etcd KV delete operation.

func (*Etcd) Features ¶ added in v1.11.0

func (e *Etcd) Features() []state.Feature

Features returns the features available in this state store.

func (*Etcd) Get ¶ added in v1.11.0

func (e *Etcd) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)

Get retrieves a Etcd KV item.

func (*Etcd) GetComponentMetadata ¶ added in v1.11.0

func (e *Etcd) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

func (*Etcd) Init ¶ added in v1.11.0

func (e *Etcd) Init(_ context.Context, metadata state.Metadata) error

Init does metadata and config parsing and initializes the Etcd client.

func (*Etcd) Multi ¶ added in v1.11.0

func (e *Etcd) Multi(ctx context.Context, request *state.TransactionalStateRequest) error

Multi performs a transactional operation. succeeds only if all operations succeed, and fails if one or more operations fail.

func (*Etcd) MultiMaxSize ¶ added in v1.12.0

func (e *Etcd) MultiMaxSize() int

MultiMaxSize returns the maximum number of operations allowed in a transaction. For Etcd the default is 128, but this can be configured via the server flag --max-txn-ops. As such we are using the component metadata value maxTxnOps.

func (*Etcd) ParseClientFromConfig ¶ added in v1.11.0

func (e *Etcd) ParseClientFromConfig(etcdConfig *etcdConfig) (*clientv3.Client, error)

func (*Etcd) Ping ¶ added in v1.11.0

func (e *Etcd) Ping() error

func (*Etcd) Set ¶ added in v1.11.0

func (e *Etcd) Set(ctx context.Context, req *state.SetRequest) error

Set saves a Etcd KV item.

Source Files ¶

View all Source files

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