aws

Jan 8, 2022

Changes in this version

+ func IsAlevoInstance(instanceType string) (bool, error)

+ func IsFPGAInstance(instanceType string) (bool, error)

+ func IsGaudiInstance(instanceType string) (bool, error)

+ func IsLoadBalancerV2Healthy(loadBalancer elbv2.LoadBalancer) bool

+ func IsTrainiumInstance(instanceType string) (bool, error)

+ type ClassicLoadBalancerState string

+ const LoadBalancerStateInService

+ const LoadBalancerStateOutOfService

+ const LoadBalancerStateUnknown

+ func (state ClassicLoadBalancerState) String() string

type Client

+ func (c *Client) ELB() *elb.ELB

+ func (c *Client) FindLoadBalancerV2(tags map[string]string) (*elbv2.LoadBalancer, error)

+ func (c *Client) IsLoadBalancerHealthy(loadBalancerName string) (bool, error)

Jul 6, 2021

Changes in this version

+ func IsGPUInstance(instanceType string) (bool, error)

+ func IsInferentiaInstance(instanceType string) (bool, error)

+ func IsNvidiaGPUInstance(instanceType string) (bool, error)

Jun 24, 2021

Changes in this version

+ func IsMacInstance(instanceType string) (bool, error)

type Client

+ func (c *Client) EnableBucketEncryption(bucket string) error

+ func (c *Client) ListServiceQuotas(quotaCodes []string, serviceCodes []string) (map[string]int, error)

+ func (c *Client) VerifyEIPQuota(eipQuota int, availabilityZones strset.Set, highlyAvailableNATGateway bool) error

+ func (c *Client) VerifyInternetGatewayQuota(internetGatewayQuota int, requiredInternetGateways int) error

+ func (c *Client) VerifyNATGatewayQuota(natGatewayQuota int, availabilityZones strset.Set, ...) error

+ func (c *Client) VerifySecurityGroupQuota(securifyGroupsQuota int, numNodeGroups int, clusterAlreadyExists bool) error

+ func (c *Client) VerifySecurityGroupRulesQuota(securifyGroupRulesQuota int, availabilityZones strset.Set, numNodeGroups int, ...) error

+ func (c *Client) VerifyVPCQuota(vpcQuota int, requiredVPCs int) error

Jun 8, 2021

Changes in this version

type Client

+ func NewForSession(sess *session.Session) (*Client, error)

May 11, 2021

Changes in this version

+ const ErrInvalidInstanceType

+ const ErrSecurityGroupLimitExceeded

+ const ErrSecurityGroupRulesExceeded

+ var AllInstanceTypes = strset.New("a1.medium", "a1.large", "a1.xlarge", "a1.2xlarge", "a1.4xlarge", "a1.metal", ...)

+ var InstanceTypes = map[string]strset.Set

+ func CheckValidInstanceType(instanceType string) error

+ func ErrorInvalidInstanceType(instanceType string) error

+ func ErrorSecurityGroupLimitExceeded(currentLimit, additionalQuotaRequired int, region string) error

+ func ErrorSecurityGroupRulesExceeded(currentLimit, additionalQuotaRequired int, region string) error

+ func IsAMDGPUInstance(instanceType string) (bool, error)

+ func IsValidInstanceType(instanceType string) bool

type Client

+ func (c *Client) DeleteLifecycleRules(bucket string) error

+ func (c *Client) DeleteLogGroup(logGroup string) error

+ func (c *Client) DescribeSecurityGroups() ([]ec2.SecurityGroup, error)

+ func (c *Client) GetLifecycleRules(bucket string) ([]s3.LifecycleRule, error)

+ func (c *Client) GetPolicyOrNil(policyARN string) (*iam.Policy, error)

+ func (c *Client) ListS3TopLevelDirs(bucket string) ([]string, error)

+ func (c *Client) SetLifecycleRules(bucket string, rules []s3.LifecycleRule) error

+ func (c Client) Session() *session.Session

