aws

package

v0.1.0 Latest Latest Go to latest Published: Feb 14, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

func AuthUser(accessKeyID string, secretAccessKey string) (bool, error)
func DeleteFromS3ByPrefix(prefix string, continueIfFailure bool) error
func GetLogs(prefix string) (string, error)
func IsNoSuchKeyErr(err error) bool
func IsNotFoundErr(err error) bool
func IsS3Dir(dirPath string) (bool, error)
func IsS3File(key string) (bool, error)
func IsS3FileExternal(key string, bucket string) (bool, error)
func IsS3Prefix(prefix string) (bool, error)
func IsS3PrefixExternal(prefix string, bucket string) (bool, error)
func IsS3aPrefixExternal(s3aPath string) (bool, error)
func ReadBytesFromS3(key string) ([]byte, error)
func ReadJSONFromS3(objPtr interface{}, key string) error
func ReadMsgpackFromS3(objPtr interface{}, key string) error
func ReadStringFromS3(key string) (string, error)
func S3Path(key string) string
func UploadBufferToS3(buffer *bytes.Buffer, key string) error
func UploadBytesToS3(data []byte, key string) error
func UploadBytesesToS3(data []byte, keys ...string) error
func UploadFileToS3(filePath string, key string) error
func UploadJSONToS3(obj interface{}, key string) error
func UploadMsgpackToS3(obj interface{}, key string) error
func UploadStringToS3(str string, key string) error
type FluentdLog

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AuthUser ¶

func AuthUser(accessKeyID string, secretAccessKey string) (bool, error)

func DeleteFromS3ByPrefix ¶

func DeleteFromS3ByPrefix(prefix string, continueIfFailure bool) error

func GetLogs ¶

func GetLogs(prefix string) (string, error)

func IsNoSuchKeyErr ¶

func IsNoSuchKeyErr(err error) bool

func IsNotFoundErr ¶

func IsNotFoundErr(err error) bool

func IsS3Dir ¶

func IsS3Dir(dirPath string) (bool, error)

func IsS3File ¶

func IsS3File(key string) (bool, error)

func IsS3FileExternal ¶

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

func IsS3Prefix ¶

func IsS3Prefix(prefix string) (bool, error)

func IsS3PrefixExternal ¶

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

func IsS3aPrefixExternal ¶

func IsS3aPrefixExternal(s3aPath string) (bool, error)

func ReadBytesFromS3 ¶

func ReadBytesFromS3(key string) ([]byte, error)

func ReadJSONFromS3 ¶

func ReadJSONFromS3(objPtr interface{}, key string) error

func ReadMsgpackFromS3 ¶

func ReadMsgpackFromS3(objPtr interface{}, key string) error

func ReadStringFromS3 ¶

func ReadStringFromS3(key string) (string, error)

func S3Path ¶

func S3Path(key string) string

func UploadBufferToS3 ¶

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

func UploadBytesToS3 ¶

func UploadBytesToS3(data []byte, key string) error

func UploadBytesesToS3 ¶

func UploadBytesesToS3(data []byte, keys ...string) error

func UploadFileToS3 ¶

func UploadFileToS3(filePath string, key string) error

func UploadJSONToS3 ¶

func UploadJSONToS3(obj interface{}, key string) error

func UploadMsgpackToS3 ¶

func UploadMsgpackToS3(obj interface{}, key string) error

func UploadStringToS3 ¶

func UploadStringToS3(str string, key string) error

Types ¶

type FluentdLog ¶

type FluentdLog struct {
	Log    string `json:"log"`
	Stream string `json:"stream"`
	Docker struct {
		Container_id string `json:"container_id"`
	} `json:"docker"`
	Kubernetes struct {
		Container_name     string `json:"container_name"`
		Namespace_name     string `json:"namespace_name"`
		Pod_name           string `json:"pod_name"`
		Orphaned_namespace string `json:"orphaned_namespace"`
		Namespace_id       string `json:"namespace_id"`
	} `json:"kubernetes"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL