conn

Documentation

Index

• Constants
• func WithoutWrapping(ctx context.Context) context.Context
• type Config
• type Conn
  • func New(e endpoint.Endpoint, config Config, opts ...option) Conn
• type Getter
• type Pessimizer
• type Pool
  • func NewPool(ctx context.Context, config Config) Pool
• type PoolConfig
• type Releaser
• type State
  • func (s State) Code() int
  • func (s State) IsValid() bool
  • func (s State) String() string
• type Taker

Constants

const (
	Unknown = State(iota)
	Created
	Online
	Banned
	Offline
	Destroyed
)

Functions

func WithoutWrapping

func WithoutWrapping(ctx context.Context) context.Context

Types

type Config

type Config interface {
	DialTimeout() time.Duration
	Trace() trace.Driver
	ConnectionTTL() time.Duration
	GrpcDialOptions() []grpc.DialOption
	UseDNSResolver() bool
}

type Conn

type Conn interface {
	grpc.ClientConnInterface

	Endpoint() endpoint.Endpoint

	LastUsage() time.Time

	IsState(states ...State) bool
	GetState() State
	SetState(State) State

	Release(ctx context.Context) error
}

func New

func New(e endpoint.Endpoint, config Config, opts ...option) Conn

type Getter

type Getter interface {
	Get(endpoint endpoint.Endpoint) Conn
}

type Pessimizer

type Pessimizer interface {
	Pessimize(ctx context.Context, cc Conn, cause error)
}

type Pool

type Pool interface {
	Getter
	Taker
	Releaser
	Pessimizer
}

func NewPool

func NewPool(
	ctx context.Context,
	config Config,
) Pool

type PoolConfig

type PoolConfig interface {
	ConnectionTTL() time.Duration
	GrpcDialOptions() []grpc.DialOption
}

type Releaser

type Releaser interface {
	Release(ctx context.Context) error
}

type State

type State int8

func (State) Code

func (s State) Code() int

func (State) IsValid

func (s State) IsValid() bool

func (State) String

func (s State) String() string

type Taker

type Taker interface {
	Take(ctx context.Context) error
}