type EBSMetadata

+ PriceThroughput float64

+ ThroughputConfigurable bool

+ type ParsedInstanceType struct

+ Capabilities strset.Set

+ Family string

+ Generation int

+ Size string

+ func ParseInstanceType(instanceType string) (ParsedInstanceType, error)

Apr 27, 2021

Changes in this version

+ func PartitionFromRegion(region string) string

type Client

+ func (c *Client) CreateEmptyS3File(bucket string, key string) error

Mar 17, 2021

Changes in this version

type Client

+ func (c *Client) DeleteVolume(volumeID string) error

+ func (c *Client) ListVolumes(tags ...ec2.Tag) ([]ec2.Volume, error)

+ type InstanceTypeRequests struct

+ InstanceType string

+ RequiredOnDemandInstances int64

+ RequiredSpotInstances int64

Mar 2, 2021

Changes in this version

+ const ErrEIPLimitExceeded

+ const ErrInternetGatewayLimitExceeded

+ const ErrNATGatewayLimitExceeded

+ const ErrRegionNotConfigured

+ const ErrUnableToFindCredentials

+ const ErrVPCLimitExceeded

+ func ErrorEIPLimitExceeded(currentLimit, additionalQuotaRequired int, region string) error

+ func ErrorInternetGatewayLimitExceeded(currentLimit, additionalQuotaRequired int, region string) error

+ func ErrorNATGatewayLimitExceeded(currentLimit, additionalQuotaRequired int, availabilityZones []string, ...) error

+ func ErrorRegionNotConfigured() error

+ func ErrorUnableToFindCredentials() error

+ func ErrorVPCLimitExceeded(currentLimit, additionalQuotaRequired int, region string) error

+ func ExecuteIdentityRequestFromHeader(indentityRequestheader string) (string, error)

+ func IsAWSError(err error) bool

+ func IsNoSuchEntityErr(err error) bool

type Client

+ func NewForRegion(region string) (*Client, error)

+ func NewFromS3Bucket(bucket string) (*Client, error)

+ func (c *Client) DeletePolicy(policyARN string) error

+ func (c *Client) DescribeNATGateways() ([]ec2.NatGateway, error)

+ func (c *Client) DescribeSubnets() ([]ec2.Subnet, error)

+ func (c *Client) DescribeVpcs() ([]ec2.Vpc, error)

+ func (c *Client) IdentityRequestAsHeader() (string, error)

+ func (c *Client) ListElasticIPs() ([]string, error)

+ func (c *Client) ListInternetGateways() ([]string, error)

+ func (c *Client) SessionToken() *string

+ func (c *Client) VerifyNetworkQuotas(requiredInternetGateways int, natGatewayRequired bool, ...) error

Dec 23, 2020

Changes in this version

+ func IsNonExistentQueueErr(err error) bool

Nov 24, 2020

Changes in this version

type Client

+ func (c *Client) ListS3DirOneLevel(bucket string, s3Dir string, maxResults *int64) ([]string, error)

Nov 11, 2020

Changes in this version

+ const ErrInsufficientInstanceQuota

+ func ConvertS3ObjectsToKeys(s3Objects ...*s3.Object) []string

+ func ErrorInsufficientInstanceQuota(instanceType string, lifecycle string, region string, requiredInstances int64, ...) error

+ func IsARMInstance(instanceType string) bool

+ func IsInstanceSupportedByNLB(instanceType string) bool

type Client

+ func (c *Client) GetNLevelsDeepFromS3Path(s3Path string, depth int, includeDirObjects bool, maxResults *int64) ([]string, []string, error)

Oct 27, 2020

Changes in this version

+ var NLBUnsupportedInstancePrefixes = strset.New("c1", "cc1", "cc2", "cg1", "cg2", "cr1", "g1", "g2", "hi1", "hs1", "m1", "m2", ...)

Sep 29, 2020

Changes in this version

type Client

+ func (c *Client) EKS() *eks.EKS

