connection

type ClientConfig struct {
	Endpoints []*Endpoint   `mapstructure:"endpoints"`
	Retry     *RetryProfile `mapstructure:"reconnect"`
	RootCA    [][]byte      `mapstructure:"root-ca"`
	// RootCAPaths The path to the root CAs (alternative to the raw data).
	RootCAPaths []string `mapstructure:"root-ca-paths"`
}

type DialConfig struct {
	Address  string
	DialOpts []grpc.DialOption
	// Resolver may be updated to update the connection's endpoints.
	Resolver *manual.Resolver
}

type Endpoint struct {
	Host string `mapstructure:"host" json:"host,omitempty" yaml:"host,omitempty"`
	Port int    `mapstructure:"port" json:"port,omitempty" yaml:"port,omitempty"`
}

type RetryProfile struct {
	InitialInterval     time.Duration `mapstructure:"initial-interval" yaml:"initial-interval"`
	RandomizationFactor float64       `mapstructure:"randomization-factor" yaml:"randomization-factor"`
	Multiplier          float64       `mapstructure:"multiplier" yaml:"multiplier"`
	MaxInterval         time.Duration `mapstructure:"max-interval" yaml:"max-interval"`
	// After MaxElapsedTime the ExponentialBackOff returns RetryStopDuration.
	// It never stops if MaxElapsedTime == 0.
	MaxElapsedTime time.Duration `mapstructure:"max-elapsed-time" yaml:"max-elapsed-time"`
}

type ServerConfig struct {
	Endpoint  Endpoint               `mapstructure:"endpoint"`
	Creds     *ServerCredsConfig     `mapstructure:"creds"`
	KeepAlive *ServerKeepAliveConfig `mapstructure:"keep-alive"`
	// contains filtered or unexported fields
}

type ServerCredsConfig struct {
	CertPath string `mapstructure:"cert-path"`
	KeyPath  string `mapstructure:"key-path"`
}

type ServerKeepAliveConfig struct {
	Params            *ServerKeepAliveParamsConfig            `mapstructure:"params"`
	EnforcementPolicy *ServerKeepAliveEnforcementPolicyConfig `mapstructure:"enforcement-policy"`
}

type ServerKeepAliveEnforcementPolicyConfig struct {
	MinTime             time.Duration `mapstructure:"min-time"`
	PermitWithoutStream bool          `mapstructure:"permit-without-stream"`
}

type ServerKeepAliveParamsConfig struct {
	MaxConnectionIdle     time.Duration `mapstructure:"max-connection-idle"`
	MaxConnectionAge      time.Duration `mapstructure:"max-connection-age"`
	MaxConnectionAgeGrace time.Duration `mapstructure:"max-connection-age-grace"`
	Time                  time.Duration `mapstructure:"time"`
	Timeout               time.Duration `mapstructure:"timeout"`
}

type Service interface {
	// Run executes the service until the context is done.
	Run(ctx context.Context) error
	// WaitForReady waits for the service resources to initialize.
	// If the context ended before the service is ready, returns false.
	WaitForReady(ctx context.Context) bool
	// RegisterService registers the supported APIs for this service.
	RegisterService(server *grpc.Server)
}

type WithAddress interface {
	Address() string
}