executor

type ClientTunnel ¶

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

ClientTunnel is an implementation of Tunnel that will return results from the cluster to the end client.

func NewClientTunnel(clientConn *pgproto.Backend, extendedQueryMode bool) *ClientTunnel

func (t *ClientTunnel) SendMessage(msg pgproto.BackendMessage) error

type Executor ¶

type Executor interface {
	SetExtendedQueryMode(extended bool)
	Execute(plan plan.ExecutionPlan) error
}

func NewExecutor(colony core.Colony, logger timber.Logger, tunnel Tunnel) Executor

type Result ¶

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

type Tunnel ¶

type Tunnel interface {
	SendMessage(msg pgproto.BackendMessage) error
}

Tunnel is an interface used to receive and handle result data from the data node shard. When a query is executed, the response messages are piped into the provided tunnel.