openapi

package
v0.20.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2024 License: Apache-2.0 Imports: 21 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 NewClientWithEndpoints added in v0.19.0 

func NewClientWithEndpoints(config *openapi.Config, endpoints Endpoints) (*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 Endpoints added in v0.19.0 

type Endpoints struct {
	RAM string
	STS string
	CS  string
}

func NewEndpoints added in v0.19.0 

func NewEndpoints(region string, vpc bool) Endpoints

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.