Fountain

English

Tiếng Việt

English

Tiếng Việt

Appearance

Import path: gitlab.soludian.com/soludian/fountain/libs/sd/fetcd

fetcd ​

go
import "gitlab.soludian.com/soludian/fountain/libs/sd/fetcd"

Index ​

Constants ​

go
const KPackageName = "fetcd"

Variables ​

go
var GetFountainInstance = Lib.GetFountainInstance

go
var GetFountainManager = Lib.GetFountainManager

Sử dụng khi config instance ở dạng key:value; Nếu config instance ở dạng key:array thì sử dụng hàm InstallFountainInstances Nếu config ở dạng key:array thì sẽ chỉ install config phần tử đầu tiên mà thôi

Install with config format <key>:<value>; eg: fetcd:<value>

Usage:

config.yaml:

fetcd:
  name: default_name
  ...

code.go

fetcd.InstallFountainInstance()

fetcd.WithConfigKey("fetcd").InstallFountainInstance()
go
var InstallFountainInstance = Lib.InstallFountainInstance

Sử dụng khi config instance ở dạng key:value, sẽ luôn khởi tạo lại Nếu config ở dạng key:array thì sẽ chỉ install config phần tử đầu tiên mà thôi

Install with config format <key>:<value>; eg: fetcd:<value>

Usage:

config.yaml:

	fetcd:
	  name: default_name
	  ...

	code.go

	fetcd.InstallFountainInstanceOnce()

 fetcd.WithConfigKey("fetcd").InstallFountainInstanceOnce()
go
var InstallFountainInstanceOnce = Lib.InstallFountainInstanceOnce

Sử dụng khi config instance ở dạng key:array<value>; Sẽ luôn cố gắng khởi tạo kể cả khi config ở dạng key:value

Install with config format <key>:array<value>; eg: fetcd:array<value>

Usage:

config.yaml:

fetcd:
  - name: default_name
    ...

code.go

fetcd.InstallFountainInstances()

fetcd.WithConfigKey("fetcd").InstallFountainInstances()
go
var InstallFountainInstances = Lib.InstallFountainInstances

Truy cập thẳng tới bộ quản lý thư viện

go
var Lib = lib_3rd.NewLib(newClient, lib_3rd.WithDefaultConfigsFunc[config, Client](DefaultConfig))

go
var WithConfigKey = Lib.WithConfigKey

func AddAddrs ​

go
func AddAddrs(addrs ...string) lib_3rd.Option[config]

func WithAddrs ​

go
func WithAddrs(addrs ...string) lib_3rd.Option[config]

func WithBasicAuth ​

go
func WithBasicAuth(username, password string) lib_3rd.Option[config]

func WithCaCert ​

go
func WithCaCert(caCert string) lib_3rd.Option[config]

func WithCert ​

go
func WithCert(certFile, keyFile string) lib_3rd.Option[config]

func WithConfig ​

go
func WithConfig(conf *config) lib_3rd.Option[config]

WithConfig Required. Set config

func WithEnvironment ​

go
func WithEnvironment(env string) lib_3rd.Option[config]

func WithLogger ​

go
func WithLogger(logger ...flog.FlogInf) lib_3rd.Option[config]

func WithName ​

go
func WithName(name string) lib_3rd.Option[config]

type Client ​

Component ...

go
type Client struct {
    *clientv3.Client
    // contains filtered or unexported fields
}

func (Client) DelPrefix ​

go
func (e Client) DelPrefix(ctx context.Context, prefix string) (deleted int64, err error)

DelPrefix delete by prefix

func (Client) GetKeyValue ​

go
func (e Client) GetKeyValue(ctx context.Context, key string) (kv *mvccpb.KeyValue, err error)

GetKeyValue queries etcd key, returns mvccpb.KeyValue

func (Client) GetLeaseSession ​

go
func (e Client) GetLeaseSession(ctx context.Context, opts ...concurrency.SessionOption) (leaseSession *concurrency.Session, err error)

GetLeaseSession creates a lease session

func (Client) GetPrefix ​

go
func (e Client) GetPrefix(ctx context.Context, prefix string) (map[string]string, error)

GetPrefix get prefix

func (Client) GetValues ​

go
func (e Client) GetValues(ctx context.Context, keys ...string) (map[string]string, error)

GetValues queries etcd for keys prefixed by prefix.

func (*Client) NewMutex ​

go
func (e *Client) NewMutex(key string, opts ...concurrency.SessionOption) (mutex *Mutex, err error)

NewMutex...

func (*Client) WatchPrefix ​

go
func (e *Client) WatchPrefix(ctx context.Context, prefix string) (*Watch, error)

WatchPrefix listens for a key

type Mutex ​

Mutex ...

go
type Mutex struct {
    // contains filtered or unexported fields
}

func (*Mutex) Lock ​

go
func (mutex *Mutex) Lock(ctx context.Context) (err error)

Lock ...

func (*Mutex) Unlock ​

go
func (mutex *Mutex) Unlock(ctx context.Context) (err error)

Unlock ...

type Watch ​

Watch A watch only tells the latest revision

go
type Watch struct {
    // contains filtered or unexported fields
}

func (*Watch) C ​

go
func (w *Watch) C() chan *clientv3.Event

C ...

func (*Watch) Close ​

go
func (w *Watch) Close() error

Close watch

func (*Watch) IncipientKeyValues ​

go
func (w *Watch) IncipientKeyValues() []*mvccpb.KeyValue

IncipientKeyValues incipient key and values

Generated by gomarkdoc