rpcclient

Documentation

Index

• Constants
• func OverrideGrpcLogger()
• type Client
  • func NewWithClient(a rpc.AdminClient, c rpc.ClusterClient, ca rpc.CertificateAuthorityClient, ...) *Client
  • func NewWithInternalToken(conn *grpc.ClientConn, token string) (*Client, error)
  • func NewWithStaticToken(conn *grpc.ClientConn) (*Client, error)
  • func (c *Client) AddUser(id, role string) error
  • func (c *Client) Alive() bool
  • func (c *Client) Close()
  • func (c *Client) ClusterMemberList() ([]*rpc.ClusterMember, error)
  • func (c *Client) DeleteUser(id string, role string) error
  • func (c *Client) GetCert(serialNumber *big.Int) (*rpc.CertItem, error)
  • func (c *Client) GetGPGKey(userId string) (string, error)
  • func (c *Client) GetSSHKey(userId string) (string, error)
  • func (c *Client) GetUser(id string, withToken bool) (*rpc.UserItem, error)
  • func (c *Client) ListAgentBackend() ([]*rpc.BackendItem, error)
  • func (c *Client) ListAllBackend() ([]*rpc.BackendItem, error)
  • func (c *Client) ListAllUser() ([]*rpc.UserItem, error)
  • func (c *Client) ListCert() ([]*rpc.CertItem, error)
  • func (c *Client) ListConnectedAgent() ([]*rpc.Agent, error)
  • func (c *Client) ListRevokedCert() ([]*rpc.CertItem, error)
  • func (c *Client) ListRole() ([]*rpc.RoleItem, error)
  • func (c *Client) ListServiceAccount() ([]*rpc.UserItem, error)
  • func (c *Client) ListUser(role string) ([]*rpc.UserItem, error)
  • func (c *Client) NewAgentCert(commonName, comment string) error
  • func (c *Client) NewAgentCertByCSR(csr string, commonName string) ([]byte, error)
  • func (c *Client) NewCert(commonName, keyType string, keyBits int, password, comment string) error
  • func (c *Client) NewCertByCSR(csr string, commonName string) (*rpc.CertItem, error)
  • func (c *Client) NewServerCert(csr []byte) ([]byte, error)
  • func (c *Client) NewServiceAccount(id, comment string) error
  • func (c *Client) NewToken(name, userId string) (*rpc.AccessTokenItem, error)
  • func (c *Client) RevokeCert(serialNumber *big.Int) error
  • func (c *Client) SetGPGKey(key string) error
  • func (c *Client) SetSSHKey(key string) error
  • func (c *Client) ToggleAdmin(id string) error
  • func (c *Client) UpdateUser(id string, user *rpc.UserItem) error
  • func (c *Client) UserBecomeMaintainer(id, role string) error
• type ClientWithUserToken
  • func NewClientWithUserToken(conn *grpc.ClientConn) *ClientWithUserToken
  • func (u *ClientWithUserToken) WithRequest(req *http.Request) *ClientWithUserToken
  • func (u *ClientWithUserToken) WithToken(token string) *ClientWithUserToken
• type RevokedCert
• type RevokedCertificateWatcher
  • func NewRevokedCertificateWatcher(conn *grpc.ClientConn, token string) (*RevokedCertificateWatcher, error)
  • func (w *RevokedCertificateWatcher) Error() error
  • func (w *RevokedCertificateWatcher) Get() []*RevokedCert
  • func (w *RevokedCertificateWatcher) IsReady() bool

Constants

const (
	TokenHeaderName = "X-Auth-Token"
)

Functions

func OverrideGrpcLogger

func OverrideGrpcLogger()

Types

type Client

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

func NewWithClient

func NewWithClient(a rpc.AdminClient, c rpc.ClusterClient, ca rpc.CertificateAuthorityClient, user rpc.UserClient) *Client

func NewWithInternalToken

func NewWithInternalToken(conn *grpc.ClientConn, token string) (*Client, error)

func NewWithStaticToken

func NewWithStaticToken(conn *grpc.ClientConn) (*Client, error)

func (*Client) AddUser

func (c *Client) AddUser(id, role string) error

func (*Client) Alive

func (c *Client) Alive() bool

