client

Documentation

Overview

Package client is a generated GoMock package.

Index

• Constants
• type MockPieceStoreAPI
  • func NewMockPieceStoreAPI(ctrl *gomock.Controller) *MockPieceStoreAPI
  • func (m *MockPieceStoreAPI) DeletePiece(ctx context.Context, key string) error
  • func (m *MockPieceStoreAPI) EXPECT() *MockPieceStoreAPIMockRecorder
  • func (m *MockPieceStoreAPI) GetPiece(ctx context.Context, key string, offset, limit int64) ([]byte, error)
  • func (m *MockPieceStoreAPI) PutPiece(key string, value []byte) error
• type MockPieceStoreAPIMockRecorder
  • func (mr *MockPieceStoreAPIMockRecorder) DeletePiece(ctx, key any) *gomock.Call
  • func (mr *MockPieceStoreAPIMockRecorder) GetPiece(ctx, key, offset, limit any) *gomock.Call
  • func (mr *MockPieceStoreAPIMockRecorder) PutPiece(key, value any) *gomock.Call
• type PieceStoreAPI
• type StoreClient
  • func NewStoreClient(pieceConfig *storage.PieceStoreConfig) (*StoreClient, error)
  • func (client *StoreClient) DeletePiece(ctx context.Context, key string) error
  • func (client *StoreClient) GetPiece(ctx context.Context, key string, offset, limit int64) (data []byte, err error)
  • func (client *StoreClient) PutPiece(ctx context.Context, key string, value []byte) error

Constants

const (
	// PieceStoreSuccessPut defines the metrics label of successfully put piece data
	PieceStoreSuccessPut = "put_piece_store_success"
	// PieceStoreFailurePut defines the metrics label of unsuccessfully put piece data
	PieceStoreFailurePut = "put_piece_store_failure"
	// PieceStoreSuccessGet defines the metrics label of successfully get piece data
	PieceStoreSuccessGet = "get_piece_store_success"
	// PieceStoreFailureGet defines the metrics label of unsuccessfully get piece data
	PieceStoreFailureGet = "get_piece_store_failure"
	// PieceStoreSuccessDel defines the metrics label of successfully delete piece data
	PieceStoreSuccessDel = "del_piece_store_success"
	// PieceStoreFailureDel defines the metrics label of unsuccessfully delete piece data
	PieceStoreFailureDel = "del_piece_store_failure"
)

Types

type MockPieceStoreAPI

type MockPieceStoreAPI struct {
	// contains filtered or unexported fields
}

MockPieceStoreAPI is a mock of PieceStoreAPI interface.

func NewMockPieceStoreAPI

func NewMockPieceStoreAPI(ctrl *gomock.Controller) *MockPieceStoreAPI

NewMockPieceStoreAPI creates a new mock instance.

func (*MockPieceStoreAPI) DeletePiece

func (m *MockPieceStoreAPI) DeletePiece(ctx context.Context, key string) error

DeletePiece mocks base method.

func (*MockPieceStoreAPI) EXPECT

func (m *MockPieceStoreAPI) EXPECT() *MockPieceStoreAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPieceStoreAPI) GetPiece

func (m *MockPieceStoreAPI) GetPiece(ctx context.Context, key string, offset, limit int64) ([]byte, error)

GetPiece mocks base method.

func (*MockPieceStoreAPI) PutPiece

func (m *MockPieceStoreAPI) PutPiece(key string, value []byte) error

PutPiece mocks base method.

type MockPieceStoreAPIMockRecorder

type MockPieceStoreAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockPieceStoreAPIMockRecorder is the mock recorder for MockPieceStoreAPI.

func (*MockPieceStoreAPIMockRecorder) DeletePiece

func (mr *MockPieceStoreAPIMockRecorder) DeletePiece(ctx, key any) *gomock.Call

DeletePiece indicates an expected call of DeletePiece.

func (*MockPieceStoreAPIMockRecorder) GetPiece

func (mr *MockPieceStoreAPIMockRecorder) GetPiece(ctx, key, offset, limit any) *gomock.Call

GetPiece indicates an expected call of GetPiece.

func (*MockPieceStoreAPIMockRecorder) PutPiece

func (mr *MockPieceStoreAPIMockRecorder) PutPiece(key, value any) *gomock.Call

PutPiece indicates an expected call of PutPiece.

type PieceStoreAPI

type PieceStoreAPI interface {
	GetPiece(ctx context.Context, key string, offset, limit int64) ([]byte, error)
	PutPiece(key string, value []byte) error
	DeletePiece(ctx context.Context, key string) error
}

PieceStoreAPI provides an interface to enable mocking the StoreClient's API operation. This makes unit test to test your code easier.

type StoreClient

type StoreClient struct {
	// contains filtered or unexported fields
}

func NewStoreClient

func NewStoreClient(pieceConfig *storage.PieceStoreConfig) (*StoreClient, error)

func (*StoreClient) DeletePiece

func (client *StoreClient) DeletePiece(ctx context.Context, key string) error

DeletePiece deletes piece from piece store.

func (*StoreClient) GetPiece

func (client *StoreClient) GetPiece(ctx context.Context, key string, offset, limit int64) (data []byte, err error)

GetPiece gets piece data from piece store.

func (*StoreClient) PutPiece

func (client *StoreClient) PutPiece(ctx context.Context, key string, value []byte) error

PutPiece puts piece to piece store.