+ func (c *Client) EKSClusterOrNil(clusterName string) (*eks.Cluster, error)

+ func (c *Client) ELBV2() *elbv2.ELBV2

+ func (c *Client) FindLoadBalancer(tags map[string]string) (*elbv2.LoadBalancer, error)

+ func (c *Client) MostRecentASGActivity(asgName string) (*autoscaling.Activity, error)

Aug 25, 2020

Changes in this version

+ const ErrDashboardHeightOutOfRange

+ const ErrDashboardWidthOutOfRange

+ func ErrorDashboardHeightOutOfRange(height int) error

+ func ErrorDashboardWidthOutOfRange(width int) error

type Client

+ func (c *Client) DeleteQueuesWithPrefix(queueNamePrefix string) error

+ func (c *Client) DeleteS3File(bucket string, key string) error

+ func (c *Client) DoesQueueExist(queueName string) (bool, error)

+ func (c *Client) GetAllQueueAttributes(queueURL string) (map[string]string, error)

+ func (c *Client) ListQueuesByQueueNamePrefix(queueNamePrefix string) ([]string, error)

+ func (c *Client) ReadMsgpackFromS3Path(objPtr interface{}, s3Path string) error

+ func (c *Client) S3FileIterator(bucket string, s3Obj *s3.Object, partSize int, ...) error

+ func (c *Client) SQS() *sqs.SQS

+ type CloudWatchWidgetGrid struct

+ NumColumns int

+ NumRows int

+ WidgetHeight int

+ WidgetWidth int

+ Widgets []CloudWatchWidget

+ XOrigin int

+ YOrigin int

+ func NewHorizontalGrid(xOrigin, yOrigin, widgetHeight, widgetWidth, numColumns int) (*CloudWatchWidgetGrid, error)

+ func NewVerticalGrid(xOrigin, yOrigin, widgetHeight, widgetWidth, numRows int) (*CloudWatchWidgetGrid, error)

+ func (grid *CloudWatchWidgetGrid) AddWidget(metric []interface{}, title string, stat string, period int, region string) error

Jun 30, 2020

Changes in this version

type Client

+ func (c *Client) CreateAPIGateway(name string, tags map[string]string) (string, error)

+ func (c *Client) DeleteAPIGateway(apiGatewayID string) error

Jun 24, 2020

Changes in this version

+ func ExtractRouteIntegrationID(route *apigatewayv2.Route) string

type Client

+ func (c *Client) APIGatewayV2() *apigatewayv2.ApiGatewayV2

+ func (c *Client) CreateHTTPIntegration(apiGatewayID string, targetEndpoint string) (string, error)

+ func (c *Client) CreateRoute(apiGatewayID string, integrationID string, endpoint string) error

+ func (c *Client) DeleteAPIGatewayByTag(tagName string, tagValue string) (*apigatewayv2.Api, error)

+ func (c *Client) DeleteAPIGatewayMappings(apiGatewayID string) error

+ func (c *Client) DeleteAPIGatewayMappingsForDomainName(apiGatewayID string, domainName string) error

+ func (c *Client) DeleteIntegration(apiGatewayID string, integrationID string) error

+ func (c *Client) DeleteRoute(apiGatewayID string, endpoint string) (*apigatewayv2.Route, error)

+ func (c *Client) DeleteVPCLinkByTag(tagName string, tagValue string) (*apigatewayv2.VpcLink, error)

+ func (c *Client) GetAPIGatewayByTag(tagName string, tagValue string) (*apigatewayv2.Api, error)

+ func (c *Client) GetRoute(apiGatewayID string, endpoint string) (*apigatewayv2.Route, error)

+ func (c *Client) GetRouteIntegrationID(apiGatewayID string, endpoint string) (string, error)

+ func (c *Client) GetVPCLinkByTag(tagName string, tagValue string) (*apigatewayv2.VpcLink, error)

+ func (c *Client) GetVPCLinkIntegration(apiGatewayID string, vpcLinkID string) (*apigatewayv2.Integration, error)