func (*Client) Close

func (c *Client) Close()

func (*Client) ClusterMemberList

func (c *Client) ClusterMemberList() ([]*rpc.ClusterMember, error)

func (*Client) DeleteUser

func (c *Client) DeleteUser(id string, role string) error

func (*Client) GetCert

func (c *Client) GetCert(serialNumber *big.Int) (*rpc.CertItem, error)

func (*Client) GetGPGKey

func (c *Client) GetGPGKey(userId string) (string, error)

func (*Client) GetSSHKey

func (c *Client) GetSSHKey(userId string) (string, error)

func (*Client) GetUser

func (c *Client) GetUser(id string, withToken bool) (*rpc.UserItem, error)

func (*Client) ListAgentBackend

func (c *Client) ListAgentBackend() ([]*rpc.BackendItem, error)

func (*Client) ListAllBackend

func (c *Client) ListAllBackend() ([]*rpc.BackendItem, error)

func (*Client) ListAllUser

func (c *Client) ListAllUser() ([]*rpc.UserItem, error)

func (*Client) ListCert

func (c *Client) ListCert() ([]*rpc.CertItem, error)

func (*Client) ListConnectedAgent

func (c *Client) ListConnectedAgent() ([]*rpc.Agent, error)

func (*Client) ListRevokedCert

func (c *Client) ListRevokedCert() ([]*rpc.CertItem, error)

func (*Client) ListRole

func (c *Client) ListRole() ([]*rpc.RoleItem, error)

func (*Client) ListServiceAccount

func (c *Client) ListServiceAccount() ([]*rpc.UserItem, error)

func (*Client) ListUser

func (c *Client) ListUser(role string) ([]*rpc.UserItem, error)

func (*Client) NewAgentCert

func (c *Client) NewAgentCert(commonName, comment string) error

func (*Client) NewAgentCertByCSR

func (c *Client) NewAgentCertByCSR(csr string, commonName string) ([]byte, error)

func (*Client) NewCert

func (c *Client) NewCert(commonName, keyType string, keyBits int, password, comment string) error

func (*Client) NewCertByCSR

func (c *Client) NewCertByCSR(csr string, commonName string) (*rpc.CertItem, error)

func (*Client) NewServerCert

func (c *Client) NewServerCert(csr []byte) ([]byte, error)

func (*Client) NewServiceAccount

func (c *Client) NewServiceAccount(id, comment string) error

func (*Client) NewToken

func (c *Client) NewToken(name, userId string) (*rpc.AccessTokenItem, error)

func (*Client) RevokeCert

func (c *Client) RevokeCert(serialNumber *big.Int) error

func (*Client) SetGPGKey

func (c *Client) SetGPGKey(key string) error

func (*Client) SetSSHKey

func (c *Client) SetSSHKey(key string) error

func (*Client) ToggleAdmin

func (c *Client) ToggleAdmin(id string) error

func (*Client) UpdateUser

func (c *Client) UpdateUser(id string, user *rpc.UserItem) error

func (*Client) UserBecomeMaintainer

func (c *Client) UserBecomeMaintainer(id, role string) error

type ClientWithUserToken

type ClientWithUserToken struct {
	*Client
}

func NewClientWithUserToken

func NewClientWithUserToken(conn *grpc.ClientConn) *ClientWithUserToken

func (*ClientWithUserToken) WithRequest

func (u *ClientWithUserToken) WithRequest(req *http.Request) *ClientWithUserToken

func (*ClientWithUserToken) WithToken

func (u *ClientWithUserToken) WithToken(token string) *ClientWithUserToken

type RevokedCert

type RevokedCert struct {
	SerialNumber *big.Int
}

type RevokedCertificateWatcher

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

func NewRevokedCertificateWatcher

func NewRevokedCertificateWatcher(conn *grpc.ClientConn, token string) (*RevokedCertificateWatcher, error)

func (*RevokedCertificateWatcher) Error

func (w *RevokedCertificateWatcher) Error() error

func (*RevokedCertificateWatcher) Get

func (w *RevokedCertificateWatcher) Get() []*RevokedCert

func (*RevokedCertificateWatcher) IsReady

func (w *RevokedCertificateWatcher) IsReady() bool