esdb

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

type AllPosition interface {
	// contains filtered or unexported methods
}

type Any struct{}

type AppendToStreamOptions struct {
	ExpectedRevision ExpectedRevision
	Authenticated    *Credentials
	Deadline         *time.Duration
}

type Client struct {
	Config *Configuration
	// contains filtered or unexported fields
}

type Configuration struct {
	// The URI of the EventStoreDB. Use this when connecting to a single node.
	// Example: localhost:2113
	Address string

	// An array of end points used to seed gossip.
	GossipSeeds []*EndPoint

	// Disable communicating over a secure channel.
	DisableTLS bool // Defaults to false.

	// The NodePreference to use when connecting.
	NodePreference NodePreference

	// The username to use for authenticating against the EventStoreDB instance.
	Username string

	// The password to use for authenticating against the EventStoreDB instance.
	Password string

	// RootCAs defines the set of root certificate authorities
	// that clients use when verifying server certificates.
	// If RootCAs is nil, TLS uses the host's root CA set.
	RootCAs *x509.CertPool // Defaults to nil.

	// Allows to skip certificate validation.
	SkipCertificateVerification bool // Defaults to false.

	// The maximum number of times to attempt end point discovery.
	MaxDiscoverAttempts int // Defaults to 10.

	// The polling interval (in milliseconds) used to discover the end point.
	DiscoveryInterval int // Defaults to 100 milliseconds.

	// The amount of time (in seconds) after which an attempt to discover gossip will fail.
	GossipTimeout int // Defaults to 5 seconds.

	// Specifies if DNS discovery should be used.
	DnsDiscover bool // Defaults to false.

	// The amount of time (in milliseconds) to wait after which a keepalive ping is sent on the transport.
	// If set below 10s, a minimum value of 10s will be used instead. Use -1 to disable. Use -1 to disable.
	KeepAliveInterval time.Duration // Defaults to 10 seconds.

	// The amount of time (in milliseconds) the sender of the keep alive ping waits for an acknowledgement.
	KeepAliveTimeout time.Duration // Defaults to 10 seconds.

	// The amount of time (in milliseconds) a non-streaming operation should take to complete before resulting in a
	// DeadlineExceeded. Defaults to 10 seconds.
	DefaultDeadline *time.Duration

	// Logging abstraction used by the client.
	Logger LoggingFunc
}

type ConsumerStrategy string

type ContentType int

type Credentials struct {
	Login    string
	Password string
}

type DeletePersistentSubscriptionOptions struct {
	Authenticated *Credentials
	Deadline      *time.Duration
}

type DeleteResult struct {
	Position Position
}

type DeleteStreamOptions struct {
	ExpectedRevision ExpectedRevision
	Authenticated    *Credentials
	Deadline         *time.Duration
}

type Direction int

type End struct {
}

type EndPoint struct {
	Host string
	Port uint16
}

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

type ErrorCode int

type EventAppeared struct {
	Event      *ResolvedEvent
	RetryCount int
}

type EventData struct {
	EventID     uuid.UUID
	EventType   string
	ContentType ContentType
	Data        []byte
	Metadata    []byte
}

type ExpectedRevision interface {
	// contains filtered or unexported methods
}

type FilterType int

type GetPersistentSubscriptionOptions struct {
	Authenticated *Credentials
	Deadline      *time.Duration
}

type ListPersistentSubscriptionsOptions struct {
	Authenticated *Credentials
	Deadline      *time.Duration
}

type LogLevel = string

type LoggingFunc = func(level LogLevel, format string, args ...interface{})

type Nack_Action int32

type NoStream struct{}

type NodePreference string

type PersistentAllSubscriptionOptions struct {
	Settings        *SubscriptionSettings
	StartFrom       AllPosition
	MaxSearchWindow int
	Filter          *SubscriptionFilter
	Authenticated   *Credentials
	Deadline        *time.Duration
}

