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
Redistributable license
Tagged version
Stable version
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