Documentation ¶
Index ¶
- func AssumeRoleWithOIDCToken(ctx context.Context, providerArn, roleArn string, ...) (*oidctoken.Credential, error)
- func GetStsEndpoint(region string, vpc bool) string
- func IsRamPolicyAttachedToRoleErr(err error) bool
- func IsRamPolicyNotExistErr(err error) bool
- func IsRamRoleNotExistErr(err error) bool
- func IsRamUserNotExistErr(err error) bool
- type CSClientInterface
- type Client
- func (c *Client) AttachPolicyToRole(ctx context.Context, policyName, policyType, roleName string) error
- func (c *Client) CleanClusterUserPermissions(ctx context.Context, clusterId string, uid int64, force bool) error
- func (c *Client) CreatePolicy(ctx context.Context, policy types.RamPolicy) (*types.RamPolicy, error)
- func (c *Client) CreateRole(ctx context.Context, role types.RamRole) (*types.RamRole, error)
- func (c *Client) Credential() credentials.Credential
- func (c *Client) DescribeUserClusterActivityState(ctx context.Context, clusterId string, uid int64) (*UserClusterActivityState, error)
- func (c *Client) GetAddonMetaData(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error)
- func (c *Client) GetAddonStatus(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error)
- func (c *Client) GetCallerIdentity(ctx context.Context) (*types.Account, error)
- func (c *Client) GetCluster(ctx context.Context, clusterId string) (*types.Cluster, error)
- func (c *Client) GetPolicy(ctx context.Context, name, policyType string) (*types.RamPolicy, error)
- func (c *Client) GetRecentClusterLogs(ctx context.Context, clusterId string) ([]types.ClusterLog, error)
- func (c *Client) GetRole(ctx context.Context, name string) (*types.RamRole, error)
- func (c *Client) GetTask(ctx context.Context, taskId string) (*types.ClusterTask, error)
- func (c *Client) GetUserKubeConfig(ctx context.Context, clusterId string, privateIpAddress bool, ...) (*types.KubeConfig, error)
- func (c *Client) InstallAddon(ctx context.Context, clusterId string, addon types.ClusterAddon) error
- func (c *Client) ListAddons(ctx context.Context, clusterId string) ([]types.ClusterAddon, error)
- func (c *Client) ListClusters(ctx context.Context) ([]types.Cluster, error)
- func (c *Client) ListClustersV1(ctx context.Context) ([]types.Cluster, error)
- func (c *Client) ListPoliciesForRole(ctx context.Context, name string) ([]types.RamRolePolicy, error)
- func (c *Client) ListRoles(ctx context.Context) ([]types.RamRole, error)
- func (c *Client) ListUsers(ctx context.Context) ([]types.RamUser, error)
- func (c *Client) UpdateCluster(ctx context.Context, clusterId string, opt UpdateClusterOption) (*types.ClusterTask, error)
- func (c *Client) UpdateRole(ctx context.Context, name string, opt UpdateRamRoleOption) (*types.RamRole, error)
- type ClientInterface
- type RamClientInterface
- type StsClientInterface
- type UpdateClusterOption
- type UpdateRamRoleOption
- type UserClusterActivityState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssumeRoleWithOIDCToken ¶
func GetStsEndpoint ¶
func IsRamPolicyAttachedToRoleErr ¶ added in v0.6.0
func IsRamPolicyNotExistErr ¶ added in v0.6.0
func IsRamRoleNotExistErr ¶ added in v0.6.0
func IsRamUserNotExistErr ¶ added in v0.17.0
Types ¶
type CSClientInterface ¶
type CSClientInterface interface { GetCluster(ctx context.Context, clusterId string) (*types.Cluster, error) GetRecentClusterLogs(ctx context.Context, clusterId string) ([]types.ClusterLog, error) UpdateCluster(ctx context.Context, clusterId string, opt UpdateClusterOption) (*types.ClusterTask, error) GetTask(ctx context.Context, taskId string) (*types.ClusterTask, error) GetUserKubeConfig(ctx context.Context, clusterId string, privateIpAddress bool, temporaryDuration time.Duration) (*types.KubeConfig, error) // XXXDeprecated: use ListClustersV1 instead ListClusters(ctx context.Context) ([]types.Cluster, error) ListClustersV1(ctx context.Context) ([]types.Cluster, error) GetAddonMetaData(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error) GetAddonStatus(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error) InstallAddon(ctx context.Context, clusterId string, addon types.ClusterAddon) error ListAddons(ctx context.Context, clusterId string) ([]types.ClusterAddon, error) CleanClusterUserPermissions(ctx context.Context, clusterId string, uid int64, force bool) error DescribeUserClusterActivityState(ctx context.Context, clusterId string, uid int64) (*UserClusterActivityState, error) }
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) AttachPolicyToRole ¶ added in v0.6.0
func (*Client) CleanClusterUserPermissions ¶ added in v0.17.0
func (*Client) CreatePolicy ¶ added in v0.6.0
func (*Client) CreateRole ¶ added in v0.4.0
func (*Client) Credential ¶ added in v0.11.0
func (c *Client) Credential() credentials.Credential
func (*Client) DescribeUserClusterActivityState ¶ added in v0.17.0
func (*Client) GetAddonMetaData ¶ added in v0.9.1
func (*Client) GetAddonStatus ¶ added in v0.9.1
func (*Client) GetCallerIdentity ¶ added in v0.17.0
func (*Client) GetCluster ¶
func (*Client) GetRecentClusterLogs ¶
func (*Client) GetUserKubeConfig ¶ added in v0.7.0
func (*Client) InstallAddon ¶ added in v0.9.1
func (*Client) ListAddons ¶ added in v0.9.1
func (*Client) ListClusters ¶ added in v0.9.0
XXXDeprecated: use ListClustersV1 instead
func (*Client) ListClustersV1 ¶ added in v0.17.0
func (*Client) ListPoliciesForRole ¶ added in v0.6.0
func (*Client) UpdateCluster ¶
func (c *Client) UpdateCluster(ctx context.Context, clusterId string, opt UpdateClusterOption) (*types.ClusterTask, error)
func (*Client) UpdateRole ¶
type ClientInterface ¶ added in v0.17.0
type ClientInterface interface { RamClientInterface CSClientInterface StsClientInterface }
type RamClientInterface ¶
type RamClientInterface interface { GetRole(ctx context.Context, name string) (*types.RamRole, error) CreateRole(ctx context.Context, role types.RamRole) (*types.RamRole, error) UpdateRole(ctx context.Context, name string, opt UpdateRamRoleOption) (*types.RamRole, error) ListPoliciesForRole(ctx context.Context, name string) ([]types.RamRolePolicy, error) GetPolicy(ctx context.Context, name, policyType string) (*types.RamPolicy, error) CreatePolicy(ctx context.Context, policy types.RamPolicy) (*types.RamPolicy, error) AttachPolicyToRole(ctx context.Context, policyName, policyType, roleName string) error ListUsers(ctx context.Context) ([]types.RamUser, error) ListRoles(ctx context.Context) ([]types.RamRole, error) }
type StsClientInterface ¶ added in v0.17.0
type UpdateClusterOption ¶
type UpdateClusterOption struct {
EnableRRSA *bool
}
type UpdateRamRoleOption ¶
type UpdateRamRoleOption struct {
AssumeRolePolicyDocument *types.RamPolicyDocument
}
type UserClusterActivityState ¶ added in v0.17.0
type UserClusterActivityState struct { LogProjectName string `json:"log_project_name,omitempty"` LogStoreName string `json:"log_store_name,omitempty"` LogQueryExp string `json:"log_query_exp,omitempty"` Active bool `json:"active"` LastActivity *metav1.Time `json:"last_activity,omitempty"` LastAuditId string `json:"last_audit_id,omitempty"` }
func (UserClusterActivityState) LastLocalActivity ¶ added in v0.17.0
func (s UserClusterActivityState) LastLocalActivity() string
Click to show internal directories.
Click to hide internal directories.