session

Documentation

Index

• Constants
• func IsAlive(status Status) bool
• func Open(ctx context.Context, client Ydb_Query_V1.QueryServiceClient, opts ...Option) (_ *core, finalErr error)
• type Core
• type Option
  • func WithConn(cc grpc.ClientConnInterface) Option
  • func WithDeleteTimeout(deleteTimeout time.Duration) Option
  • func WithTrace(t *trace.Query) Option
• type Status
  • func (s Status) String() string

Constants

const (
	StatusIdle
	StatusInUse
	StatusClosing
	StatusClosed
	StatusError
)

Functions

func IsAlive

func IsAlive(status Status) bool

func Open

func Open(
	ctx context.Context, client Ydb_Query_V1.QueryServiceClient, opts ...Option,
) (_ *core, finalErr error)

Types

type Core

type Core interface {
	query.SessionInfo
	pool.Item

	SetStatus(code Status)
}

type Option

type Option func(*core)

func WithConn

func WithConn(cc grpc.ClientConnInterface) Option

func WithDeleteTimeout

func WithDeleteTimeout(deleteTimeout time.Duration) Option

func WithTrace

func WithTrace(t *trace.Query) Option

type Status

type Status uint32

func (Status) String

func (s Status) String() string