Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type AsyncClient struct + 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 struct + func (_m AsyncClient_Download) Return(outputFuture catalog.DownloadFuture, err error) *AsyncClient_Download + type AsyncClient_Upload struct + func (_m AsyncClient_Upload) Return(putFuture catalog.UploadFuture, err error) *AsyncClient_Upload + type Client struct + 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 struct + func (_m Client_Get) Return(_a0 catalog.Entry, _a1 error) *Client_Get + type Client_GetOrExtendReservation struct + func (_m Client_GetOrExtendReservation) Return(_a0 *datacatalog.Reservation, _a1 error) *Client_GetOrExtendReservation + type Client_Put struct + func (_m Client_Put) Return(_a0 catalog.Status, _a1 error) *Client_Put + type Client_ReleaseReservation struct + func (_m Client_ReleaseReservation) Return(_a0 error) *Client_ReleaseReservation + type Client_Update struct + func (_m Client_Update) Return(_a0 catalog.Status, _a1 error) *Client_Update + type DownloadFuture struct + 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 struct + func (_m DownloadFuture_GetResponse) Return(_a0 catalog.DownloadResponse, _a1 error) *DownloadFuture_GetResponse + type DownloadFuture_GetResponseError struct + func (_m DownloadFuture_GetResponseError) Return(_a0 error) *DownloadFuture_GetResponseError + type DownloadFuture_GetResponseStatus struct + func (_m DownloadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *DownloadFuture_GetResponseStatus + type DownloadResponse struct + 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 struct + func (_m DownloadResponse_GetCachedCount) Return(_a0 int) *DownloadResponse_GetCachedCount + type DownloadResponse_GetCachedResults struct + func (_m DownloadResponse_GetCachedResults) Return(_a0 *bitarray.BitSet) *DownloadResponse_GetCachedResults + type DownloadResponse_GetResultsSize struct + func (_m DownloadResponse_GetResultsSize) Return(_a0 int) *DownloadResponse_GetResultsSize + type Future struct + 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 struct + func (_m Future_GetResponseError) Return(_a0 error) *Future_GetResponseError + type Future_GetResponseStatus struct + func (_m Future_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *Future_GetResponseStatus + type UploadFuture struct + 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 struct + func (_m UploadFuture_GetResponseError) Return(_a0 error) *UploadFuture_GetResponseError + type UploadFuture_GetResponseStatus struct + func (_m UploadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *UploadFuture_GetResponseStatus