Documentation ¶
Index ¶
- type AsyncClient
- func (_m *AsyncClient) Download(ctx context.Context, requests ...catalog.DownloadRequest) (catalog.DownloadFuture, error)
- func (_m *AsyncClient) OnDownload(ctx context.Context, requests ...catalog.DownloadRequest) *AsyncClient_Download
- func (_m *AsyncClient) OnDownloadMatch(matchers ...interface{}) *AsyncClient_Download
- func (_m *AsyncClient) OnUpload(ctx context.Context, requests ...catalog.UploadRequest) *AsyncClient_Upload
- func (_m *AsyncClient) OnUploadMatch(matchers ...interface{}) *AsyncClient_Upload
- func (_m *AsyncClient) Upload(ctx context.Context, requests ...catalog.UploadRequest) (catalog.UploadFuture, error)
- type AsyncClient_Download
- type AsyncClient_Upload
- type Client
- func (_m *Client) Get(ctx context.Context, key catalog.Key) (io.OutputReader, error)
- func (_m *Client) OnGet(ctx context.Context, key catalog.Key) *Client_Get
- func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get
- func (_m *Client) OnPut(ctx context.Context, key catalog.Key, reader io.OutputReader, ...) *Client_Put
- func (_m *Client) OnPutMatch(matchers ...interface{}) *Client_Put
- func (_m *Client) Put(ctx context.Context, key catalog.Key, reader io.OutputReader, ...) error
- type Client_Get
- type Client_Put
- type DownloadFuture
- func (_m *DownloadFuture) GetResponse() (catalog.DownloadResponse, error)
- func (_m *DownloadFuture) GetResponseError() error
- func (_m *DownloadFuture) GetResponseStatus() catalog.ResponseStatus
- func (_m *DownloadFuture) OnGetResponse() *DownloadFuture_GetResponse
- func (_m *DownloadFuture) OnGetResponseError() *DownloadFuture_GetResponseError
- func (_m *DownloadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *DownloadFuture_GetResponseError
- func (_m *DownloadFuture) OnGetResponseMatch(matchers ...interface{}) *DownloadFuture_GetResponse
- func (_m *DownloadFuture) OnGetResponseStatus() *DownloadFuture_GetResponseStatus
- func (_m *DownloadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *DownloadFuture_GetResponseStatus
- func (_m *DownloadFuture) OnReady(handler catalog.ReadyHandler)
- type DownloadFuture_GetResponse
- type DownloadFuture_GetResponseError
- type DownloadFuture_GetResponseStatus
- type DownloadResponse
- func (_m *DownloadResponse) GetCachedCount() int
- func (_m *DownloadResponse) GetCachedResults() *bitarray.BitSet
- func (_m *DownloadResponse) GetResultsSize() int
- func (_m *DownloadResponse) OnGetCachedCount() *DownloadResponse_GetCachedCount
- func (_m *DownloadResponse) OnGetCachedCountMatch(matchers ...interface{}) *DownloadResponse_GetCachedCount
- func (_m *DownloadResponse) OnGetCachedResults() *DownloadResponse_GetCachedResults
- func (_m *DownloadResponse) OnGetCachedResultsMatch(matchers ...interface{}) *DownloadResponse_GetCachedResults
- func (_m *DownloadResponse) OnGetResultsSize() *DownloadResponse_GetResultsSize
- func (_m *DownloadResponse) OnGetResultsSizeMatch(matchers ...interface{}) *DownloadResponse_GetResultsSize
- type DownloadResponse_GetCachedCount
- type DownloadResponse_GetCachedResults
- type DownloadResponse_GetResultsSize
- type Future
- func (_m *Future) GetResponseError() error
- func (_m *Future) GetResponseStatus() catalog.ResponseStatus
- func (_m *Future) OnGetResponseError() *Future_GetResponseError
- func (_m *Future) OnGetResponseErrorMatch(matchers ...interface{}) *Future_GetResponseError
- func (_m *Future) OnGetResponseStatus() *Future_GetResponseStatus
- func (_m *Future) OnGetResponseStatusMatch(matchers ...interface{}) *Future_GetResponseStatus
- func (_m *Future) OnReady(handler catalog.ReadyHandler)
- type Future_GetResponseError
- type Future_GetResponseStatus
- type UploadFuture
- func (_m *UploadFuture) GetResponseError() error
- func (_m *UploadFuture) GetResponseStatus() catalog.ResponseStatus
- func (_m *UploadFuture) OnGetResponseError() *UploadFuture_GetResponseError
- func (_m *UploadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *UploadFuture_GetResponseError
- func (_m *UploadFuture) OnGetResponseStatus() *UploadFuture_GetResponseStatus
- func (_m *UploadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *UploadFuture_GetResponseStatus
- func (_m *UploadFuture) OnReady(handler catalog.ReadyHandler)
- type UploadFuture_GetResponseError
- type UploadFuture_GetResponseStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncClient ¶
AsyncClient is an autogenerated mock type for the AsyncClient type
func (*AsyncClient) Download ¶
func (_m *AsyncClient) Download(ctx context.Context, requests ...catalog.DownloadRequest) (catalog.DownloadFuture, error)
Download provides a mock function with given fields: ctx, requests
func (*AsyncClient) OnDownload ¶
func (_m *AsyncClient) OnDownload(ctx context.Context, requests ...catalog.DownloadRequest) *AsyncClient_Download
func (*AsyncClient) OnDownloadMatch ¶
func (_m *AsyncClient) OnDownloadMatch(matchers ...interface{}) *AsyncClient_Download
func (*AsyncClient) OnUpload ¶
func (_m *AsyncClient) OnUpload(ctx context.Context, requests ...catalog.UploadRequest) *AsyncClient_Upload
func (*AsyncClient) OnUploadMatch ¶
func (_m *AsyncClient) OnUploadMatch(matchers ...interface{}) *AsyncClient_Upload
func (*AsyncClient) Upload ¶
func (_m *AsyncClient) Upload(ctx context.Context, requests ...catalog.UploadRequest) (catalog.UploadFuture, error)
Upload provides a mock function with given fields: ctx, requests
type AsyncClient_Download ¶
func (AsyncClient_Download) Return ¶
func (_m AsyncClient_Download) Return(outputFuture catalog.DownloadFuture, err error) *AsyncClient_Download
type AsyncClient_Upload ¶
func (AsyncClient_Upload) Return ¶
func (_m AsyncClient_Upload) Return(putFuture catalog.UploadFuture, err error) *AsyncClient_Upload
type Client ¶
Client is an autogenerated mock type for the Client type
func (*Client) OnGetMatch ¶
func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get
func (*Client) OnPut ¶
func (_m *Client) OnPut(ctx context.Context, key catalog.Key, reader io.OutputReader, metadata catalog.Metadata) *Client_Put
func (*Client) OnPutMatch ¶
func (_m *Client) OnPutMatch(matchers ...interface{}) *Client_Put
type Client_Get ¶
func (Client_Get) Return ¶
func (_m Client_Get) Return(_a0 io.OutputReader, _a1 error) *Client_Get
type Client_Put ¶
func (Client_Put) Return ¶
func (_m Client_Put) Return(_a0 error) *Client_Put
type DownloadFuture ¶
DownloadFuture is an autogenerated mock type for the DownloadFuture type
func (*DownloadFuture) GetResponse ¶
func (_m *DownloadFuture) GetResponse() (catalog.DownloadResponse, error)
GetResponse provides a mock function with given fields:
func (*DownloadFuture) GetResponseError ¶
func (_m *DownloadFuture) GetResponseError() error
GetResponseError provides a mock function with given fields:
func (*DownloadFuture) GetResponseStatus ¶
func (_m *DownloadFuture) GetResponseStatus() catalog.ResponseStatus
GetResponseStatus provides a mock function with given fields:
func (*DownloadFuture) OnGetResponse ¶
func (_m *DownloadFuture) OnGetResponse() *DownloadFuture_GetResponse
func (*DownloadFuture) OnGetResponseError ¶
func (_m *DownloadFuture) OnGetResponseError() *DownloadFuture_GetResponseError
func (*DownloadFuture) OnGetResponseErrorMatch ¶
func (_m *DownloadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *DownloadFuture_GetResponseError
func (*DownloadFuture) OnGetResponseMatch ¶
func (_m *DownloadFuture) OnGetResponseMatch(matchers ...interface{}) *DownloadFuture_GetResponse
func (*DownloadFuture) OnGetResponseStatus ¶
func (_m *DownloadFuture) OnGetResponseStatus() *DownloadFuture_GetResponseStatus
func (*DownloadFuture) OnGetResponseStatusMatch ¶
func (_m *DownloadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *DownloadFuture_GetResponseStatus
func (*DownloadFuture) OnReady ¶
func (_m *DownloadFuture) OnReady(handler catalog.ReadyHandler)
OnReady provides a mock function with given fields: handler
type DownloadFuture_GetResponse ¶
func (DownloadFuture_GetResponse) Return ¶
func (_m DownloadFuture_GetResponse) Return(_a0 catalog.DownloadResponse, _a1 error) *DownloadFuture_GetResponse
type DownloadFuture_GetResponseError ¶
func (DownloadFuture_GetResponseError) Return ¶
func (_m DownloadFuture_GetResponseError) Return(_a0 error) *DownloadFuture_GetResponseError
type DownloadFuture_GetResponseStatus ¶
func (DownloadFuture_GetResponseStatus) Return ¶
func (_m DownloadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *DownloadFuture_GetResponseStatus
type DownloadResponse ¶
DownloadResponse is an autogenerated mock type for the DownloadResponse type
func (*DownloadResponse) GetCachedCount ¶
func (_m *DownloadResponse) GetCachedCount() int
GetCachedCount provides a mock function with given fields:
func (*DownloadResponse) GetCachedResults ¶
func (_m *DownloadResponse) GetCachedResults() *bitarray.BitSet
GetCachedResults provides a mock function with given fields:
func (*DownloadResponse) GetResultsSize ¶
func (_m *DownloadResponse) GetResultsSize() int
GetResultsSize provides a mock function with given fields:
func (*DownloadResponse) OnGetCachedCount ¶
func (_m *DownloadResponse) OnGetCachedCount() *DownloadResponse_GetCachedCount
func (*DownloadResponse) OnGetCachedCountMatch ¶
func (_m *DownloadResponse) OnGetCachedCountMatch(matchers ...interface{}) *DownloadResponse_GetCachedCount
func (*DownloadResponse) OnGetCachedResults ¶
func (_m *DownloadResponse) OnGetCachedResults() *DownloadResponse_GetCachedResults
func (*DownloadResponse) OnGetCachedResultsMatch ¶
func (_m *DownloadResponse) OnGetCachedResultsMatch(matchers ...interface{}) *DownloadResponse_GetCachedResults
func (*DownloadResponse) OnGetResultsSize ¶
func (_m *DownloadResponse) OnGetResultsSize() *DownloadResponse_GetResultsSize
func (*DownloadResponse) OnGetResultsSizeMatch ¶
func (_m *DownloadResponse) OnGetResultsSizeMatch(matchers ...interface{}) *DownloadResponse_GetResultsSize
type DownloadResponse_GetCachedCount ¶
func (DownloadResponse_GetCachedCount) Return ¶
func (_m DownloadResponse_GetCachedCount) Return(_a0 int) *DownloadResponse_GetCachedCount
type DownloadResponse_GetCachedResults ¶
func (DownloadResponse_GetCachedResults) Return ¶
func (_m DownloadResponse_GetCachedResults) Return(_a0 *bitarray.BitSet) *DownloadResponse_GetCachedResults
type DownloadResponse_GetResultsSize ¶
func (DownloadResponse_GetResultsSize) Return ¶
func (_m DownloadResponse_GetResultsSize) Return(_a0 int) *DownloadResponse_GetResultsSize
type Future ¶
Future is an autogenerated mock type for the Future type
func (*Future) GetResponseError ¶
GetResponseError provides a mock function with given fields:
func (*Future) GetResponseStatus ¶
func (_m *Future) GetResponseStatus() catalog.ResponseStatus
GetResponseStatus provides a mock function with given fields:
func (*Future) OnGetResponseError ¶
func (_m *Future) OnGetResponseError() *Future_GetResponseError
func (*Future) OnGetResponseErrorMatch ¶
func (_m *Future) OnGetResponseErrorMatch(matchers ...interface{}) *Future_GetResponseError
func (*Future) OnGetResponseStatus ¶
func (_m *Future) OnGetResponseStatus() *Future_GetResponseStatus
func (*Future) OnGetResponseStatusMatch ¶
func (_m *Future) OnGetResponseStatusMatch(matchers ...interface{}) *Future_GetResponseStatus
func (*Future) OnReady ¶
func (_m *Future) OnReady(handler catalog.ReadyHandler)
OnReady provides a mock function with given fields: handler
type Future_GetResponseError ¶
func (Future_GetResponseError) Return ¶
func (_m Future_GetResponseError) Return(_a0 error) *Future_GetResponseError
type Future_GetResponseStatus ¶
func (Future_GetResponseStatus) Return ¶
func (_m Future_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *Future_GetResponseStatus
type UploadFuture ¶
UploadFuture is an autogenerated mock type for the UploadFuture type
func (*UploadFuture) GetResponseError ¶
func (_m *UploadFuture) GetResponseError() error
GetResponseError provides a mock function with given fields:
func (*UploadFuture) GetResponseStatus ¶
func (_m *UploadFuture) GetResponseStatus() catalog.ResponseStatus
GetResponseStatus provides a mock function with given fields:
func (*UploadFuture) OnGetResponseError ¶
func (_m *UploadFuture) OnGetResponseError() *UploadFuture_GetResponseError
func (*UploadFuture) OnGetResponseErrorMatch ¶
func (_m *UploadFuture) OnGetResponseErrorMatch(matchers ...interface{}) *UploadFuture_GetResponseError
func (*UploadFuture) OnGetResponseStatus ¶
func (_m *UploadFuture) OnGetResponseStatus() *UploadFuture_GetResponseStatus
func (*UploadFuture) OnGetResponseStatusMatch ¶
func (_m *UploadFuture) OnGetResponseStatusMatch(matchers ...interface{}) *UploadFuture_GetResponseStatus
func (*UploadFuture) OnReady ¶
func (_m *UploadFuture) OnReady(handler catalog.ReadyHandler)
OnReady provides a mock function with given fields: handler
type UploadFuture_GetResponseError ¶
func (UploadFuture_GetResponseError) Return ¶
func (_m UploadFuture_GetResponseError) Return(_a0 error) *UploadFuture_GetResponseError
type UploadFuture_GetResponseStatus ¶
func (UploadFuture_GetResponseStatus) Return ¶
func (_m UploadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *UploadFuture_GetResponseStatus