external

Oct 11, 2023

Changes in this version

type Consensus

+ func (ext *Consensus) StepDown(ctx context.Context) error

Oct 8, 2023

Changes in this version

type Consensus

+ func (ext *Consensus) GetPeer(ctx context.Context, id string) (*v1.StoragePeer, error)

Oct 2, 2023

Changes in this version

type Options

+ LogFormat string

Sep 30, 2023

Changes in this version

type Provider

+ func (ext *Provider) MeshDB() storage.MeshDB

Sep 27, 2023

Changes in this version

type ExternalStorage

+ func (ext *ExternalStorage) ListKeys(ctx context.Context, prefix []byte) ([][]byte, error)

Sep 27, 2023

Changes in this version

type Consensus

+ func (ext *Consensus) GetPeers(ctx context.Context) ([]*v1.StoragePeer, error)

Sep 26, 2023

Changes in this version

+ type Consensus struct

+ func (ext *Consensus) AddObserver(ctx context.Context, peer *v1.StoragePeer) error

+ func (ext *Consensus) AddVoter(ctx context.Context, peer *v1.StoragePeer) error

+ func (ext *Consensus) DemoteVoter(ctx context.Context, peer *v1.StoragePeer) error

+ func (ext *Consensus) GetLeader(ctx context.Context) (*v1.StoragePeer, error)

+ func (ext *Consensus) IsLeader() bool

+ func (ext *Consensus) IsMember() bool

+ func (ext *Consensus) RemovePeer(ctx context.Context, peer *v1.StoragePeer, wait bool) error

+ type ExternalStorage struct

+ func (ext *ExternalStorage) Delete(ctx context.Context, key string) error

+ func (ext *ExternalStorage) GetValue(ctx context.Context, key string) (string, error)

+ func (ext *ExternalStorage) IterPrefix(ctx context.Context, prefix string, fn storage.PrefixIterator) error

+ func (ext *ExternalStorage) List(ctx context.Context, prefix string) ([]string, error)

+ func (ext *ExternalStorage) PutValue(ctx context.Context, key, value string, ttl time.Duration) error

+ func (ext *ExternalStorage) Subscribe(ctx context.Context, prefix string, fn storage.SubscribeFunc) (context.CancelFunc, error)

+ type Options struct

+ Config *v1.PluginConfiguration

+ LogLevel string

+ NodeID string

+ Server string

+ TLSConfig *tls.Config

+ type Provider struct

+ func NewProvider(opts Options) *Provider

+ func (ext *Provider) Bootstrap(ctx context.Context) error

+ func (ext *Provider) Close() error

+ func (ext *Provider) Consensus() storage.Consensus

+ func (ext *Provider) ListenPort() uint16

+ func (ext *Provider) MeshStorage() storage.MeshStorage

+ func (ext *Provider) Start(ctx context.Context) error

+ func (ext *Provider) Status() *v1.StorageStatus