type InstanceMetadata

+ Inf int64

May 22, 2020

Changes in this version

+ func HighestY(dashboard *CloudWatchDashboard) (int, error)

+ func IsErrCode(err error, errorCode string) bool

type Client

+ func (c *Client) ACM() *acm.ACM

+ func (c *Client) CloudWatch() *cloudwatch.CloudWatch

+ func (c *Client) CreateDashboard(dashboardName string, title string) error

+ func (c *Client) DeleteDashboard(dashboardName string) error

+ func (c *Client) DoesCertificateExist(sslCertificateARN string) (bool, error)

+ func (c *Client) DoesDashboardExist(dashboardName string) (bool, error)

+ func (c *Client) GetDashboard(dashboardName string) (*CloudWatchDashboard, error)

+ func (c *Client) GetDashboardOrEmpty(dashboardName string, title string) (*CloudWatchDashboard, error)

+ func (c *Client) ListAvailabilityZonesInRegion() (strset.Set, error)

+ func (c *Client) NewDashboard(title string) *CloudWatchDashboard

+ func (c *Client) PutDashboard(dashboard *CloudWatchDashboard, dashboardName string) error

+ func (c *Client) TagBucket(bucket string, tagMap map[string]string) error

+ func (c *Client) TagLogGroup(logGroup string, tagMap map[string]string) error

+ type CloudWatchDashboard struct

+ PeriodOverride string

+ Start string

+ Widgets []CloudWatchWidget

+ type CloudWatchWidget struct

+ Height int

+ Properties map[string]interface{}

+ Type string

+ Width int

+ X int

+ Y int

+ func MetricWidget(x int, y int, width int, height int, metric []interface{}, title string, ...) CloudWatchWidget

+ func TextWidget(x int, y int, width int, height int, markdown string) CloudWatchWidget

May 15, 2020

Changes in this version

+ const ErrUnexpectedMissingCredentials

+ func ErrorUnexpectedMissingCredentials(awsAccessKeyID *string, awsSecretAccessKey *string) error

+ func GetBucketRegionFromS3Path(s3Path string) (string, error)

type Client

+ func NewFromClientS3Path(s3Path string, awsClient *Client) (*Client, error)

May 4, 2020

Changes in this version

+ const ErrECRExtractingCredentials

+ var NLBMetadatas = map[string]NLBMetadata

+ func ErrorECRExtractingCredentials() error

+ func GetAccountIDFromECRURL(path string) string

+ func GetRegionFromECRURL(path string) string

type Client

+ IsAnonymous bool

+ func NewAnonymousClient() (*Client, error)

+ func NewAnonymousClientWithRegion(region string) (*Client, error)

+ func (c *Client) DeleteS3Dir(bucket string, s3Dir string, continueIfFailure bool) error

+ func (c *Client) DeleteS3Prefix(bucket string, prefix string, continueIfFailure bool) error

+ func (c *Client) DownloadDirFromS3(bucket string, s3Dir string, localDirPath string, shouldTrimDirPrefix bool, ...) error

+ func (c *Client) DownloadFileFromS3(bucket string, key string, localPath string) error

+ func (c *Client) DownloadPrefixFromS3(bucket string, prefix string, localDirPath string, shouldTrimDirPrefix bool, ...) error

+ func (c *Client) ECR() *ecr.ECR

+ func (c *Client) GetECRAuthConfig() (ECRAuthConfig, error)

+ func (c *Client) GetECRAuthToken() (*ecr.GetAuthorizationTokenOutput, error)

+ func (c *Client) HashS3Dir(bucket string, prefix string, maxResults *int64) (string, error)

+ func (c *Client) ListS3Dir(bucket string, s3Dir string, includeDirObjects bool, maxResults *int64) ([]*s3.Object, error)

+ func (c *Client) ListS3PathDir(s3DirPath string, includeDirObjects bool, maxResults *int64) ([]*s3.Object, error)

