service

Documentation

Index

• func AllKVsBackup(stage *kk_stage.Stage) (pbFile *kk_pb_type.PBFile, err error)
• func AllKVsRestore(stage *kk_stage.Stage, pbFile *kk_pb_type.PBFile) (err error)
• func GetUser(stage *kk_stage.Stage, userName string) (user *kk_etcd_models.PBUser, res int)
• func InitEtcd(stage *kk_stage.Stage, endpoints []string, userName string, password string) error
• func KVDel(stage *kk_stage.Stage, key string) (res int)
• func KVGet(stage *kk_stage.Stage, key string) (res int, value []byte)
• func KVList(stage *kk_stage.Stage, prefix string) (res int, list *kk_etcd_models.PBListKV)
• func KVPut(stage *kk_stage.Stage, key string, value string) (err error)
• func Login(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (tokenString string, res int)
• func Logout(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)
• func RegisterService(stage *kk_stage.Stage, registration *kk_etcd_models.ServiceRegistration) error
• func RoleAdd(stage *kk_stage.Stage, role *kk_etcd_models.PBRole) (res int)
• func RoleDelete(stage *kk_stage.Stage, roleName string) (res int)
• func RoleGet(stage *kk_stage.Stage, roleName string) (role *kk_etcd_models.PBRole, res int)
• func RoleGrantPermission(stage *kk_stage.Stage, role *kk_etcd_models.PBRole) (res int)
• func RoleList(stage *kk_stage.Stage) (res int, roles *kk_etcd_models.PBListRole)
• func ServerList(stage *kk_stage.Stage, serviceName string) (res int, serverList *kk_etcd_models.PBListServer, err error)
• func Snapshot(stage *kk_stage.Stage) (pbFile *kk_pb_type.PBFile, err error)
• func SnapshotInfo(stage *kk_stage.Stage, pbFile *kk_pb_type.PBFile) (info string, err error)
• func SnapshotRestore(stage *kk_stage.Stage) (cmdStr string, err error)
• func UserAdd(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)
• func UserDelete(stage *kk_stage.Stage, userName string, admin bool) (res int)
• func UserGrantRole(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)
• func UserList(stage *kk_stage.Stage) (res int, users *kk_etcd_models.PBListUser)

Functions

func AllKVsBackup

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

func AllKVsRestore

func AllKVsRestore(stage *kk_stage.Stage, pbFile *kk_pb_type.PBFile) (err error)

func GetUser

func GetUser(stage *kk_stage.Stage, userName string) (user *kk_etcd_models.PBUser, res int)

func InitEtcd

func InitEtcd(stage *kk_stage.Stage, endpoints []string, userName string, password string) error

func KVDel

func KVDel(stage *kk_stage.Stage, key string) (res int)

func KVGet

func KVGet(stage *kk_stage.Stage, key string) (res int, value []byte)

func KVList

func KVList(stage *kk_stage.Stage, prefix string) (res int, list *kk_etcd_models.PBListKV)

func KVPut

func KVPut(stage *kk_stage.Stage, key string, value string) (err error)

func Login

func Login(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (tokenString string, res int)

func Logout

func Logout(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)

func RegisterService

func RegisterService(stage *kk_stage.Stage, registration *kk_etcd_models.ServiceRegistration) error

func RoleAdd

func RoleAdd(stage *kk_stage.Stage, role *kk_etcd_models.PBRole) (res int)

func RoleDelete

func RoleDelete(stage *kk_stage.Stage, roleName string) (res int)

func RoleGet

func RoleGet(stage *kk_stage.Stage, roleName string) (role *kk_etcd_models.PBRole, res int)

func RoleGrantPermission

func RoleGrantPermission(stage *kk_stage.Stage, role *kk_etcd_models.PBRole) (res int)

func RoleList

func RoleList(stage *kk_stage.Stage) (res int, roles *kk_etcd_models.PBListRole)

func ServerList

func ServerList(stage *kk_stage.Stage, serviceName string) (res int, 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 Snapshot

func Snapshot(stage *kk_stage.Stage) (pbFile *kk_pb_type.PBFile, err error)

Snapshot get snapshot, similar to `etcdctl snapshot save snapshot.db`

func SnapshotInfo

func SnapshotInfo(stage *kk_stage.Stage, pbFile *kk_pb_type.PBFile) (info string, err error)

func SnapshotRestore

func SnapshotRestore(stage *kk_stage.Stage) (cmdStr string, err error)

SnapshotRestore todo migrate to etcd cluster manager

func UserAdd

func UserAdd(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)

func UserDelete

func UserDelete(stage *kk_stage.Stage, userName string, admin bool) (res int)

func UserGrantRole

func UserGrantRole(stage *kk_stage.Stage, user *kk_etcd_models.PBUser) (res int)

func UserList

func UserList(stage *kk_stage.Stage) (res int, users *kk_etcd_models.PBListUser)