openapi

package
v0.18.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssumeRoleWithOIDCToken

func AssumeRoleWithOIDCToken(ctx context.Context, providerArn, roleArn string,
	sessionDuration time.Duration, token []byte, stsEndpoint string) (*oidctoken.Credential, error)

func GetStsEndpoint

func GetStsEndpoint(region string, vpc bool) string

func IsRamPolicyAttachedToRoleErr added in v0.6.0

func IsRamPolicyAttachedToRoleErr(err error) bool

func IsRamPolicyNotExistErr added in v0.6.0

func IsRamPolicyNotExistErr(err error) bool

func IsRamRoleNotExistErr added in v0.6.0

func IsRamRoleNotExistErr(err error) bool

func IsRamUserNotExistErr added in v0.17.0

func IsRamUserNotExistErr(err error) bool

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 NewClient

func NewClient(config *openapi.Config) (*Client, error)

func (*Client) AttachPolicyToRole added in v0.6.0

func (c *Client) AttachPolicyToRole(ctx context.Context, policyName, policyType, roleName string) error

func (*Client) CleanClusterUserPermissions added in v0.17.0

func (c *Client) CleanClusterUserPermissions(ctx context.Context, clusterId string, uid int64, force bool) error

func (*Client) CreatePolicy added in v0.6.0

func (c *Client) CreatePolicy(ctx context.Context, policy types.RamPolicy) (*types.RamPolicy, error)

func (*Client) CreateRole added in v0.4.0

func (c *Client) CreateRole(ctx context.Context, role types.RamRole) (*types.RamRole, error)

func (*Client) Credential added in v0.11.0

func (c *Client) Credential() credentials.Credential

func (*Client) DescribeUserClusterActivityState added in v0.17.0

func (c *Client) DescribeUserClusterActivityState(ctx context.Context, clusterId string, uid int64) (*UserClusterActivityState, error)

func (*Client) GetAddonMetaData added in v0.9.1

func (c *Client) GetAddonMetaData(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error)

func (*Client) GetAddonStatus added in v0.9.1

func (c *Client) GetAddonStatus(ctx context.Context, clusterId string, name string) (*types.ClusterAddon, error)

func (*Client) GetCallerIdentity added in v0.17.0

func (c *Client) GetCallerIdentity(ctx context.Context) (*types.Account, error)

func (*Client) GetCluster

func (c *Client) GetCluster(ctx context.Context, clusterId string) (*types.Cluster, error)

func (*Client) GetPolicy added in v0.6.0

func (c *Client) GetPolicy(ctx context.Context, name, policyType string) (*types.RamPolicy, error)

func (*Client) GetRecentClusterLogs

func (c *Client) GetRecentClusterLogs(ctx context.Context, clusterId string) ([]types.ClusterLog, error)

func (*Client) GetRole

func (c *Client) GetRole(ctx context.Context, name string) (*types.RamRole, error)

func (*Client) GetTask

func (c *Client) GetTask(ctx context.Context, taskId string) (*types.ClusterTask, error)

func (*Client) GetUserKubeConfig added in v0.7.0

func (c *Client) GetUserKubeConfig(ctx context.Context, clusterId string,
	privateIpAddress bool, temporaryDuration time.Duration) (*types.KubeConfig, error)

func (*Client) InstallAddon added in v0.9.1

func (c *Client) InstallAddon(ctx context.Context, clusterId string, addon types.ClusterAddon) error

func (*Client) ListAddons added in v0.9.1

func (c *Client) ListAddons(ctx context.Context, clusterId string) ([]types.ClusterAddon, error)

func (*Client) ListClusters added in v0.9.0

func (c *Client) ListClusters(ctx context.Context) ([]types.Cluster, error)

XXXDeprecated: use ListClustersV1 instead

func (*Client) ListClustersV1 added in v0.17.0

func (c *Client) ListClustersV1(ctx context.Context) ([]types.Cluster, error)

func (*Client) ListPoliciesForRole added in v0.6.0

func (c *Client) ListPoliciesForRole(ctx context.Context, name string) ([]types.RamRolePolicy, error)

func (*Client) ListRoles added in v0.17.0

func (c *Client) ListRoles(ctx context.Context) ([]types.RamRole, error)

func (*Client) ListUsers added in v0.17.0

func (c *Client) ListUsers(ctx context.Context) ([]types.RamUser, error)

func (*Client) UpdateCluster

func (c *Client) UpdateCluster(ctx context.Context, clusterId string, opt UpdateClusterOption) (*types.ClusterTask, error)

func (*Client) UpdateRole

func (c *Client) UpdateRole(ctx context.Context, name string, opt UpdateRamRoleOption) (*types.RamRole, error)

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 StsClientInterface interface {
	GetCallerIdentity(ctx context.Context) (*types.Account, error)
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL