temporal

type Channel[T any] struct {
	// contains filtered or unexported fields
}

type Config struct {
	Host      string `env:"TEMPORAL_HOST, default=localhost:7233"`
	Namespace string `env:"TEMPORAL_NAMESPACE"`
	ApiKey    string `env:"TEMPORAL_API_KEY"`
}

type Future[T any] struct {
	Future workflow.Future
}

type RegisterOption func() interface{}

type Registerer interface {
	Register(worker.Registry)
}

type Schedule interface {
	Schedule(queue string) client.ScheduleOptions
}

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

type SchedulerParams struct {
	fx.In

	Logger    *slog.Logger
	Temporal  client.Client
	Schedules []Schedule `group:"temporal.schedules"`
}

type Settable[T any] struct {
	Settable workflow.Settable
}

type Starter interface {
	ExecuteWorkflow(
		ctx context.Context,
		options client.StartWorkflowOptions,
		workflow interface{},
		args ...interface{},
	) (client.WorkflowRun, error)

	SignalWithStartWorkflow(
		ctx context.Context,
		workflowID string,
		signalName string,
		signalArg interface{},
		options client.StartWorkflowOptions,
		workflow interface{},
		workflowArgs ...interface{},
	) (client.WorkflowRun, error)

	SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error
}

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

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

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

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

type WorkersParams struct {
	fx.In

	Runner      *infraCli.Runner
	Temporal    client.Client
	Registerers []Registerer `group:"temporal.registerers"`
}