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) (catalog.Entry, error)
- func (_m *Client) GetOrExtendReservation(ctx context.Context, key catalog.Key, ownerID string, ...) (*datacatalog.Reservation, error)
- func (_m *Client) OnGet(ctx context.Context, key catalog.Key) *Client_Get
- func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get
- func (_m *Client) OnGetOrExtendReservation(ctx context.Context, key catalog.Key, ownerID string, ...) *Client_GetOrExtendReservation
- func (_m *Client) OnGetOrExtendReservationMatch(matchers ...interface{}) *Client_GetOrExtendReservation
- 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) OnReleaseReservation(ctx context.Context, key catalog.Key, ownerID string) *Client_ReleaseReservation
- func (_m *Client) OnReleaseReservationMatch(matchers ...interface{}) *Client_ReleaseReservation
- func (_m *Client) OnUpdate(ctx context.Context, key catalog.Key, reader io.OutputReader, ...) *Client_Update
- func (_m *Client) OnUpdateMatch(matchers ...interface{}) *Client_Update
- func (_m *Client) Put(ctx context.Context, key catalog.Key, reader io.OutputReader, ...) (catalog.Status, error)
- func (_m *Client) ReleaseReservation(ctx context.Context, key catalog.Key, ownerID string) error
- func (_m *Client) Update(ctx context.Context, key catalog.Key, reader io.OutputReader, ...) (catalog.Status, error)
- type Client_Get
- type Client_GetOrExtendReservation
- type Client_Put
- type Client_ReleaseReservation
- type Client_Update
- 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) GetOrExtendReservation ¶
func (_m *Client) GetOrExtendReservation(ctx context.Context, key catalog.Key, ownerID string, heartbeatInterval time.Duration) (*datacatalog.Reservation, error)
GetOrExtendReservation provides a mock function with given fields: ctx, key, ownerID, heartbeatInterval
func (*Client) OnGetMatch ¶
func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get
func (*Client) OnGetOrExtendReservation ¶
func (*Client) OnGetOrExtendReservationMatch ¶
func (_m *Client) OnGetOrExtendReservationMatch(matchers ...interface{}) *Client_GetOrExtendReservation
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
func (*Client) OnReleaseReservation ¶
func (*Client) OnReleaseReservationMatch ¶
func (_m *Client) OnReleaseReservationMatch(matchers ...interface{}) *Client_ReleaseReservation
func (*Client) OnUpdate ¶
func (_m *Client) OnUpdate(ctx context.Context, key catalog.Key, reader io.OutputReader, metadata catalog.Metadata) *Client_Update
func (*Client) OnUpdateMatch ¶
func (_m *Client) OnUpdateMatch(matchers ...interface{}) *Client_Update
func (*Client) Put ¶
func (_m *Client) Put(ctx context.Context, key catalog.Key, reader io.OutputReader, metadata catalog.Metadata) (catalog.Status, error)
Put provides a mock function with given fields: ctx, key, reader, metadata
func (*Client) ReleaseReservation ¶
ReleaseReservation provides a mock function with given fields: ctx, key, ownerID
type Client_Get ¶
func (Client_Get) Return ¶
func (_m Client_Get) Return(_a0 catalog.Entry, _a1 error) *Client_Get
type Client_GetOrExtendReservation ¶
func (Client_GetOrExtendReservation) Return ¶
func (_m Client_GetOrExtendReservation) Return(_a0 *datacatalog.Reservation, _a1 error) *Client_GetOrExtendReservation
type Client_Put ¶
func (Client_Put) Return ¶
func (_m Client_Put) Return(_a0 catalog.Status, _a1 error) *Client_Put
type Client_ReleaseReservation ¶
func (Client_ReleaseReservation) Return ¶
func (_m Client_ReleaseReservation) Return(_a0 error) *Client_ReleaseReservation
type Client_Update ¶
func (Client_Update) Return ¶
func (_m Client_Update) Return(_a0 catalog.Status, _a1 error) *Client_Update
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