cloudevent

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

type Config struct {
	// Streams: nats stream config
	Streams map[string]*StreamConfig `yaml:"streams"`

	// Consumers: nats consumer config
	Consumers map[string]typex.YamlListType[*ConsumerConfig] `yaml:"consumers"`
}

type Consumer struct {
	jetstream.Consumer
	Config *ConsumerConfig
}

type ConsumerConfig struct {
	// Consumer name without prefix
	Consumer *string `yaml:"consumer"`

	// Concurrent default: 100
	Concurrent *int `yaml:"concurrent"`

	// Stream name without prefix
	Stream string `yaml:"stream"`

	// Subjects config
	Subjects typex.YamlListType[*strOrJobConfig] `yaml:"subjects"`

	// Job event config
	Job *JobEventConfig `yaml:"job"`
}

type Context struct {
	// Header jetstream.Headers().
	Header http.Header

	// NumDelivered jetstream.MsgMetadata{}.NumDelivered
	NumDelivered uint64

	// NumPending jetstream.MsgMetadata{}.NumPending
	NumPending uint64

	// Timestamp jetstream.MsgMetadata{}.Timestamp
	Timestamp time.Time

	// Stream jetstream.MsgMetadata{}.Stream
	Stream string

	// Consumer jetstream.MsgMetadata{}.Consumer
	Consumer string

	// Subject|Topic name jetstream.Msg().Subject()
	Subject string

	// Config job config from config file or default
	Config *JobEventConfig
}

type EventHandler[T proto.Message] func(ctx context.Context, args T) error

type EventRegister interface {
	RegisterCloudEvent(jobCli *Client)
}

type JobEventConfig struct {
	// Name subject name
	Name *string `yaml:"name"`

	// Timeout job executor timeout, default: DefaultTimeout
	Timeout *time.Duration `yaml:"timeout"`

	// MaxRetry max retries, default: DefaultMaxRetry
	MaxRetry *int `yaml:"max_retries"`

	// RetryBackoff retry backoff, default: DefaultRetryBackoff
	RetryBackoff *time.Duration `yaml:"retry_backoff"`
}

type Options = cloudeventpb.PushEventOptions

type Params struct {
	Nc  *natsclient.Client
	Cfg *Config
	Lc  lifecycle.Lifecycle
}

type PubAckInfo struct {
	AckInfo *jetstream.PubAck
	Header  nats.Header
	MsgId   string
}

type PushEventOpt func(opts *Options)

type RpcEventHandler[T proto.Message] func(ctx context.Context, args T) (*emptypb.Empty, error)

type StreamConfig struct {
	// Storage jetstream.StorageType
	Storage string `yaml:"storage"`

	// Subjects stream subscribe subject, e.g. nvr.speaker.* without prefix
	Subjects typex.YamlListType[string] `yaml:"subjects"`
}