openapi

Documentation

Index

• func AssumeRoleWithOIDCToken(ctx context.Context, providerArn, roleArn string, ...) (*oidctoken.Credential, error)
• func GetStsEndpoint(region string, vpc bool) string
• type CSClientInterface
• type Client
  • func NewClient(config *openapi.Config) (*Client, error)
  • func (c *Client) GetCluster(ctx context.Context, clusterId string) (*types.Cluster, 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) 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

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)
}

type Client

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

func NewClient

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

func (*Client) GetCluster

func (c *Client) GetCluster(ctx context.Context, clusterId string) (*types.Cluster, 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) 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)
	UpdateRole(ctx context.Context, name string, opt UpdateRamRoleOption) (*types.RamRole, error)
}

type UpdateClusterOption

type UpdateClusterOption struct {
	EnableRRSA *bool
}

type UpdateRamRoleOption

type UpdateRamRoleOption struct {
	AssumeRolePolicyDocument *types.AssumeRolePolicyDocument
}