v1beta1

package

v0.0.0-...-bda016d Latest Latest Go to latest Published: Apr 24, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

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/Nexenta/edgex-go-connector

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateEdgex(s3xurl, authkey, secret string, debug int, options ...EdgexOption) (s3xApi.S3xClient, error)
type Edgex
type EdgexOption
- func SetHTTPClient(httpClient *http.Client) EdgexOption
type S3XURL
- func NewS3XURL(baseUrl *url.URL, path string) S3XURL
- func (s3xurl *S3XURL) AddOptions(values S3XURLOptions)
- func (s3xurl *S3XURL) String() string
type S3XURLOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateEdgex ¶

func CreateEdgex(s3xurl, authkey, secret string, debug int, options ...EdgexOption) (s3xApi.S3xClient, error)

CreateEdgex - S3X client factory

Types ¶

type Edgex ¶

type Edgex struct {

	// s3 authentication keys
	Authkey string
	Secret  string

	// Debug level
	Debug int

	// Should move to Tx struct
	Sid string
	// contains filtered or unexported fields
}

Edgex - Edgex is S3xClient implementation

func (*Edgex) BucketCreate ¶

func (edgex *Edgex) BucketCreate(bucket string) error

BucketCreate - create a new bucket

func (*Edgex) BucketDelete ¶

func (edgex *Edgex) BucketDelete(bucket string) error

BucketDelete - delete bucket

func (*Edgex) BucketHead ¶

func (edgex *Edgex) BucketHead(bucket string) error

BucketHead - read bucket header fields

func (*Edgex) BucketList ¶

func (edgex *Edgex) BucketList() ([]s3xApi.Bucket, error)

func (*Edgex) Close ¶

func (edgex *Edgex) Close(bucket, object string) error

Finalize - close client connection

func (*Edgex) KeyValueCommit ¶

func (edgex *Edgex) KeyValueCommit(bucket string, object string) error

KeyValueCommit - commit key/value insert/update/delete

func (*Edgex) KeyValueDelete ¶

func (edgex *Edgex) KeyValueDelete(bucket, object, key string, more bool) error

KeyValueDelete - delete key/value pair

func (*Edgex) KeyValueDeleteJSON ¶

func (edgex *Edgex) KeyValueDeleteJSON(bucket, object, keyValueJSON string, more bool) error

KeyValueDeleteJSON - delete key/value pairs defined by json

func (*Edgex) KeyValueGet ¶

func (edgex *Edgex) KeyValueGet(bucket, object, key string) (string, error)

KeyValueGet - read object value field

func (*Edgex) KeyValueList ¶

func (edgex *Edgex) KeyValueList(bucket, object, from, pattern, contentType string, maxcount int, values bool) (string, error)

KeyValueList - read key/value pairs, contentType: application/json or text/csv

func (*Edgex) KeyValueMapDelete ¶

func (edgex *Edgex) KeyValueMapDelete(bucket, object string, values s3xApi.S3xKVMap, more bool) error

KeyValueMapDelete - delete key/value map in JSON format

func (*Edgex) KeyValueMapPost ¶

func (edgex *Edgex) KeyValueMapPost(bucket, object string, values s3xApi.S3xKVMap, more bool) error

KeyValuePostMap - post key/value map in JSON format

func (*Edgex) KeyValuePost ¶

func (edgex *Edgex) KeyValuePost(bucket, object, key string, value *bytes.Buffer, contentType string, more bool) error

KeyValuePost - post key/value pairs

func (*Edgex) KeyValuePostCSV ¶

func (edgex *Edgex) KeyValuePostCSV(bucket, object, keyValueCSV string, more bool) error

KeyValuePostCSV - post key/value pairs presented like csv

func (*Edgex) KeyValuePostJSON ¶

func (edgex *Edgex) KeyValuePostJSON(bucket, object, keyValueJSON string, more bool) error

KeyValuePostJSON - post key/value pairs

func (*Edgex) KeyValueRollback ¶

func (edgex *Edgex) KeyValueRollback(bucket string, object string) error

KeyValueRollback - rollback key/value insert/update/delete session

func (*Edgex) ObjectCreate ¶

func (edgex *Edgex) ObjectCreate(bucket, object string, objectType s3xApi.ObjectType, contentType string, chunkSize int, btreeOrder int) error

ObjectCreate - create key/value object

func (*Edgex) ObjectDelete ¶

func (edgex *Edgex) ObjectDelete(bucket, object string) error

ObjectDelete - delete object

func (*Edgex) ObjectGetStream ¶

func (edgex *Edgex) ObjectGetStream(bucket, object string) (s3xApi.ObjectStream, error)

func (*Edgex) ObjectHead ¶

func (edgex *Edgex) ObjectHead(bucket, object string) error

ObjectHead - read object header fields

func (*Edgex) ObjectList ¶

func (edgex *Edgex) ObjectList(bucket, from, pattern string, maxcount int) ([]s3xApi.Object, error)

type EdgexOption ¶

type EdgexOption func(*Edgex)

func SetHTTPClient ¶

func SetHTTPClient(httpClient *http.Client) EdgexOption

type S3XURL ¶

type S3XURL struct {
	url.URL
}

func NewS3XURL ¶

func NewS3XURL(baseUrl *url.URL, path string) S3XURL

NewS3XURL Copies endpoint values to internal url for further use

func (*S3XURL) AddOptions ¶

func (s3xurl *S3XURL) AddOptions(values S3XURLOptions)

func (*S3XURL) String ¶

func (s3xurl *S3XURL) String() string

type S3XURLOptions ¶

type S3XURLOptions map[string]string

Source Files ¶

View all Source files

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