systemlayer

Documentation

Index

• type ExecutionRequests
  • func NewExecutionRequestsAPI() *ExecutionRequests
  • func (e *ExecutionRequests) AddRequest(requestID string, userID string, startTime time.Time, sql string) error
  • func (e *ExecutionRequests) GetRequest(requestID string) (pilosa.ExecutionRequest, error)
  • func (e *ExecutionRequests) ListRequests() ([]pilosa.ExecutionRequest, error)
  • func (e *ExecutionRequests) UpdateRequest(requestID string, endTime time.Time, status string, waitType string, ...) error
• type SystemLayer
  • func NewSystemLayer() *SystemLayer
  • func (e *SystemLayer) ExecutionRequests() pilosa.ExecutionRequestsAPI

Types

type ExecutionRequests

type ExecutionRequests struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ExecutionRequests is an internal struct that keeps a list of sql execution requests this data allows visbility into queries that have been run and are running

func NewExecutionRequestsAPI

func NewExecutionRequestsAPI() *ExecutionRequests

func (*ExecutionRequests) AddRequest

func (e *ExecutionRequests) AddRequest(requestID string, userID string, startTime time.Time, sql string) error

AddRequest adds a new request to the ExecutionRequests struct

func (*ExecutionRequests) GetRequest

func (e *ExecutionRequests) GetRequest(requestID string) (pilosa.ExecutionRequest, error)

func (*ExecutionRequests) ListRequests

func (e *ExecutionRequests) ListRequests() ([]pilosa.ExecutionRequest, error)

ListRequests returns the content of the ExecutionRequests struct as copies

func (*ExecutionRequests) UpdateRequest

func (e *ExecutionRequests) UpdateRequest(requestID string,
	endTime time.Time,
	status string,
	waitType string,
	waitTime time.Duration,
	waitResource string,
	cpuTime time.Duration,
	reads int64,
	writes int64,
	logicalReads int64,
	rowCount int64,
	plan string) error

UpdateRequest updates the values for a request in the ExecutionRequests struct

type SystemLayer

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

SystemLayer is a struct to hold internal FeatureBase state Initially this is just the execution requests, but later may include other internal state (Buffer Pool?)

func NewSystemLayer

func NewSystemLayer() *SystemLayer

func (*SystemLayer) ExecutionRequests

func (e *SystemLayer) ExecutionRequests() pilosa.ExecutionRequestsAPI