client

package

Go to main page

Versions in this module

v1

v1.6.0

Jul 30, 2018

Changes in this version

type RequestClient

+ SetUserAgent func(string)

v1.5.0

Jun 27, 2018

Changes in this version

type RequestClient

+ AccountRing func() ring.Ring

v1.4.0

May 31, 2018

Changes in this version

+ var ContainerNotFound = errors.New("Container Not Found")

+ var ErrValidTracerRequired = errors.New("valid tracer required")

+ func NewTransport(tracer opentracing.Tracer, rt http.RoundTripper, enableHTTPTrace bool) (http.RoundTripper, error)

type ProxyClient

+ Close func() error

+ NewRequestClient func(mc ring.MemcacheRing, lc map[string]*ContainerInfo, logger srv.LowLevelLogger) RequestClient

+ type RequestClient interface

+ ContainerRing func() ring.Ring

+ DeleteAccount func(ctx context.Context, account string, headers http.Header) *http.Response

+ DeleteContainer func(ctx context.Context, account string, container string, headers http.Header) *http.Response

+ DeleteObject func(ctx context.Context, account string, container string, obj string, ...) *http.Response

+ GetAccountRaw func(ctx context.Context, account string, options map[string]string, ...) *http.Response

+ GetContainerInfo func(ctx context.Context, account string, container string) (*ContainerInfo, error)

+ GetContainerRaw func(ctx context.Context, account string, container string, ...) *http.Response

+ GetObject func(ctx context.Context, account string, container string, obj string, ...) *http.Response

+ HeadAccount func(ctx context.Context, account string, headers http.Header) *http.Response

+ HeadContainer func(ctx context.Context, account string, container string, headers http.Header) *http.Response

+ HeadObject func(ctx context.Context, account string, container string, obj string, ...) *http.Response

+ ObjectRingFor func(ctx context.Context, account string, container string) (ring.Ring, *http.Response)

+ PostAccount func(ctx context.Context, account string, headers http.Header) *http.Response

+ PostContainer func(ctx context.Context, account string, container string, headers http.Header) *http.Response

+ PostObject func(ctx context.Context, account string, container string, obj string, ...) *http.Response

+ PutAccount func(ctx context.Context, account string, headers http.Header) *http.Response

+ PutContainer func(ctx context.Context, account string, container string, headers http.Header) *http.Response

+ PutObject func(ctx context.Context, account string, container string, obj string, ...) *http.Response

+ SetContainerInfo func(ctx context.Context, account string, container string, resp *http.Response) (*ContainerInfo, error)

+ type TracingClient struct

+ func NewTracingClient(tracer opentracing.Tracer, httpClient *http.Client, enableHTTPTrace bool) (*TracingClient, error)

+ func (tc *TracingClient) Do(req *http.Request) (*http.Response, error)

v1.3.0

Apr 27, 2018

Changes in this version

type ProxyClient

+ SetContainerInfo func(account string, container string, resp *http.Response) (*ContainerInfo, error)

type ProxyDirectClient

+ func (c *ProxyDirectClient) SetContainerInfo(account, container string, mc ring.MemcacheRing, lc map[string]*ContainerInfo, ...) (*ContainerInfo, error)

v1.2.0

Apr 2, 2018

v1.0.0

Jan 31, 2018

v0

v0.0.5

Jan 18, 2018

v0.0.4

Jan 17, 2018

v0.0.3

Jan 17, 2018

v0.0.2

Jan 17, 2018

Changes in this version

type ProxyClient

+ ContainerRing func() ring.Ring

type ProxyDirectClient

+ Logger srv.LowLevelLogger

v0.0.1

Jul 7, 2017

Changes in this version

+ const PostQuorumTimeoutMs

+ var NilContainerInfo = &ContainerInfo

+ func ResponseStub(statusCode int, body string) *http.Response

+ func StubResponse(resp *http.Response) *http.Response

+ type Client interface

+ DeleteAccount func(headers map[string]string) *http.Response

+ DeleteContainer func(container string, headers map[string]string) *http.Response

+ DeleteObject func(container string, obj string, headers map[string]string) *http.Response

+ GetAccount func(marker string, endMarker string, limit int, prefix string, delimiter string, ...) ([]ContainerRecord, *http.Response)

+ GetContainer func(container string, marker string, endMarker string, limit int, prefix string, ...) ([]ObjectRecord, *http.Response)

+ GetObject func(container string, obj string, headers map[string]string) *http.Response

+ HeadAccount func(headers map[string]string) *http.Response

+ HeadContainer func(container string, headers map[string]string) *http.Response

+ HeadObject func(container string, obj string, headers map[string]string) *http.Response

