agent

type BackoffOptions struct {
	// MaxInterval is the maximum interval between retries.
	MaxInterval time.Duration
}

type Config struct {
	TransportReader TransportReader
	RuntimeExecutor RuntimeExecutor
	TransportWriter TransportWriter
	Backoff         *backoff.ExponentialBackOff
}

type ContainerdRuntime struct {
	Namespace  string
	SocketPath string
}

type DockerRuntime struct {
	SocketPath string
}

type FileTransport struct {
	WorkflowPath string
}

type GRPCTransport struct {
	ServerAddrPort string
	TLSEnabled     bool
	TLSInsecure    bool
	RetryInterval  time.Duration
}

type NATSTransport struct {
	ServerAddrPort netip.AddrPort
	StreamName     string
	EventsSubject  string
	ActionsSubject string
}

type Options struct {
	Transport                 Transport
	Runtime                   Runtime
	Registry                  Registry
	Proxy                     Proxy
	TransportSelected         TransportType
	RuntimeSelected           RuntimeType
	AttributeDetectionEnabled bool
	BackoffOptions            BackoffOptions
}

type Proxy struct {
	HTTPProxy  []string
	HTTPSProxy []string
	NoProxy    []string
}

type Registry struct {
	Name string
	User string
	Pass string
}

type Runtime struct {
	Docker     DockerRuntime
	Containerd ContainerdRuntime
}

type RuntimeExecutor interface {
	// Execute blocks until the action is completed or an error occurs
	Execute(ctx context.Context, action spec.Action) error
}

type RuntimeType string

type Transport struct {
	GRPC GRPCTransport
	File FileTransport
	NATS NATSTransport
}

type TransportReader interface {
	// Read blocks until an action is available or an error occurs
	Read(ctx context.Context) (spec.Action, error)
}

type TransportType string

type TransportWriter interface {
	// Write blocks until the event is written or an error occurs
	Write(ctx context.Context, event spec.Event) error
}