vaultcli

Documentation

Index

• Constants
• Variables
• func GetEventFrom(resp *http.Response) (data map[string]*ProcInfo, err error)
• func ProcWatcherUrl(appName string) (url string)
• type ContainerInfo
• type ContainerInfoWithStatus
• type ContainerStatus
• type LainletClient
• type ProcInfo
• type VaultClient
  • func (c *VaultClient) CheckRootToken(token string) bool
  • func (c *VaultClient) CheckToken(token string, tokentype string) bool
  • func (c *VaultClient) DeleteSecret(token string, path string) error
  • func (c *VaultClient) GetAllStatus() []byte
  • func (c *VaultClient) InitClient(tls bool)
  • func (c *VaultClient) InitVault(req *api.InitRequest) (*api.InitResponse, error)
  • func (c *VaultClient) ListSecrets(token string, path string) ([]string, error)
  • func (c *VaultClient) PutSecret(token string, path string, data string) error
  • func (c *VaultClient) Unseal(unsealkey []string) (err error)
  • func (c *VaultClient) UpdateClient()
• type VaultStatus
  • func (v *VaultStatus) AllSealed() bool
  • func (v *VaultStatus) AllUnsealed() bool
  • func (v *VaultStatus) GetContainers() map[string]ContainerInfoWithStatus
  • func (v *VaultStatus) GetStatus() []byte
  • func (v *VaultStatus) UnsealedURL() string
  • func (v *VaultStatus) UpdateStatus()

Constants

const (
	AppName        = "lvault"
	ProcName       = "lvault.web.web"
	UpdateInterval = 2 // 更新 vault 状态的周期，单位为秒
)

Variables

var VaultURL string

Functions

func GetEventFrom

func GetEventFrom(resp *http.Response) (data map[string]*ProcInfo, err error)

func ProcWatcherUrl

func ProcWatcherUrl(appName string) (url string)

Types

type ContainerInfo

type ContainerInfo struct {
	ContainerIp   string `json:"container_ip"`
	ContainerPort int    `json:"container_port"`
}

type ContainerInfoWithStatus

type ContainerInfoWithStatus struct {
	Info   ContainerInfo
	Status ContainerStatus
}

type ContainerStatus

type ContainerStatus struct {
	Sealed          bool `json:"sealed"`
	Threshold       int  `json:"t"`
	TotalSharedKeys int  `json:"n"`
	Progress        int  `json:"progress"`
}

type LainletClient

type LainletClient struct {
	// contains filtered or unexported fields
}

type ProcInfo

type ProcInfo struct {
	NumInstances int             `json:"num_instances"`
	Containers   []ContainerInfo `json:"containers"`
}

type VaultClient

type VaultClient struct {
	// contains filtered or unexported fields
}

func (*VaultClient) CheckRootToken

func (c *VaultClient) CheckRootToken(token string) bool

检查是否是 root token

func (*VaultClient) CheckToken

func (c *VaultClient) CheckToken(token string, tokentype string) bool

前置条件必须是 vault 集群至少有一个节点是解锁的

func (*VaultClient) DeleteSecret

func (c *VaultClient) DeleteSecret(token string, path string) error

func (*VaultClient) GetAllStatus

func (c *VaultClient) GetAllStatus() []byte

func (*VaultClient) InitClient

func (c *VaultClient) InitClient(tls bool)

func (*VaultClient) InitVault

func (c *VaultClient) InitVault(req *api.InitRequest) (*api.InitResponse, error)

func (*VaultClient) ListSecrets

func (c *VaultClient) ListSecrets(token string, path string) ([]string, error)

func (*VaultClient) PutSecret

func (c *VaultClient) PutSecret(token string, path string, data string) error

func (*VaultClient) Unseal

func (c *VaultClient) Unseal(unsealkey []string) (err error)

func (*VaultClient) UpdateClient

func (c *VaultClient) UpdateClient()

type VaultStatus

type VaultStatus struct {
	Lock sync.RWMutex

	//The key is container_ip+container_port
	Containers map[string]ContainerInfoWithStatus

	Cli *LainletClient
	// contains filtered or unexported fields
}

func (*VaultStatus) AllSealed

func (v *VaultStatus) AllSealed() bool

func (*VaultStatus) AllUnsealed

func (v *VaultStatus) AllUnsealed() bool

func (*VaultStatus) GetContainers

func (v *VaultStatus) GetContainers() map[string]ContainerInfoWithStatus

return a copy of the corresponding slice

func (*VaultStatus) GetStatus

func (v *VaultStatus) GetStatus() []byte

func (*VaultStatus) UnsealedURL

func (v *VaultStatus) UnsealedURL() string

func (*VaultStatus) UpdateStatus

func (v *VaultStatus) UpdateStatus()