api

package

v0.0.0-...-8b27293 Latest Latest Go to latest Published: Sep 29, 2021 License: Apache-2.0 Imports: 25 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/paulmatencio/s3c

Documentation ¶

Index ¶

Constants
func AbortMultipartUpload(req datatype.AbortMultipartUploadRequest) error
func AddBucketAcl(req datatype.PutBucketAclRequest) (*s3.PutBucketAclOutput, error)
func AddObjectAcl(req datatype.PutObjectAclRequest) (*s3.PutObjectAclOutput, error)
func CompleteMultipartUpload(req datatype.CompleteMultipartUploadRequest) (*s3.CompleteMultipartUploadOutput, error)
func ContentToJson(contents []byte) string
func CopyObject(req datatype.CopyObjRequest) (*s3.CopyObjectOutput, error)
func CreateMultipartUpload(req datatype.CreateMultipartUploadRequest) (*s3.CreateMultipartUploadOutput, error)
func CreateSession() *session.Session
func CreateSession2(req datatype.CreateSession) *session.Session
func DeleteBucket(req datatype.DeleteBucketRequest) (*s3.DeleteBucketOutput, error)
func DeleteObjectVersions(req []*datatype.DeleteObjRequest) (*s3.DeleteObjectsOutput, error)
func DeleteObjects(req datatype.DeleteObjRequest) (*s3.DeleteObjectOutput, error)
func FputObject(req datatype.FputObjRequest) (*s3.PutObjectOutput, error)
func FputObject2(req datatype.FputObjRequest) (*s3.PutObjectOutput, error)
func GetBucketAcl(req datatype.GetBucketAclRequest) (*s3.GetBucketAclOutput, error)
func GetBucketPolicy(req datatype.GetBucketPolicyRequest) (*s3.GetBucketPolicyOutput, error)
func GetBucketReplication(req datatype.GetBucketReplicationRequest) (*s3.GetBucketReplicationOutput, error)
func GetMultipart(req datatype.GetMultipartObjRequest) (int64, error)
func GetMultipartToBuffer(req datatype.GetMultipartObjRequest) (int64, *aws.WriteAtBuffer, error)
func GetObject(req datatype.GetObjRequest) (*s3.GetObjectOutput, error)
func GetObjectAcl(req datatype.GetObjAclRequest) (*s3.GetObjectAclOutput, error)
func GetRaftBucket(client *http.Client, url string, bucket string) (error, *datatype.RaftBucket)
func GetRaftBuckets(client *http.Client, url string) (error, []string)
func GetRaftBucketsV2(client *http.Client, url string) (error, []string)
func GetRaftConfig(what string, url string) (error, bool)
func GetRaftLeader(client *http.Client, url string) (error, *datatype.RaftLeader)
func GetRaftLeaderV2(client *http.Client, url string) (error, datatype.RaftLeader)
func GetRaftSession(client *http.Client, url string, sessionId int) (error, *datatype.RaftSessionInfo)
func GetRaftSessionsV2(client *http.Client, url string) (error, *datatype.RaftSessions)
func GetRaftState(client *http.Client, url string) (error, *datatype.RaftState)
func GetRaftStatus(client *http.Client, url string) (error, string)
func HeathCheck(client *http.Client, url string) (error, *datatype.HealthCheck)
func ListBucket(req datatype.ListBucketRequest) (*s3.ListBucketsOutput, error)
func ListCommonPrefix(cp []interface{})
func ListMultipartObject(req datatype.ListMultipartObjRequest) (*s3.ListMultipartUploadsOutput, error)
func ListObject(req datatype.ListObjRequest) (*s3.ListObjectsOutput, error)
func ListObjectLdb(request datatype.ListObjLdbRequest) (datatype.Rlb, error)
func ListObjectV2(req datatype.ListObjV2Request) (*s3.ListObjectsV2Output, error)
func ListObjectVersions(req datatype.ListObjVersionsRequest) (*s3.ListObjectVersionsOutput, error)
func ListObjectVersionsWithContext(req datatype.ListObjVersionsRequest) (*s3.ListObjectVersionsOutput, error)
func ListObjectWithContext(timeout time.Duration, req datatype.ListObjRequest) (*s3.ListObjectsOutput, error)
func ListObjectWithContextV2(timeout time.Duration, req datatype.ListObjV2Request) (*s3.ListObjectsV2Output, error)
func ListRaftSessions(client *http.Client, url string) (error, *datatype.RaftSessions)
func MakeBucket(req datatype.MakeBucketRequest) (*s3.CreateBucketOutput, error)
func PutBucketAcl(req datatype.PutBucketAclRequest) (*s3.PutBucketAclOutput, error)
func PutObject(req datatype.PutObjRequest) (*s3.PutObjectOutput, error)
func PutObject2(req datatype.PutObjRequest) (*s3.PutObjectOutput, error)
func PutObjectAcl(req datatype.PutObjectAclRequest) (*s3.PutObjectAclOutput, error)
func PutObjectWithContext(timeout time.Duration, req datatype.PutObjRequest3) (*s3.PutObjectOutput, error)
func SetContext(timeout time.Duration) (context.Context, context.CancelFunc)
func StatBucket(req datatype.StatBucketRequest) (*s3.HeadBucketOutput, error)
func StatObject(req datatype.StatObjRequest) (*s3.HeadObjectOutput, error)
func StatObjectV2(request datatype.StatObjRequestV2) (*http.Response, error)
func UploadPart(req datatype.UploadPartRequest) (*s3.CompletedPart, error)
type Resp

