mocks

package
v1.9.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 6, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AsyncClient 

type AsyncClient struct {
	mock.Mock
}

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 

type AsyncClient_Download struct {
	*mock.Call
}

func (AsyncClient_Download) Return 

func (_m AsyncClient_Download) Return(outputFuture catalog.DownloadFuture, err error) *AsyncClient_Download

type AsyncClient_Upload 

type AsyncClient_Upload struct {
	*mock.Call
}

func (AsyncClient_Upload) Return 

func (_m AsyncClient_Upload) Return(putFuture catalog.UploadFuture, err error) *AsyncClient_Upload

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) Get 

func (_m *Client) Get(ctx context.Context, key catalog.Key) (catalog.Entry, error)

Get provides a mock function with given fields: ctx, key

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) OnGet 

func (_m *Client) OnGet(ctx context.Context, key catalog.Key) *Client_Get

func (*Client) OnGetMatch 

func (_m *Client) OnGetMatch(matchers ...interface{}) *Client_Get

func (*Client) OnGetOrExtendReservation 

func (_m *Client) OnGetOrExtendReservation(ctx context.Context, key catalog.Key, ownerID string, heartbeatInterval time.Duration) *Client_GetOrExtendReservation

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 (_m *Client) OnReleaseReservation(ctx context.Context, key catalog.Key, ownerID string) *Client_ReleaseReservation

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 

func (_m *Client) ReleaseReservation(ctx context.Context, key catalog.Key, ownerID string) error

ReleaseReservation provides a mock function with given fields: ctx, key, ownerID

func (*Client) Update 

func (_m *Client) Update(ctx context.Context, key catalog.Key, reader io.OutputReader, metadata catalog.Metadata) (catalog.Status, error)

Update provides a mock function with given fields: ctx, key, reader, metadata

type Client_Get 

type Client_Get struct {
	*mock.Call
}

func (Client_Get) Return 

func (_m Client_Get) Return(_a0 catalog.Entry, _a1 error) *Client_Get

type Client_GetOrExtendReservation 

type Client_GetOrExtendReservation struct {
	*mock.Call
}

func (Client_GetOrExtendReservation) Return 

func (_m Client_GetOrExtendReservation) Return(_a0 *datacatalog.Reservation, _a1 error) *Client_GetOrExtendReservation

type Client_Put 

type Client_Put struct {
	*mock.Call
}

func (Client_Put) Return 

func (_m Client_Put) Return(_a0 catalog.Status, _a1 error) *Client_Put

type Client_ReleaseReservation 

type Client_ReleaseReservation struct {
	*mock.Call
}

func (Client_ReleaseReservation) Return 

func (_m Client_ReleaseReservation) Return(_a0 error) *Client_ReleaseReservation

type Client_Update 

type Client_Update struct {
	*mock.Call
}

func (Client_Update) Return 

func (_m Client_Update) Return(_a0 catalog.Status, _a1 error) *Client_Update

type DownloadFuture 

type DownloadFuture struct {
	mock.Mock
}

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 

type DownloadFuture_GetResponse struct {
	*mock.Call
}

func (DownloadFuture_GetResponse) Return 

func (_m DownloadFuture_GetResponse) Return(_a0 catalog.DownloadResponse, _a1 error) *DownloadFuture_GetResponse

type DownloadFuture_GetResponseError 

type DownloadFuture_GetResponseError struct {
	*mock.Call
}

func (DownloadFuture_GetResponseError) Return 

func (_m DownloadFuture_GetResponseError) Return(_a0 error) *DownloadFuture_GetResponseError

type DownloadFuture_GetResponseStatus 

type DownloadFuture_GetResponseStatus struct {
	*mock.Call
}

func (DownloadFuture_GetResponseStatus) Return 

func (_m DownloadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *DownloadFuture_GetResponseStatus

type DownloadResponse 

type DownloadResponse struct {
	mock.Mock
}

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 

type DownloadResponse_GetCachedCount struct {
	*mock.Call
}

func (DownloadResponse_GetCachedCount) Return 

func (_m DownloadResponse_GetCachedCount) Return(_a0 int) *DownloadResponse_GetCachedCount

type DownloadResponse_GetCachedResults 

type DownloadResponse_GetCachedResults struct {
	*mock.Call
}

func (DownloadResponse_GetCachedResults) Return 

func (_m DownloadResponse_GetCachedResults) Return(_a0 *bitarray.BitSet) *DownloadResponse_GetCachedResults

type DownloadResponse_GetResultsSize 

type DownloadResponse_GetResultsSize struct {
	*mock.Call
}

func (DownloadResponse_GetResultsSize) Return 

func (_m DownloadResponse_GetResultsSize) Return(_a0 int) *DownloadResponse_GetResultsSize

type Future 

type Future struct {
	mock.Mock
}

Future is an autogenerated mock type for the Future type

func (*Future) GetResponseError 

func (_m *Future) GetResponseError() error

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 

type Future_GetResponseError struct {
	*mock.Call
}

func (Future_GetResponseError) Return 

func (_m Future_GetResponseError) Return(_a0 error) *Future_GetResponseError

type Future_GetResponseStatus 

type Future_GetResponseStatus struct {
	*mock.Call
}

func (Future_GetResponseStatus) Return 

func (_m Future_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *Future_GetResponseStatus

type UploadFuture 

type UploadFuture struct {
	mock.Mock
}

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 

type UploadFuture_GetResponseError struct {
	*mock.Call
}

func (UploadFuture_GetResponseError) Return 

func (_m UploadFuture_GetResponseError) Return(_a0 error) *UploadFuture_GetResponseError

type UploadFuture_GetResponseStatus 

type UploadFuture_GetResponseStatus struct {
	*mock.Call
}

func (UploadFuture_GetResponseStatus) Return 

func (_m UploadFuture_GetResponseStatus) Return(_a0 catalog.ResponseStatus) *UploadFuture_GetResponseStatus

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.