stream

type ByteCapacity uint64

type CreateStreamOptions struct {
	MaxAge         time.Duration
	MaxLength      ByteCapacity
	MaxSegmentSize ByteCapacity
}

type DoneChan struct {
	C chan struct{}
	// contains filtered or unexported fields
}

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

type EnvironmentConfiguration struct {
	// The URI of the nodes to try to connect to (cluster). This takes precedence
	// over URI and Host + Port.
	//
	// If Uris, Uri, Host and Port are zero-values, it will
	// default to "rabbitmq-stream://guest:guest@localhost:5552/%2f"
	Uris []string
	// The URI of the node to connect to (single node). This takes precedence over Host + Port.
	//
	// If Uris, Uri, Host and Port are zero-values, it will
	// default to "rabbitmq-stream://guest:guest@localhost:5552/%2f"
	Uri string
	// Host to connect to. Uris and Uri take precedence over this. Leave Uris and Uri unset
	// to use this and Port for connection.
	//
	// If Uris, Uri, Host and Port are zero-values, it will
	// default to "localhost"
	Host string
	// Port to use. Uris and Uri take precedence over this. Leave Uris and Uri unset
	// to use this and Host for connection.
	//
	// If Uris, Uri, Host and Port are zero-values, it will
	//default to 5552
	Port int
	// Username to use to connect.
	//
	// Default: "guest"
	Username string
	// Password to use to connect
	//
	// Default: "guest"
	Password string
	// Virtual host to connect to
	//
	// Default: "/"
	VirtualHost string
	// The maximum number of `Producer` instances a single connection can maintain
	// before a new connection is open. The value must be between 1 and 255
	//
	// Default: 255
	MaxProducersByConnection int
	// The maximum number of `Consumer` instances that store their offset a single
	// connection can maintain before a new connection is open. The value must be
	// between 1 and 255
	//
	// Default: 50
	MaxTrackingConsumersByConnection int
	// The maximum number of `Consumer` instances a single connection can maintain
	// before a new connection is open. The value must be between 1 and 255
	//
	// Default: 255
	MaxConsumersByConnection int
	// To delay the connection opening until necessary
	//
	// Default: false
	LazyInitialization bool
	// Informational ID for the environment instance. Used as a prefix for connection
	// names
	//
	// Default: "rabbitmq-stream"
	Id string
}

type EnvironmentConfigurationOption func(*EnvironmentConfiguration)

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