+ func (c *Client) ListS3PathPrefix(s3Path string, includeDirObjects bool, maxResults *int64) ([]*s3.Object, error)

+ func (c *Client) ListS3Prefix(bucket string, prefix string, includeDirObjects bool, maxResults *int64) ([]*s3.Object, error)

+ func (c *Client) ReadBufferFromS3(bucket string, key string) (*bytes.Buffer, error)

+ func (c *Client) ReadReaderFromS3(bucket string, key string) (io.ReadCloser, error)

+ func (c *Client) S3BatchIterator(bucket string, prefix string, includeDirObjects bool, maxResults *int64, ...) error

+ func (c *Client) S3Downloader() *s3manager.Downloader

+ func (c *Client) S3Iterator(bucket string, prefix string, includeDirObjects bool, maxResults *int64, ...) error

+ func (c *Client) S3Uploader() *s3manager.Uploader

+ func (c *Client) SecretAccessKey() *string

+ func (c *Client) UploadDirToS3(localDirPath string, bucket string, s3Dir string, ignoreFns ...files.IgnoreFn) error

+ func (c *Client) UploadReaderToS3(data io.Reader, bucket string, key string) error

type EBSMetadata

+ IOPSConfigurable bool

+ PriceGB float64

+ PriceIOPS float64

+ Type string

+ type ECRAuthConfig struct

+ AccessToken string

+ ProxyEndpoint string

+ Username string

+ type NLBMetadata struct

+ Price float64

+ Region string

Mar 25, 2020

Changes in this version

+ func IsForbiddenErr(err error) bool

type Client

+ func (c *Client) AccessKeyID() *string

+ func (c *Client) CloudFormation() *cloudformation.CloudFormation

+ func (c *Client) CreateBucket(bucket string) error

+ func (c *Client) CreateLogGroup(logGroup string) error

+ func (c *Client) DoesBucketExist(bucket string) (bool, error)

+ func (c *Client) DoesLogGroupExist(logGroup string) (bool, error)

+ func (c *Client) GetGroupsForUser(userName string) ([]iam.Group, error)

+ func (c *Client) GetManagedPoliciesForUser(userName string) ([]iam.AttachedPolicy, error)

+ func (c *Client) GetUser() (iam.User, error)

+ func (c *Client) IAM() *iam.IAM

+ func (c *Client) IsAdmin() bool

+ func (c *Client) ListAllRegions() (strset.Set, error)

+ func (c *Client) ListAvailabilityZones() (strset.Set, error)

+ func (c *Client) ListEKSStacks(controlPlaneStackName string, nodegroupStackNames strset.Set) ([]*cloudformation.StackSummary, error)

+ func (c *Client) ListEnabledRegions() (strset.Set, error)

+ func (c *Client) ListRegions() (strset.Set, strset.Set, error)

+ func (c *Client) ListSupportedAvailabilityZones(instanceType string, instanceTypes ...string) (strset.Set, error)

Jan 29, 2020

Changes in this version

+ var EKSPrices = map[string]float64

Jan 22, 2020

Changes in this version

+ func ErrorBucketNotFound(bucket string) error

+ func ErrorInvalidAWSCredentials() error

+ func JoinS3Path(paths ...string) string

+ func S3Path(bucket string, key string) string

type Client

+ func NewFromCreds(region string, accessKeyID string, secretAccessKey string) (*Client, error)

+ func NewFromCredsS3Bucket(bucket string, accessKeyID string, secretAccessKey string) (*Client, error)

+ func NewFromCredsS3Path(s3Path string, accessKeyID string, secretAccessKey string) (*Client, error)

+ func NewFromEnv(region string) (*Client, error)

+ func NewFromEnvS3Bucket(bucket string) (*Client, error)

+ func NewFromEnvS3Path(s3Path string) (*Client, error)

+ func (c *Client) AreCredentialsValid() (string, string, bool, error)

+ func (c *Client) Autoscaling() *autoscaling.AutoScaling

