stream

type AuthOptions struct {
	// Type specifies the authentication type, supported values: 'bearer'
	// If empty, no authentication enabled.
	Type string
	// Bearer configures the bearer authentication type..
	Bearer BearerOptions
}

type BearerOptions struct {
	// Bearer token
	Token string
}

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

type FromS interface {
	*protos.ServerToClient | *protos.ServerToSampler
}

type Handler[F FromS, T ToS] interface {
	// contains filtered or unexported methods
}

type Options struct {
	// Block determines if the initial connection request will block until it
	// successfully connects.
	Block bool
	// ConnTimeout is a duration for the maximum amount of time to wait
	// during the initial connection request. Only applicable if Block is true.
	ConnTimeout time.Duration
	// ResponseTimeout is a duration for the maximum amount of time to wait
	// for a response to a request send to the server.
	ResponseTimeout time.Duration
	// KeepAliveMaxPeriod is a duration that defines the maximum period to
	// send keep alive messages. Minimum value is 10s. A larger period reduces
	// network load but increases the time required to detect when the stream
	// disconnects.
	KeepAliveMaxPeriod time.Duration
	// ServerReqsQueueLen defines how many server requests are allowed to be queued.
	ServerReqsQueueLen int
	// TLS related options
	TLS TLSOptions
	// Auth related options
	Auth AuthOptions
}

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

type State int

type Stream[F FromS, T ToS] struct {
	// contains filtered or unexported fields
}

type TLSOptions struct {
	// Enable determines if the server implements TLS. If TLSCert is not set,
	// it t will use the system CA certificates to validate the server certificate.
	// By default, it is disabled.
	Enable bool
	// CACertPath defines te path to the certificate CA used to validate the
	// server certificate.
	CACertPath string
}

type ToS interface {
	*protos.ClientToServer | *protos.SamplerToServer
}