connection

type Configuration struct {
	// The URI of the EventStoreDB.
	// Use this when connecting to a single node or when DNS Discovery is set to true.
	// 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 uint64 // 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.
	// If set to true use Address field as DNS address.
	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.
}

type ConnectionHandle interface {
	Id() uuid.UUID
	Connection() *grpc.ClientConn
}

type EndPoint struct {
	Host string
	Port uint16
}

type GrpcClient interface {
	HandleError(
		handle ConnectionHandle,
		headers metadata.MD,
		trailers metadata.MD,
		err error,
		mapUnknownErrorToOtherError ...errors.ErrorCode) errors.Error
	GetConnectionHandle() (ConnectionHandle, errors.Error)
	Close()
}

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

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

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

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

type NodePreference string