nats

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

type AggCpStoreConfig struct {
	Connect   Connector
	Bucket    string
	KeyPrefix string
	Timeout   time.Duration // Timeout for checkpoint operations (default: 10s)
}

type Connector func() (nc *natsgo.Conn, err error)

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

type CpStoreConfig struct {
	Connect Connector
	Bucket  string
	Key     string
	Timeout time.Duration // Timeout for checkpoint operations (default: 10s)
}

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

type EventStoreConfig struct {
	Connect        Connector    // Connect is used to create the underlying NATS connection. If nil, ConnectDefault() is used.
	Log            *slog.Logger // Log for diagnostics (optional)
	SubjectPrefix  string       // SubjectPrefix is the prefix used to store events
	StreamSubjects []string     // StreamSubjects is the list of subjects the stream is fed with
	StreamName     string
	RenameType     func(string) string

	// Retention defines the retention policy for the stream (default: RetentionLimits).
	Retention RetentionPolicy

	// MaxAge is the maximum age of messages in the stream.
	MaxAge time.Duration

	// MaxBytes is the maximum total size of messages in the stream.
	MaxBytes int64

	// MaxMsgs is the maximum number of messages in the stream.
	MaxMsgs int64
}

type KvConfig struct {
	Connect      Connector
	Bucket       string
	TTL          time.Duration
	MaxBytes     int
	MaxValueSize int
	KeyPrefix    string
}

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

type RetentionPolicy int

type Testing interface {
	require.TestingT
	Context() context.Context
	Logf(format string, args ...any)
	Cleanup(func())
}

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

type TransportConfig struct {
	Connect       Connector    // Connect is used to create the underlying NATS connection. If nil, ConnectDefault() is used.
	Log           *slog.Logger // Log for diagnostics (optional)
	SubjectPrefix string       // SubjectPrefix for shard subjects, e.g. "clstr" -> clstr.shard.<id>
}