handler

type Executor ¶ added in v1.3.4

type Executor interface {
	Heartbeat(context.Context, *types.ExecutorHeartbeatRequest) (*types.ExecutorHeartbeatResponse, error)
}

func NewExecutorHandler(
	logger log.Logger,
	storage store.Store,
	timeSource clock.TimeSource,
	shardDistributionCfg config.ShardDistribution,
	cfg *config.Config,
	metricsClient metrics.Client,
) Executor

type Handler ¶

type Handler interface {
	common.Daemon

	Health(context.Context) (*types.HealthStatus, error)

	GetShardOwner(context.Context, *types.GetShardOwnerRequest) (*types.GetShardOwnerResponse, error)

	WatchNamespaceState(*types.WatchNamespaceStateRequest, WatchNamespaceStateServer) error
}

Handler is the interface for shard distributor handler

func NewHandler(
	logger log.Logger,
	shardDistributionCfg config.ShardDistribution,
	storage store.Store,
) Handler

type MockExecutor ¶ added in v1.3.4

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

MockExecutor is a mock of Executor interface.

func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor

func (m *MockExecutor) EXPECT() *MockExecutorMockRecorder

func (m *MockExecutor) Heartbeat(arg0 context.Context, arg1 *types.ExecutorHeartbeatRequest) (*types.ExecutorHeartbeatResponse, error)

type MockExecutorMockRecorder ¶ added in v1.3.4

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

MockExecutorMockRecorder is the mock recorder for MockExecutor.

func (mr *MockExecutorMockRecorder) Heartbeat(arg0, arg1 any) *gomock.Call

type MockHandler ¶

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

MockHandler is a mock of Handler interface.

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

func (m *MockHandler) GetShardOwner(arg0 context.Context, arg1 *types.GetShardOwnerRequest) (*types.GetShardOwnerResponse, error)

func (m *MockHandler) Health(arg0 context.Context) (*types.HealthStatus, error)

func (m *MockHandler) Start()

func (m *MockHandler) Stop()

func (m *MockHandler) WatchNamespaceState(arg0 *types.WatchNamespaceStateRequest, arg1 WatchNamespaceStateServer) error

type MockHandlerMockRecorder ¶

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

MockHandlerMockRecorder is the mock recorder for MockHandler.

func (mr *MockHandlerMockRecorder) GetShardOwner(arg0, arg1 any) *gomock.Call

func (mr *MockHandlerMockRecorder) Health(arg0 any) *gomock.Call

func (mr *MockHandlerMockRecorder) Start() *gomock.Call

func (mr *MockHandlerMockRecorder) Stop() *gomock.Call

func (mr *MockHandlerMockRecorder) WatchNamespaceState(arg0, arg1 any) *gomock.Call

type MockWatchNamespaceStateServer ¶ added in v1.4.0

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

MockWatchNamespaceStateServer is a mock of WatchNamespaceStateServer interface.

func NewMockWatchNamespaceStateServer(ctrl *gomock.Controller) *MockWatchNamespaceStateServer

func (m *MockWatchNamespaceStateServer) Context() context.Context

func (m *MockWatchNamespaceStateServer) EXPECT() *MockWatchNamespaceStateServerMockRecorder

func (m *MockWatchNamespaceStateServer) Send(arg0 *types.WatchNamespaceStateResponse) error

type MockWatchNamespaceStateServerMockRecorder ¶ added in v1.4.0

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

MockWatchNamespaceStateServerMockRecorder is the mock recorder for MockWatchNamespaceStateServer.

func (mr *MockWatchNamespaceStateServerMockRecorder) Context() *gomock.Call

func (mr *MockWatchNamespaceStateServerMockRecorder) Send(arg0 any) *gomock.Call

type WatchNamespaceStateServer ¶ added in v1.4.0

type WatchNamespaceStateServer interface {
	Context() context.Context
	Send(*types.WatchNamespaceStateResponse) error
}