worker

type Config struct {
	// builtin configuration
	Env         config.Env `config:"env" validate:"required"`
	ServiceName string     `config:"service_name" validate:"required"`

	GitRef  string `config:"git_ref" validate:"required"`
	Version string `config:"version" validate:"required"`

	// temporal configuration
	TemporalHost                    string `config:"temporal_host" validate:"required"`
	TemporalNamespace               string `config:"temporal_namespace"`
	TemporalTaskQueue               string `config:"temporal_task_queue" validate:"required"`
	TemporalMaxConcurrentActivities int    `config:"temporal_max_concurrent_activities" validate:"required" faker:"oneof: 10,20"`

	// observability configuration
	HostIP               string `config:"host_ip" validate:"required"`
	LogLevel             string `config:"log_level"`
	SlowQueryThresholdMS int    `config:"slow_query_threshold_ms"`
}

type Worker interface {
	Run(<-chan interface{}) error
}