type PersistentStreamSubscriptionOptions struct {
	Settings      *SubscriptionSettings
	StartFrom     StreamPosition
	Authenticated *Credentials
	Deadline      *time.Duration
}

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

type PersistentSubscriptionConfig struct {
	ResolveLinkTos       bool   `json:"resolveLinktos"`
	StartFrom            int64  `json:"startFrom"`
	StartPosition        string `json:"startPosition,omitempty"`
	MessageTimeout       int64  `json:"messageTimeoutMilliseconds"`
	ExtraStatistics      bool   `json:"extraStatistics"`
	MaxRetryCount        int64  `json:"maxRetryCount"`
	LiveBufferSize       int64  `json:"liveBufferSize"`
	BufferSize           int64  `json:"bufferSize"`
	ReadBatchSize        int64  `json:"readBatchSize"`
	PreferRoundRobin     bool   `json:"preferRoundRobin"`
	CheckpointAfter      int64  `json:"checkPointAfterMilliseconds"`
	CheckpointLowerBound int64  `json:"minCheckPointCount"`
	CheckpointUpperBound int64  `json:"maxCheckPointCount"`
	MaxSubscriberCount   int64  `json:"maxSubscriberCount"`
	ConsumerStrategyName string `json:"consumerStrategyName"`
}

type PersistentSubscriptionConnectionInfo struct {
	From                      string                              `json:"from"`
	Username                  string                              `json:"username"`
	AverageItemsPerSecond     float64                             `json:"averageItemsPerSecond"`
	TotalItemsProcessed       int64                               `json:"totalItemsProcessed"`
	CountSinceLastMeasurement int64                               `json:"countSinceLastMeasurement"`
	AvailableSlots            int64                               `json:"availableSlots"`
	InFlightMessages          int64                               `json:"inFlightMessages"`
	ConnectionName            string                              `json:"connectionName"`
	ExtraStatistics           []PersistentSubscriptionMeasurement `json:"extraStatistics"`
}

type PersistentSubscriptionEvent struct {
	EventAppeared       *EventAppeared
	SubscriptionDropped *SubscriptionDropped
	CheckPointReached   *Position
}

type PersistentSubscriptionInfo struct {
	EventSource string
	GroupName   string
	Status      string
	Connections []PersistentSubscriptionConnectionInfo
	Settings    *SubscriptionSettings
	Stats       *PersistentSubscriptionStats
}

type PersistentSubscriptionInfoHttpJson struct {
	EventStreamId                 string                                 `json:"eventStreamId"`
	GroupName                     string                                 `json:"groupName"`
	Status                        string                                 `json:"status"`
	AverageItemsPerSecond         float64                                `json:"averageItemsPerSecond"`
	TotalItemsProcessed           int64                                  `json:"totalItemsProcessed"`
	LastProcessedEventNumber      int64                                  `json:"lastProcessedEventNumber"`
	LastKnownEventNumber          int64                                  `json:"lastKnownEventNumber"`
	LastCheckpointedEventPosition string                                 `json:"lastCheckpointedEventPosition,omitempty"`
	LastKnownEventPosition        string                                 `json:"lastKnownEventPosition,omitempty"`
	ConnectionCount               int64                                  `json:"connectionCount,omitempty"`
	TotalInFlightMessages         int64                                  `json:"totalInFlightMessages"`
	Config                        *PersistentSubscriptionConfig          `json:"config,omitempty"`
	Connections                   []PersistentSubscriptionConnectionInfo `json:"connections,omitempty"`
	ReadBufferCount               int64                                  `json:"readBufferCount"`
	RetryBufferCount              int64                                  `json:"retryBufferCount"`
	LiveBufferCount               int64                                  `json:"liveBufferCount"`
	OutstandingMessagesCount      int64                                  `json:"OutstandingMessagesCount"`
	ParkedMessageCount            int64                                  `json:"parkedMessageCount"`
	CountSinceLastMeasurement     int64                                  `json:"countSinceLastMeasurement"`
}

