async

Documentation

Index

• Variables
• func AsString(src any) ([]byte, error)
• type InvocationType
• type Job
• type Notification
• type NotificationMethod
• type Principal
• type QueryArgs
  • func (q QueryArgs) Scan(src any) error
  • func (q QueryArgs) Value() (driver.Value, error)
• type Request
• type SQL
• type Status

Variables

var InvocationTypeKey = "invocation"

InvocationTypeKey defines context key

var JobKey = jobKey("job")

JobKey defines context job key

Functions

func AsString

func AsString(src any) ([]byte, error)

Types

type InvocationType

type InvocationType string

const (
	InvocationTypeEvent     InvocationType = "event"
	InvocationTypeUndefined InvocationType = ""
)

type Job

type Job struct {
	ID       string `sqlx:"primaryKey=true,name=ID" json:",omitempty"`
	MatchKey string `json:",omitempty"`
	Status   string `sqlx:"name=Status" json:",omitempty"`
	Metrics  string `json:",omitempty"`
	destination.Table
	destination.Cache
	Request
	Principal
	MainView      string     `json:",omitempty" sqlx:"MainView"`
	Module        string     `json:",omitempty" sqlx:"Module"`
	Labels        string     `json:",omitempty"`
	JobType       string     `json:",omitempty"`
	EventURL      string     `json:",omitempty"`
	Error         *string    `json:",omitempty"`
	CreationTime  time.Time  `json:",omitempty"`
	StartTime     *time.Time `json:",omitempty"`
	EndTime       *time.Time `json:",omitempty"`
	ExpiryTime    *time.Time `json:",omitempty"`
	WaitTimeInMcs int        `json:",omitempty"`
	RunTimeInMcs  int        `json:",omitempty"`
	SQL           []*SQL     `sqlx:"enc=JSON,name=SQLQuery" sqlxAsync:"enc=JSON,name=SQLQuery"`
	Deactivated   bool       `json:",omitempty"`
}

type Notification

type Notification struct {
	Method      NotificationMethod
	Destination string
}

type NotificationMethod

type NotificationMethod string

const (
	NotificationMethodStorage    NotificationMethod = "Storage"
	NotificationMethodMessageBus NotificationMethod = "MessageBus"
	NotificationMethodUndefined  NotificationMethod = ""
)

type Principal

type Principal struct {
	UserEmail *string `json:",omitempty"`
	UserID    *string `json:",omitempty"`
}

type QueryArgs

type QueryArgs []interface{}

func (QueryArgs) Scan

func (q QueryArgs) Scan(src any) error

func (QueryArgs) Value

func (q QueryArgs) Value() (driver.Value, error)

type Request

type Request struct {
	Method string `json:",omitempty"`
	URI    string `json:",omitempty"`
	State  string `json:",omitempty"`
}

type SQL

type SQL struct {
	Query string        `json:",omitempty"`
	Args  []interface{} `json:",omitempty"`
}

type Status

type Status string

const (
	StatusPending Status = "PENDING"
	StatusRunning Status = "RUNNING"
	StatusDone    Status = "DONE"
	StatusError   Status = "ERROR"
)