+ func (c *Client) CheckCredentials() (string, string, error)

+ func (c *Client) CloudWatchLogs() *cloudwatchlogs.CloudWatchLogs

+ func (c *Client) DeleteDir(bucket string, prefix string, continueIfFailure bool) error

+ func (c *Client) DeletePrefix(bucket string, prefix string, continueIfFailure bool) error

+ func (c *Client) EC2() *ec2.EC2

+ func (c *Client) GetAvailabilityZones() ([]string, error)

+ func (c *Client) GetCachedAccountID() (string, string, error)

+ func (c *Client) ListDir(bucket string, prefix string, maxResults int64) ([]*s3.Object, error)

+ func (c *Client) ListPathDir(s3Path string, maxResults int64) ([]*s3.Object, error)

+ func (c *Client) ListPathPrefix(s3Path string, maxResults int64) ([]*s3.Object, error)

+ func (c *Client) ReadBytesFromS3Path(s3Path string) ([]byte, error)

+ func (c *Client) ReadStringFromS3Path(s3Path string) (string, error)

+ func (c *Client) STS() *sts.STS

+ func (c *Client) ServiceQuotas() *servicequotas.ServiceQuotas

+ func (c *Client) SpotInstancePrice(region string, instanceType string) (float64, error)

+ func (c *Client) VerifyInstanceQuota(instanceType string) error

type ErrorKind

+ const ErrBucketNotFound

+ const ErrInvalidAWSCredentials

Dec 26, 2019

Changes in this version

+ var EBSMetadatas = map[string]EBSMetadata

+ var EKSSupportedRegionsSlice []string

+ var ELBMetadatas = map[string]ELBMetadata

+ var NATMetadatas = map[string]NATMetadata

+ func ErrorInstanceTypeLimitIsZero(instanceType string, region string) error

+ func ErrorNoValidSpotPrices(instanceType string, region string) error

+ func GetAvailabilityZones(accessKeyID string, secretAccessKey string, region string) ([]string, error)

+ func SpotInstancePrice(accessKeyID string, secretAccessKey string, region string, instanceType string) (float64, error)

+ func VerifyInstanceQuota(accessKeyID, secretAccessKey, region, instanceType string) error

+ type EBSMetadata struct

+ Price float64

+ Region string

+ type ELBMetadata struct

+ Price float64

+ Region string

type ErrorKind

+ const ErrInstanceTypeLimitIsZero

+ const ErrNoValidSpotPrices

+ type NATMetadata struct

+ Price float64

+ Region string

Nov 28, 2019

Changes in this version

+ var EKSSupportedRegions strset.Set

+ var InstanceMetadatas = map[string]map[string]InstanceMetadata

+ type InstanceMetadata struct

+ CPU kresource.Quantity

+ GPU int64

+ Memory kresource.Quantity

+ Price float64

+ Region string

+ Type string

Nov 15, 2019

Changes in this version

type Client

+ func (c *Client) AutoscalingGroups(tags map[string]string) ([]*autoscaling.Group, error)

Nov 5, 2019

Changes in this version

+ func AccountID(accessKeyID string, secretAccessKey string, region string) (string, bool, error)

+ func ErrorReadCredentials() error

+ func GetCredentialsFromCLIConfigFile() (string, string, error)

type Client

+ AccountID string

type ErrorKind

+ const ErrReadCredentials

Oct 15, 2019

Changes in this version

+ func IsGenericNotFoundErr(err error) bool

+ func IsNoSuchBucketErr(err error) bool

Sep 24, 2019

Changes in this version

+ func CheckErrCode(err error, errorCode string) bool

+ func ErrorBucketInaccessible(bucket string) error

+ func S3PathJoin(paths ...string) string

type Client

+ CloudWatchLogsClient *cloudwatchlogs.CloudWatchLogs

+ CloudWatchMetrics *cloudwatch.CloudWatch

+ S3 *s3.S3

