Documentation
¶
Index ¶
- type Client
- func (_m *Client) Close()
- func (_m *Client) CommitGeneration(gen1 *types.Generation, gen2 *types.Generation) error
- func (_m *Client) DbWasNewlyCreated() bool
- func (_m *Client) GenerationInfo(token types.Token, version types.GenVersion) (*types.Generation, error)
- func (_m *Client) GenerationsByParent(gen *types.Generation) ([]types.Generation, error)
- func (_m *Client) GetGenerationsByToken(token types.Token, clusterSize int) ([]types.Generation, error)
- func (_m *Client) Init() error
- func (_m *Client) IsShuttingDown() bool
- func (_m *Client) LatestGenerations() ([]types.Generation, error)
- func (_m *Client) MarkAsShuttingDown()
- func (_m *Client) Offsets() ([]types.OffsetStoreKeyValue, error)
- func (_m *Client) SaveOffset(offsetKv *types.OffsetStoreKeyValue) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
func NewClient(t mockConstructorTestingTNewClient) *Client
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) CommitGeneration ¶
func (_m *Client) CommitGeneration(gen1 *types.Generation, gen2 *types.Generation) error
CommitGeneration provides a mock function with given fields: gen1, gen2
func (*Client) DbWasNewlyCreated ¶
DbWasNewlyCreated provides a mock function with given fields:
func (*Client) GenerationInfo ¶
func (_m *Client) GenerationInfo(token types.Token, version types.GenVersion) (*types.Generation, error)
GenerationInfo provides a mock function with given fields: token, version
func (*Client) GenerationsByParent ¶
func (_m *Client) GenerationsByParent(gen *types.Generation) ([]types.Generation, error)
GenerationsByParent provides a mock function with given fields: gen
func (*Client) GetGenerationsByToken ¶
func (_m *Client) GetGenerationsByToken(token types.Token, clusterSize int) ([]types.Generation, error)
GetGenerationsByToken provides a mock function with given fields: token, clusterSize
func (*Client) IsShuttingDown ¶
IsShuttingDown provides a mock function with given fields:
func (*Client) LatestGenerations ¶
func (_m *Client) LatestGenerations() ([]types.Generation, error)
LatestGenerations provides a mock function with given fields:
func (*Client) MarkAsShuttingDown ¶
func (_m *Client) MarkAsShuttingDown()
MarkAsShuttingDown provides a mock function with given fields:
func (*Client) Offsets ¶
func (_m *Client) Offsets() ([]types.OffsetStoreKeyValue, error)
Offsets provides a mock function with given fields:
func (*Client) SaveOffset ¶
func (_m *Client) SaveOffset(offsetKv *types.OffsetStoreKeyValue) error
SaveOffset provides a mock function with given fields: offsetKv
Source Files