executorclient

type Config struct {
	Namespace         string        `yaml:"namespace"`
	HeartBeatInterval time.Duration `yaml:"heartbeat_interval"`
}

type Executor[SP ShardProcessor] interface {
	Start(ctx context.Context)
	Stop()

	GetShardProcess(shardID string) (SP, error)
}

type MockExecutor[SP ShardProcessor] struct {
	// contains filtered or unexported fields
}

type MockExecutorMockRecorder[SP ShardProcessor] struct {
	// contains filtered or unexported fields
}

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

type MockShardProcessorFactory[SP ShardProcessor] struct {
	// contains filtered or unexported fields
}

type MockShardProcessorFactoryMockRecorder[SP ShardProcessor] struct {
	// contains filtered or unexported fields
}

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

type Params[SP ShardProcessor] struct {
	fx.In

	YarpcClient           sharddistributorv1.ShardDistributorExecutorAPIYARPCClient
	MetricsScope          tally.Scope
	Logger                log.Logger
	ShardProcessorFactory ShardProcessorFactory[SP]
	Config                Config
	TimeSource            clock.TimeSource
}

type ShardProcessor interface {
	Start(ctx context.Context)
	Stop()
	GetShardLoad() float64
}

type ShardProcessorFactory[SP ShardProcessor] interface {
	NewShardProcessor(shardID string) (SP, error)
}