aws

Documentation

Index

• type AWS
  • func New(ctx context.Context, cfg Config, httpClient *http.Client) (AWS, error)
• type Config

Types

type AWS

type AWS interface {
	Bucket() awsbck.Bucket
	Group() awsgrp.Group
	Object() awsobj.Object
	Policy() awspol.Policy
	Role() awsrol.Role
	User() awsusr.User

	Config() Config
	HTTPCli() *http.Client
	Clone(ctx context.Context) (AWS, error)
	NewForConfig(ctx context.Context, cfg Config) (AWS, error)
	ForcePathStyle(ctx context.Context, enabled bool) error
	ForceSignerOptions(ctx context.Context, fct ...func(signer *sdksv4.SignerOptions)) error

	GetBucketName() string
	SetBucketName(bucket string)
	SetHTTPTimeout(dur time.Duration) error
	GetHTTPTimeout() time.Duration
	GetClientS3() *sdksss.Client
	SetClientS3(aws *sdksss.Client)
	GetClientIam() *sdkiam.Client
	SetClientIam(aws *sdkiam.Client)
}

func New

func New(ctx context.Context, cfg Config, httpClient *http.Client) (AWS, error)

type Config

type Config interface {
	Check(ctx context.Context) error
	Validate() error

	GetAccessKey() string
	GetSecretKey() string
	SetCredentials(accessKey, secretKey string)
	ResetRegionEndpoint()
	RegisterRegionEndpoint(region string, endpoint *url.URL) error
	RegisterRegionAws(endpoint *url.URL) error
	SetRegion(region string)
	GetRegion() string
	SetEndpoint(endpoint *url.URL)
	GetEndpoint() *url.URL

	IsHTTPs() bool
	ResolveEndpoint(service, region string) (sdkaws.Endpoint, error)
	ResolveEndpointWithOptions(service, region string, options ...interface{}) (sdkaws.Endpoint, error)
	GetDisableHTTPS() bool
	GetResolvedRegion() string
	SetRetryer(retryer func() sdkaws.Retryer)

	GetConfig(ctx context.Context, cli *http.Client) (*sdkaws.Config, error)
	JSON() ([]byte, error)
	Clone() Config

	GetBucketName() string
	SetBucketName(bucket string)
}