type PersistentSubscriptionMeasurement struct {
	Key   string `json:"key"`
	Value int64  `json:"value"`
}

type PersistentSubscriptionStats struct {
	AveragePerSecond              int64
	TotalItems                    int64
	CountSinceLastMeasurement     int64
	LastCheckpointedEventRevision *uint64
	LastKnownEventRevision        *uint64
	LastCheckpointedPosition      *Position
	LastKnownPosition             *Position
	ReadBufferCount               int64
	LiveBufferCount               int64
	RetryBufferCount              int64
	TotalInFlightMessages         int64
	OutstandingMessagesCount      int64
	ParkedMessagesCount           int64
}

type PersistentSubscriptionStatus string

type Position struct {
	Commit  uint64
	Prepare uint64
}

type ReadAllOptions struct {
	Direction      Direction
	From           AllPosition
	ResolveLinkTos bool
	Authenticated  *Credentials
	Deadline       *time.Duration
}

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

type ReadStreamOptions struct {
	Direction      Direction
	From           StreamPosition
	ResolveLinkTos bool
	Authenticated  *Credentials
	Deadline       *time.Duration
}

type RecordedEvent struct {
	EventID        uuid.UUID
	EventType      string
	ContentType    string
	StreamID       string
	EventNumber    uint64
	Position       Position
	CreatedDate    time.Time
	Data           []byte
	SystemMetadata map[string]string
	UserMetadata   []byte
}

type ReplayParkedMessagesOptions struct {
	Authenticated *Credentials
	StopAt        int
	Deadline      *time.Duration
}

type ResolvedEvent struct {
	Link   *RecordedEvent
	Event  *RecordedEvent
	Commit *uint64
}

type RestartPersistentSubscriptionSubsystemOptions struct {
	Authenticated *Credentials
	Deadline      *time.Duration
}

type ServerInfo struct {
	Version      ServerVersion
	FeatureFlags int
}

type ServerVersion struct {
	Major int
	Minor int
	Patch int
}

type Start struct {
}

type StreamExists struct{}

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

type StreamPosition interface {
	// contains filtered or unexported methods
}

type StreamRevision struct {
	Value uint64
}

type SubscribeToAllOptions struct {
	From               AllPosition
	ResolveLinkTos     bool
	MaxSearchWindow    int
	CheckpointInterval int
	Filter             *SubscriptionFilter
	Authenticated      *Credentials
	Deadline           *time.Duration
}

type SubscribeToPersistentSubscriptionOptions struct {
	BufferSize    uint32
	Authenticated *Credentials
	Deadline      *time.Duration
}

type SubscribeToStreamOptions struct {
	From           StreamPosition
	ResolveLinkTos bool
	Authenticated  *Credentials
	Deadline       *time.Duration
}

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

type SubscriptionDropped struct {
	Error error
}

type SubscriptionEvent struct {
	EventAppeared       *ResolvedEvent
	SubscriptionDropped *SubscriptionDropped
	CheckPointReached   *Position
}

type SubscriptionFilter struct {
	Type     FilterType
	Prefixes []string
	Regex    string
}

type SubscriptionFilterOptions struct {
	MaxSearchWindow    int
	CheckpointInterval int
	SubscriptionFilter *SubscriptionFilter
}

type SubscriptionSettings struct {
	StartFrom            interface{}
	ResolveLinkTos       bool
	ExtraStatistics      bool
	MaxRetryCount        int32
	CheckpointLowerBound int32
	CheckpointUpperBound int32
	MaxSubscriberCount   int32
	LiveBufferSize       int32
	ReadBatchSize        int32
	HistoryBufferSize    int32
	ConsumerStrategyName ConsumerStrategy
	MessageTimeout       int32
	CheckpointAfter      int32
}

type TombstoneStreamOptions struct {
	ExpectedRevision ExpectedRevision
	Authenticated    *Credentials
	Deadline         *time.Duration
}

type WriteResult struct {
	CommitPosition      uint64
	PreparePosition     uint64
	NextExpectedVersion uint64
}