+ func NewFromS3Path(s3Path string, withAccountID bool) (*Client, error)

+ func (c *Client) ExractS3PathPrefixes(s3Paths ...string) ([]string, error)

+ func (c *Client) IsS3PathDir(s3Paths ...string) (bool, error)

+ func (c *Client) IsS3PathFile(s3Paths ...string) (bool, error)

+ func (c *Client) IsS3PathPrefix(s3Paths ...string) (bool, error)

+ func (c *Client) ListPrefix(prefix string, maxResults int64) ([]*s3.Object, error)

type ErrorKind

+ const ErrBucketInaccessible

Jun 27, 2019

Changes in this version

+ func GetBucketRegion(bucket string) (string, error)

+ func IsS3PathFileExternal(s3Path string) (bool, error)

+ func IsS3aPathPrefixExternal(s3aPath string) (bool, error)

Jun 14, 2019

Changes in this version

+ const DefaultS3Region

+ var S3Regions strset.Set

+ func ErrorAuth() error

+ func ErrorInvalidS3Path(provided string) error

+ func ErrorInvalidS3aPath(provided string) error

+ func IsNoSuchKeyErr(err error) bool

+ func IsNotFoundErr(err error) bool

+ func IsS3FileExternal(bucket string, key string, region string) (bool, error)

+ func IsS3PrefixExternal(bucket string, prefix string, region string) (bool, error)

+ func IsS3aPrefixExternal(s3aPath string, region string) (bool, error)

+ func IsValidS3Path(s3Path string) bool

+ func IsValidS3aPath(s3aPath string) bool

+ func SplitS3Path(s3Path string) (string, string, error)

+ func SplitS3aPath(s3aPath string) (string, string, error)

+ type Client struct

+ Bucket string

+ HashedAccountID string

+ Region string

+ func New(region, bucket string) *Client

+ func (c *Client) AuthUser(accessKeyID string, secretAccessKey string) (bool, error)

+ func (c *Client) DeleteFromS3ByPrefix(prefix string, continueIfFailure bool) error

+ func (c *Client) GetLogs(prefix string, logGroup string) (string, error)

+ func (c *Client) IsS3Dir(dirPath string) (bool, error)

+ func (c *Client) IsS3File(key string) (bool, error)

+ func (c *Client) IsS3Prefix(prefix string) (bool, error)

+ func (c *Client) ReadBytesFromS3(key string) ([]byte, error)

+ func (c *Client) ReadJSONFromS3(objPtr interface{}, key string) error

+ func (c *Client) ReadMsgpackFromS3(objPtr interface{}, key string) error

+ func (c *Client) ReadStringFromS3(key string) (string, error)

+ func (c *Client) S3Path(key string) string

+ func (c *Client) UploadBufferToS3(buffer *bytes.Buffer, key string) error

+ func (c *Client) UploadBytesToS3(data []byte, key string) error

+ func (c *Client) UploadBytesesToS3(data []byte, keys ...string) error

+ func (c *Client) UploadFileToS3(filePath string, key string) error

+ func (c *Client) UploadJSONToS3(obj interface{}, key string) error

+ func (c *Client) UploadMsgpackToS3(obj interface{}, key string) error

+ func (c *Client) UploadStringToS3(str string, key string) error

+ type Error struct

+ Kind ErrorKind

+ func (e Error) Error() string

+ type ErrorKind int

+ const ErrAuth

+ const ErrInvalidS3Path

+ const ErrInvalidS3aPath

+ const ErrUnknown

+ func (t *ErrorKind) UnmarshalBinary(data []byte) error

+ func (t *ErrorKind) UnmarshalText(text []byte) error

+ func (t ErrorKind) MarshalBinary() ([]byte, error)

+ func (t ErrorKind) MarshalText() ([]byte, error)

+ func (t ErrorKind) String() string

+ type FluentdLog struct

+ Docker struct{ ... }

+ Kubernetes struct{ ... }

+ Log string

+ Stream string