Constants ¶

View Source

const (
	CONTIMEOUT = 2000  // connection timeout in ms
	KEEPALIVE  = 15000 // keep alive  in ms
)

Variables ¶

This section is empty.

Functions ¶

func AbortMultipartUpload ¶

func AbortMultipartUpload(req datatype.AbortMultipartUploadRequest) error

func AddBucketAcl ¶

func AddBucketAcl(req datatype.PutBucketAclRequest) (*s3.PutBucketAclOutput, error)

func AddObjectAcl ¶

func AddObjectAcl(req datatype.PutObjectAclRequest) (*s3.PutObjectAclOutput, error)

func CompleteMultipartUpload ¶

func CompleteMultipartUpload(req datatype.CompleteMultipartUploadRequest) (*s3.CompleteMultipartUploadOutput, error)

func ContentToJson ¶

func ContentToJson(contents []byte) string

transform content returned by the bucketd API into JSON string

func CopyObject ¶

func CopyObject(req datatype.CopyObjRequest) (*s3.CopyObjectOutput, error)

func CreateMultipartUpload ¶

func CreateMultipartUpload(req datatype.CreateMultipartUploadRequest) (*s3.CreateMultipartUploadOutput, error)

func CreateSession ¶

func CreateSession() *session.Session

func CreateSession2 ¶

func CreateSession2(req datatype.CreateSession) *session.Session

func DeleteBucket ¶

func DeleteBucket(req datatype.DeleteBucketRequest) (*s3.DeleteBucketOutput, error)

func DeleteObjectVersions ¶

func DeleteObjectVersions(req []*datatype.DeleteObjRequest) (*s3.DeleteObjectsOutput, error)

func DeleteObjects ¶

func DeleteObjects(req datatype.DeleteObjRequest) (*s3.DeleteObjectOutput, error)

func FputObject ¶

func FputObject(req datatype.FputObjRequest) (*s3.PutObjectOutput, error)

func FputObject2 ¶

func FputObject2(req datatype.FputObjRequest) (*s3.PutObjectOutput, error)

func GetBucketAcl ¶

func GetBucketAcl(req datatype.GetBucketAclRequest) (*s3.GetBucketAclOutput, error)

func GetBucketPolicy ¶

func GetBucketPolicy(req datatype.GetBucketPolicyRequest) (*s3.GetBucketPolicyOutput, error)

func GetBucketReplication ¶

func GetBucketReplication(req datatype.GetBucketReplicationRequest) (*s3.GetBucketReplicationOutput, error)

func GetMultipart ¶

func GetMultipart(req datatype.GetMultipartObjRequest) (int64, error)

func GetMultipartToBuffer ¶

func GetMultipartToBuffer(req datatype.GetMultipartObjRequest) (int64, *aws.WriteAtBuffer, error)

func GetObject ¶

func GetObject(req datatype.GetObjRequest) (*s3.GetObjectOutput, error)

func GetObjectAcl ¶

func GetObjectAcl(req datatype.GetObjAclRequest) (*s3.GetObjectAclOutput, error)

func GetRaftBucket ¶