+ PostAccount func(headers map[string]string) *http.Response

+ PostContainer func(container string, headers map[string]string) *http.Response

+ PostObject func(container string, obj string, headers map[string]string) *http.Response

+ PutAccount func(headers map[string]string) *http.Response

+ PutContainer func(container string, headers map[string]string) *http.Response

+ PutObject func(container string, obj string, headers map[string]string, src io.Reader) *http.Response

+ func NewClient(tenant string, username string, password string, apikey string, region string, ...) (Client, *http.Response)

+ func NewDirectClient(account string) (Client, error)

+ func NewInsecureClient(tenant string, username string, password string, apikey string, region string, ...) (Client, *http.Response)

+ type ContainerInfo struct

+ Metadata map[string]string

+ ObjectBytes int64

+ ObjectCount int64

+ ReadACL string

+ StoragePolicyIndex int

+ SyncKey string

+ SysMetadata map[string]string

+ WriteACL string

+ type ContainerRecord struct

+ Bytes int64

+ Count int64

+ Name string

+ type KeystonePasswordAuthV2 struct

+ PasswordCredentials struct{ ... }

+ TenantName string

+ type KeystoneRequestV2 struct

+ Auth interface{}

+ type KeystoneResponseV2 struct

+ Access struct{ ... }

+ type ObjectRecord struct

+ Bytes int

+ ContentType string

+ Hash string

+ LastModified string

+ Name string

+ type ProxyClient interface

+ DeleteAccount func(account string, headers http.Header) *http.Response

+ DeleteContainer func(account string, container string, headers http.Header) *http.Response

+ DeleteObject func(account string, container string, obj string, headers http.Header) *http.Response

+ GetAccount func(account string, options map[string]string, headers http.Header) *http.Response

+ GetContainer func(account string, container string, options map[string]string, ...) *http.Response

+ GetContainerInfo func(account string, container string) (*ContainerInfo, error)

+ GetObject func(account string, container string, obj string, headers http.Header) *http.Response

+ HeadAccount func(account string, headers http.Header) *http.Response

+ HeadContainer func(account string, container string, headers http.Header) *http.Response

+ HeadObject func(account string, container string, obj string, headers http.Header) *http.Response

+ ObjectRingFor func(account string, container string) (ring.Ring, *http.Response)

+ PostAccount func(account string, headers http.Header) *http.Response

+ PostContainer func(account string, container string, headers http.Header) *http.Response

+ PostObject func(account string, container string, obj string, headers http.Header) *http.Response

+ PutAccount func(account string, headers http.Header) *http.Response

+ PutContainer func(account string, container string, headers http.Header) *http.Response

+ PutObject func(account string, container string, obj string, headers http.Header, ...) *http.Response

+ func NewProxyClient(pdc *ProxyDirectClient, mc ring.MemcacheRing, lc map[string]*ContainerInfo) ProxyClient

+ type ProxyDirectClient struct

+ AccountRing ring.Ring

+ ContainerRing ring.Ring

+ func NewProxyDirectClient(policyList conf.PolicyList) (*ProxyDirectClient, error)

+ func (c *ProxyDirectClient) DeleteAccount(account string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) DeleteContainer(account string, container string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) DeleteObject(account string, container string, obj string, headers http.Header, ...) *http.Response

+ func (c *ProxyDirectClient) GetAccount(account string, options map[string]string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) GetContainer(account string, container string, options map[string]string, ...) *http.Response

+ func (c *ProxyDirectClient) GetContainerInfo(account string, container string, mc ring.MemcacheRing, ...) (*ContainerInfo, error)

+ func (c *ProxyDirectClient) GetObject(account string, container string, obj string, headers http.Header, ...) *http.Response

+ func (c *ProxyDirectClient) GrepObject(account string, container string, obj string, search string, ...) *http.Response

+ func (c *ProxyDirectClient) HeadAccount(account string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) HeadContainer(account string, container string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) HeadObject(account string, container string, obj string, headers http.Header, ...) *http.Response

+ func (c *ProxyDirectClient) ObjectRingFor(account string, container string, mc ring.MemcacheRing, ...) (ring.Ring, *http.Response)

+ func (c *ProxyDirectClient) PostAccount(account string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) PostContainer(account string, container string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) PostObject(account string, container string, obj string, headers http.Header, ...) *http.Response

+ func (c *ProxyDirectClient) PutAccount(account string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) PutContainer(account string, container string, headers http.Header) *http.Response

+ func (c *ProxyDirectClient) PutObject(account string, container string, obj string, headers http.Header, ...) *http.Response

+ type RaxAPIKeyAuthV2 struct

+ APIKeyCredentials struct{ ... }

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