mock_metastore

package
v0.0.0-...-34e0b2d Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockStreamingCoordCataLog 

type MockStreamingCoordCataLog struct {
	mock.Mock
}

MockStreamingCoordCataLog is an autogenerated mock type for the StreamingCoordCataLog type

func NewMockStreamingCoordCataLog 

func NewMockStreamingCoordCataLog(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockStreamingCoordCataLog

NewMockStreamingCoordCataLog creates a new instance of MockStreamingCoordCataLog. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockStreamingCoordCataLog) EXPECT 

func (_m *MockStreamingCoordCataLog) EXPECT() *MockStreamingCoordCataLog_Expecter

func (*MockStreamingCoordCataLog) ListPChannel 

func (_m *MockStreamingCoordCataLog) ListPChannel(ctx context.Context) ([]*streamingpb.PChannelMeta, error)

ListPChannel provides a mock function with given fields: ctx

func (*MockStreamingCoordCataLog) SavePChannels 

func (_m *MockStreamingCoordCataLog) SavePChannels(ctx context.Context, info []*streamingpb.PChannelMeta) error

SavePChannels provides a mock function with given fields: ctx, info

type MockStreamingCoordCataLog_Expecter 

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

func (*MockStreamingCoordCataLog_Expecter) ListPChannel 

func (_e *MockStreamingCoordCataLog_Expecter) ListPChannel(ctx interface{}) *MockStreamingCoordCataLog_ListPChannel_Call

ListPChannel is a helper method to define mock.On call

  • ctx context.Context

func (*MockStreamingCoordCataLog_Expecter) SavePChannels 

func (_e *MockStreamingCoordCataLog_Expecter) SavePChannels(ctx interface{}, info interface{}) *MockStreamingCoordCataLog_SavePChannels_Call

SavePChannels is a helper method to define mock.On call

  • ctx context.Context
  • info []*streamingpb.PChannelMeta

type MockStreamingCoordCataLog_ListPChannel_Call 

type MockStreamingCoordCataLog_ListPChannel_Call struct {
	*mock.Call
}

MockStreamingCoordCataLog_ListPChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPChannel'

func (*MockStreamingCoordCataLog_ListPChannel_Call) Return 

func (_c *MockStreamingCoordCataLog_ListPChannel_Call) Return(_a0 []*streamingpb.PChannelMeta, _a1 error) *MockStreamingCoordCataLog_ListPChannel_Call

func (*MockStreamingCoordCataLog_ListPChannel_Call) Run 

func (_c *MockStreamingCoordCataLog_ListPChannel_Call) Run(run func(ctx context.Context)) *MockStreamingCoordCataLog_ListPChannel_Call

func (*MockStreamingCoordCataLog_ListPChannel_Call) RunAndReturn 

func (_c *MockStreamingCoordCataLog_ListPChannel_Call) RunAndReturn(run func(context.Context) ([]*streamingpb.PChannelMeta, error)) *MockStreamingCoordCataLog_ListPChannel_Call

type MockStreamingCoordCataLog_SavePChannels_Call 

type MockStreamingCoordCataLog_SavePChannels_Call struct {
	*mock.Call
}

MockStreamingCoordCataLog_SavePChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SavePChannels'

func (*MockStreamingCoordCataLog_SavePChannels_Call) Return 

func (_c *MockStreamingCoordCataLog_SavePChannels_Call) Return(_a0 error) *MockStreamingCoordCataLog_SavePChannels_Call

func (*MockStreamingCoordCataLog_SavePChannels_Call) Run 

func (_c *MockStreamingCoordCataLog_SavePChannels_Call) Run(run func(ctx context.Context, info []*streamingpb.PChannelMeta)) *MockStreamingCoordCataLog_SavePChannels_Call

func (*MockStreamingCoordCataLog_SavePChannels_Call) RunAndReturn 

func (_c *MockStreamingCoordCataLog_SavePChannels_Call) RunAndReturn(run func(context.Context, []*streamingpb.PChannelMeta) error) *MockStreamingCoordCataLog_SavePChannels_Call

type MockStreamingNodeCataLog 

type MockStreamingNodeCataLog struct {
	mock.Mock
}

MockStreamingNodeCataLog is an autogenerated mock type for the StreamingNodeCataLog type

func NewMockStreamingNodeCataLog 

