openapi

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
• type CSClientInterface
• type Client
  • func NewClient(config *openapi.Config) (*Client, error)
  • func (c *Client) AttachPolicyToRole(ctx context.Context, policyName, policyType, roleName string) 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) 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) ListPoliciesForRole(ctx context.Context, name string) ([]types.RamRolePolicy, 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 RamClientInterface
• type UpdateClusterOption
• type UpdateRamRoleOption

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

func IsRamPolicyAttachedToRoleErr(err error) bool

func IsRamPolicyNotExistErr

func IsRamPolicyNotExistErr(err error) bool

func IsRamRoleNotExistErr

func IsRamRoleNotExistErr(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)
}

type Client

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

func NewClient

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

func (*Client) AttachPolicyToRole

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

func (*Client) CreatePolicy

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

func (*Client) CreateRole

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

func (*Client) GetCluster

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

func (*Client) GetPolicy

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

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

func (*Client) ListPoliciesForRole

func (c *Client) ListPoliciesForRole(ctx context.Context, name string) ([]types.RamRolePolicy, 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 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
}

type UpdateClusterOption

type UpdateClusterOption struct {
	EnableRRSA *bool
}

type UpdateRamRoleOption

type UpdateRamRoleOption struct {
	AssumeRolePolicyDocument *types.RamPolicyDocument
}