func GetRaftBucket(client *http.Client, url string, bucket string) (error, *datatype.RaftBucket)

func GetRaftBuckets ¶

func GetRaftBuckets(client *http.Client, url string) (error, []string)

func GetRaftBucketsV2 ¶

func GetRaftBucketsV2(client *http.Client, url string) (error, []string)

func GetRaftConfig ¶

func GetRaftConfig(what string, url string) (error, bool)

func GetRaftLeader ¶

func GetRaftLeader(client *http.Client, url string) (error, *datatype.RaftLeader)

func GetRaftLeaderV2 ¶

func GetRaftLeaderV2(client *http.Client, url string) (error, datatype.RaftLeader)

func GetRaftSession ¶

func GetRaftSession(client *http.Client, url string, sessionId int) (error, *datatype.RaftSessionInfo)

func GetRaftSessionsV2 ¶

func GetRaftSessionsV2(client *http.Client, url string) (error, *datatype.RaftSessions)

func GetRaftState ¶

func GetRaftState(client *http.Client, url string) (error, *datatype.RaftState)

func GetRaftStatus ¶

func GetRaftStatus(client *http.Client, url string) (error, string)

func HeathCheck ¶

func HeathCheck(client *http.Client, url string) (error, *datatype.HealthCheck)

func ListBucket ¶

func ListBucket(req datatype.ListBucketRequest) (*s3.ListBucketsOutput, error)

func ListCommonPrefix ¶

func ListCommonPrefix(cp []interface{})

func ListMultipartObject ¶

func ListMultipartObject(req datatype.ListMultipartObjRequest) (*s3.ListMultipartUploadsOutput, error)

func ListObject ¶

func ListObject(req datatype.ListObjRequest) (*s3.ListObjectsOutput, error)

func ListObjectLdb ¶

func ListObjectLdb(request datatype.ListObjLdbRequest) (datatype.Rlb, error)

func ListObjectV2 ¶

func ListObjectV2(req datatype.ListObjV2Request) (*s3.ListObjectsV2Output, error)

func ListObjectVersions ¶

func ListObjectVersions(req datatype.ListObjVersionsRequest) (*s3.ListObjectVersionsOutput, error)

func ListObjectVersionsWithContext ¶

func ListObjectVersionsWithContext(req datatype.ListObjVersionsRequest) (*s3.ListObjectVersionsOutput, error)

func ListObjectWithContext ¶

func ListObjectWithContext(timeout time.Duration, req datatype.ListObjRequest) (*s3.ListObjectsOutput, error)

func ListObjectWithContextV2 ¶

func ListObjectWithContextV2(timeout time.Duration, req datatype.ListObjV2Request) (*s3.ListObjectsV2Output, error)

func ListRaftSessions ¶

func ListRaftSessions(client *http.Client, url string) (error, *datatype.RaftSessions)

func MakeBucket ¶

func MakeBucket(req datatype.MakeBucketRequest) (*s3.CreateBucketOutput, error)

func PutBucketAcl ¶

func PutBucketAcl(req datatype.PutBucketAclRequest) (*s3.PutBucketAclOutput, error)

func PutObject ¶

func PutObject(req datatype.PutObjRequest) (*s3.PutObjectOutput, error)

func PutObject2 ¶

func PutObject2(req datatype.PutObjRequest) (*s3.PutObjectOutput, error)

func PutObjectAcl ¶

func PutObjectAcl(req datatype.PutObjectAclRequest) (*s3.PutObjectAclOutput, error)

func PutObjectWithContext ¶

func PutObjectWithContext(timeout time.Duration, req datatype.PutObjRequest3) (*s3.PutObjectOutput, error)

func SetContext ¶

func SetContext(timeout time.Duration) (context.Context, context.CancelFunc)

func StatBucket ¶

func StatBucket(req datatype.StatBucketRequest) (*s3.HeadBucketOutput, error)

func StatObject ¶

func StatObject(req datatype.StatObjRequest) (*s3.HeadObjectOutput, error)

func StatObjectV2 ¶

func StatObjectV2(request datatype.StatObjRequestV2) (*http.Response, error)

func UploadPart ¶

func UploadPart(req datatype.UploadPartRequest) (*s3.CompletedPart, error)

Types ¶

type Resp ¶

type Resp struct {
	Result *interface{}
	Err    error
	Status int
}

Source Files ¶

View all Source files

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