func NewMockStreamingNodeCataLog(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockStreamingNodeCataLog

NewMockStreamingNodeCataLog creates a new instance of MockStreamingNodeCataLog. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockStreamingNodeCataLog) EXPECT 

func (_m *MockStreamingNodeCataLog) EXPECT() *MockStreamingNodeCataLog_Expecter

func (*MockStreamingNodeCataLog) ListSegmentAssignment 

func (_m *MockStreamingNodeCataLog) ListSegmentAssignment(ctx context.Context, pChannelName string) ([]*streamingpb.SegmentAssignmentMeta, error)

ListSegmentAssignment provides a mock function with given fields: ctx, pChannelName

func (*MockStreamingNodeCataLog) SaveSegmentAssignments 

func (_m *MockStreamingNodeCataLog) SaveSegmentAssignments(ctx context.Context, pChannelName string, infos []*streamingpb.SegmentAssignmentMeta) error

SaveSegmentAssignments provides a mock function with given fields: ctx, pChannelName, infos

type MockStreamingNodeCataLog_Expecter 

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

func (*MockStreamingNodeCataLog_Expecter) ListSegmentAssignment 

func (_e *MockStreamingNodeCataLog_Expecter) ListSegmentAssignment(ctx interface{}, pChannelName interface{}) *MockStreamingNodeCataLog_ListSegmentAssignment_Call

ListSegmentAssignment is a helper method to define mock.On call

  • ctx context.Context
  • pChannelName string

func (*MockStreamingNodeCataLog_Expecter) SaveSegmentAssignments 

func (_e *MockStreamingNodeCataLog_Expecter) SaveSegmentAssignments(ctx interface{}, pChannelName interface{}, infos interface{}) *MockStreamingNodeCataLog_SaveSegmentAssignments_Call

SaveSegmentAssignments is a helper method to define mock.On call

  • ctx context.Context
  • pChannelName string
  • infos []*streamingpb.SegmentAssignmentMeta

type MockStreamingNodeCataLog_ListSegmentAssignment_Call 

type MockStreamingNodeCataLog_ListSegmentAssignment_Call struct {
	*mock.Call
}

MockStreamingNodeCataLog_ListSegmentAssignment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSegmentAssignment'

func (*MockStreamingNodeCataLog_ListSegmentAssignment_Call) Return 

func (_c *MockStreamingNodeCataLog_ListSegmentAssignment_Call) Return(_a0 []*streamingpb.SegmentAssignmentMeta, _a1 error) *MockStreamingNodeCataLog_ListSegmentAssignment_Call

func (*MockStreamingNodeCataLog_ListSegmentAssignment_Call) Run 

func (_c *MockStreamingNodeCataLog_ListSegmentAssignment_Call) Run(run func(ctx context.Context, pChannelName string)) *MockStreamingNodeCataLog_ListSegmentAssignment_Call

func (*MockStreamingNodeCataLog_ListSegmentAssignment_Call) RunAndReturn 

func (_c *MockStreamingNodeCataLog_ListSegmentAssignment_Call) RunAndReturn(run func(context.Context, string) ([]*streamingpb.SegmentAssignmentMeta, error)) *MockStreamingNodeCataLog_ListSegmentAssignment_Call

type MockStreamingNodeCataLog_SaveSegmentAssignments_Call 

type MockStreamingNodeCataLog_SaveSegmentAssignments_Call struct {
	*mock.Call
}

MockStreamingNodeCataLog_SaveSegmentAssignments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveSegmentAssignments'

func (*MockStreamingNodeCataLog_SaveSegmentAssignments_Call) Return 

func (_c *MockStreamingNodeCataLog_SaveSegmentAssignments_Call) Return(_a0 error) *MockStreamingNodeCataLog_SaveSegmentAssignments_Call

func (*MockStreamingNodeCataLog_SaveSegmentAssignments_Call) Run 

func (_c *MockStreamingNodeCataLog_SaveSegmentAssignments_Call) Run(run func(ctx context.Context, pChannelName string, infos []*streamingpb.SegmentAssignmentMeta)) *MockStreamingNodeCataLog_SaveSegmentAssignments_Call

func (*MockStreamingNodeCataLog_SaveSegmentAssignments_Call) RunAndReturn 

func (_c *MockStreamingNodeCataLog_SaveSegmentAssignments_Call) RunAndReturn(run func(context.Context, string, []*streamingpb.SegmentAssignmentMeta) error) *MockStreamingNodeCataLog_SaveSegmentAssignments_Call

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.