Versions in this module Expand all Collapse all v1 v1.10.0 Nov 9, 2024 Changes in this version + type MockIngesterClient struct + func NewMockIngesterClient(t interface{ ... }) *MockIngesterClient + func (_m *MockIngesterClient) EXPECT() *MockIngesterClient_Expecter + func (_m *MockIngesterClient) Push(_a0 context.Context, _a1 *model.PushRequest) (*connect.Response[pushv1.PushResponse], error) + type MockIngesterClient_Expecter struct + func (_e *MockIngesterClient_Expecter) Push(_a0 interface{}, _a1 interface{}) *MockIngesterClient_Push_Call + type MockIngesterClient_Push_Call struct + func (_c *MockIngesterClient_Push_Call) Return(_a0 *connect.Response[pushv1.PushResponse], _a1 error) *MockIngesterClient_Push_Call + func (_c *MockIngesterClient_Push_Call) Run(run func(_a0 context.Context, _a1 *model.PushRequest)) *MockIngesterClient_Push_Call + func (_c *MockIngesterClient_Push_Call) RunAndReturn(...) *MockIngesterClient_Push_Call + type MockSegmentWriterClient struct + func NewMockSegmentWriterClient(t interface{ ... }) *MockSegmentWriterClient + func (_m *MockSegmentWriterClient) EXPECT() *MockSegmentWriterClient_Expecter + func (_m *MockSegmentWriterClient) Push(_a0 context.Context, _a1 *segmentwriterv1.PushRequest) (*segmentwriterv1.PushResponse, error) + type MockSegmentWriterClient_Expecter struct + func (_e *MockSegmentWriterClient_Expecter) Push(_a0 interface{}, _a1 interface{}) *MockSegmentWriterClient_Push_Call + type MockSegmentWriterClient_Push_Call struct + func (_c *MockSegmentWriterClient_Push_Call) Return(_a0 *segmentwriterv1.PushResponse, _a1 error) *MockSegmentWriterClient_Push_Call + func (_c *MockSegmentWriterClient_Push_Call) Run(run func(_a0 context.Context, _a1 *segmentwriterv1.PushRequest)) *MockSegmentWriterClient_Push_Call + func (_c *MockSegmentWriterClient_Push_Call) RunAndReturn(...) *MockSegmentWriterClient_Push_Call
Go to main page