kk_etcd

Documentation

Index

• func AllKVsBackup() (pbFile *kk_pb_type.PBFile, err error)
• func AllKVsRestore(jsonBytes []byte) (err error)
• func GetConfig(configKey string, configStruct any) error
• func InitEtcd(endpoints []string, userName string, password string, debugMode bool) error
• func RegisterService(registration *kk_etcd_models.ServiceRegistration) error
• func ServerList(serviceName string) (serverList *kk_etcd_models.PBListServer, err error)
• func SetConfig(configKey string, configValue string) error
• func Snapshot() (pBFile *kk_pb_type.PBFile, err error)
• func SnapshotInfo(fileByte []byte) (info string, err error)
• func SnapshotRestore() (cmdStr string, err error)
• func WatchServerList(ctx context.Context, serviceName string, ...) (err error)

Functions

func AllKVsBackup

func AllKVsBackup() (pbFile *kk_pb_type.PBFile, err error)

func AllKVsRestore

func AllKVsRestore(jsonBytes []byte) (err error)

AllKVsRestore will overwrite exist kv

func GetConfig

func GetConfig(configKey string, configStruct any) error

GetConfig get config from etcd and unmarshal to configStruct eg: GetConfig("go_rec_dev", &config.Config)

func InitEtcd

func InitEtcd(endpoints []string, userName string, password string, debugMode bool) error

func RegisterService

func RegisterService(registration *kk_etcd_models.ServiceRegistration) error

RegisterService register service to etcd

func ServerList

func ServerList(serviceName string) (serverList *kk_etcd_models.PBListServer, err error)

ServerList serviceName, should with prefix key_prefix.ServiceGrpc or key_prefix.ServiceHttp only give prefix to get all service list

func SetConfig

func SetConfig(configKey string, configValue string) error

SetConfig set config to etcd

func Snapshot

func Snapshot() (pBFile *kk_pb_type.PBFile, err error)

func SnapshotInfo

func SnapshotInfo(fileByte []byte) (info string, err error)

func SnapshotRestore

func SnapshotRestore() (cmdStr string, err error)

func WatchServerList

func WatchServerList(ctx context.Context, serviceName string, serverListChan chan *kk_etcd_models.PBListServer) (err error)

WatchServerList watch server list change