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 Pool
  • func NewPool(ctx context.Context, config Config) *Pool
  • func (p *Pool) Allow(ctx context.Context, cc Conn)
  • func (p *Pool) Ban(ctx context.Context, cc Conn, cause error)
  • func (p *Pool) Get(endpoint endpoint.Endpoint) Conn
  • func (p *Pool) Release(ctx context.Context) error
  • func (p *Pool) Take(context.Context) error
• type State
  • func (s State) Code() int
  • func (s State) IsValid() bool
  • func (s State) String() string

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
}

type Conn

type Conn interface {
	grpc.ClientConnInterface

	Endpoint() endpoint.Endpoint

	LastUsage() time.Time

	Ping(ctx context.Context) error
	IsState(states ...State) bool
	GetState() State
	SetState(State) State
	Unban() State
}

func New

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

type Pool

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

func NewPool

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

func (*Pool) Allow

func (p *Pool) Allow(ctx context.Context, cc Conn)

func (*Pool) Ban

func (p *Pool) Ban(ctx context.Context, cc Conn, cause error)

func (*Pool) Get

func (p *Pool) Get(endpoint endpoint.Endpoint) Conn

func (*Pool) Release

func (p *Pool) Release(ctx context.Context) error

func (*Pool) Take

func (p *Pool) Take(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