connections

Oct 21, 2026

Changes in this version

type Connection

+ AvailabilityZone string

+ BackendStart *time.Time

+ RouterCell string

+ RouterName string

+ RouterUID string

+ SidecarBackends []SidecarBackend

+ func (c Connection) NekiHumanFields() [][2]string

type ConnectionList

+ Warnings []string

type DatabaseKind

+ const DatabaseKindNeki

+ type NotFoundError struct

+ Branch string

+ Database string

+ Organization string

+ func (e *NotFoundError) Error() string

+ type SidecarBackend struct

+ BackendPID int

+ QueryStart *time.Time

+ QueryText string

+ ShardName string

+ ShardUID string

+ SidecarUID string

+ XactStart *time.Time

Jul 23, 2026

Changes in this version

+ func SanitizeDisplayText(value string) string

+ func SanitizeMultilineDisplayText(value string) string

Jun 16, 2026

Changes in this version

type ConnectionList

+ func (l ConnectionList) HasUnreachableInstance() bool

Jun 12, 2026

Changes in this version

+ func BlockingCounts(connections []Connection) map[int]int

+ func DerefString(value *string) string

+ func JoinInts(values []int) string

+ func JoinWaitEvents(waitEventType, waitEvent string) string

+ func SortConnections(connections []Connection, mode SortMode)

+ func UserFacingError(err error, action string) error

+ func UserFacingErrorText(err error, action string) string

+ type ActionResult struct

+ ID int64

+ Keyspace string

+ Kind string

+ Shard string

+ Success bool

+ Tablet string

+ type ActionTarget struct

+ ConnectionID *string

+ Instance string

+ PID int

+ QueryID *string

+ TransactionID *string

+ type AvailableTargets struct

+ Keyspaces []string

+ Shards []string

+ type Client struct

+ func NewClient(cfg ClientConfig) (*Client, error)

+ func (s *Client) CancelQuery(ctx context.Context, target ActionTarget) error

+ func (s *Client) CancelQueryResult(ctx context.Context, target ActionTarget) (ActionResult, error)

+ func (s *Client) List(ctx context.Context, sort SortMode) (ConnectionList, error)

+ func (s *Client) TerminateConnection(ctx context.Context, target ActionTarget) error

+ func (s *Client) TerminateConnectionResult(ctx context.Context, target ActionTarget) (ActionResult, error)

+ func (s *Client) TerminateTransaction(ctx context.Context, target ActionTarget) error

+ func (s *Client) TerminateTransactionResult(ctx context.Context, target ActionTarget) (ActionResult, error)

+ type ClientConfig struct

+ AccessToken string

+ BaseURL string

+ Branch string

+ Database string

+ HTTPClient *http.Client

+ Keyspace string

+ Organization string

+ RequestTimeout time.Duration

+ ServiceToken string

+ ServiceTokenID string

+ Shard string

+ type Connection struct

+ ApplicationName string

+ BackendType string

+ BlockedBy []int

+ ClientAddr string

+ ConnectionID *string

+ DatabaseName string

+ Duration time.Duration

+ Instance string

+ InstanceRole string

+ PID int

+ QueryID *string

+ QueryStart *time.Time

+ QueryText string

+ State string

+ TransactionID *string

+ Username string

+ WaitEvent string

+ WaitEventType string

+ XactStart *time.Time

+ func (c Connection) HumanFields() [][2]string

+ type ConnectionList struct

+ CapturedAt time.Time

+ Connections []Connection

+ DatabaseKind DatabaseKind

+ Instances []InstanceMeta

+ Sort SortMode

+ Topology *Topology

+ func NewConnectionList(capturedAt time.Time, connections []Connection, sort SortMode) ConnectionList

+ type DatabaseKind string

+ const DatabaseKindMySQL

+ const DatabaseKindPostgreSQL

+ type HTTPError struct

+ Available AvailableTargets

+ Message string

+ Op string

+ StatusCode int

+ func (e *HTTPError) Error() string

+ type InstanceMeta struct

+ Error string

+ ID string

+ Role string

+ type SortMode string

+ const SortByBlocked

+ const SortByDuration

+ const SortByTransactionStart

+ type Topology struct

+ Keyspace string

+ Shard string

+ Tablet string

+ type UnknownInstanceError struct

+ Instance string

+ Valid []string

+ func (e *UnknownInstanceError) Error() string