execute

Documentation

Index

• type CommandResponse
• type CommandResponseItem
• type Executor
  • func NewExecutor(getDbByID func(envID, dbID string) (*models.EnvDb, error), ...) Executor
  • func (e Executor) Execute(request Request) (response Response, err error)
  • func (e Executor) ExecuteSingle(command RequestCommand) (response Response, err error)
• type Request
  • func (v Request) Validate() error
• type RequestCommand
  • func (v RequestCommand) Validate() error
• type Response

Types

type CommandResponse

type CommandResponse struct {
	Items []CommandResponseItem `json:"items"`
}

CommandResponse defiens command response

type CommandResponseItem

type CommandResponseItem struct {
	Type  string      `json:"type"` // e.g. recordset
	Value interface{} `json:"value"`
}

CommandResponseItem defines response item

type Executor

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

Executor executes DataTug commands

func NewExecutor

func NewExecutor(
	getDbByID func(envID, dbID string) (*models.EnvDb, error),
	getCatalogSummary func(server models.ServerReference, catalogID string) (*models.DbCatalogSummary, error),
) Executor

NewExecutor creates new executor

func (Executor) Execute

func (e Executor) Execute(request Request) (response Response, err error)

Execute executes DataTug commands

func (Executor) ExecuteSingle

func (e Executor) ExecuteSingle(command RequestCommand) (response Response, err error)

ExecuteSingle executes single DB command

type Request

type Request struct {
	ID       string           `json:"id"`
	Project  string           `json:"project"`
	Commands []RequestCommand `json:"commands"`
}

Request defines what needs to be executed

func (Request) Validate

func (v Request) Validate() error

Validate checks if request is valid

type RequestCommand

type RequestCommand struct {
	models.Credentials // holds username & password, if not provided trusted connection
	models.ServerReference
	Env        string             `json:"env"`
	DB         string             `json:"db"`
	Text       string             `json:"text"`
	Parameters []models.Parameter `json:"parameters"`
}

RequestCommand holds parameters for command to be executed

func (RequestCommand) Validate

func (v RequestCommand) Validate() error

Validate checks of command request is valid

type Response

type Response struct {
	Duration time.Duration      `json:"durationNanoseconds"`
	Commands []*CommandResponse `json:"commands"`
}

Response holds execute response