types

package
v0.2.0-beta.202401080326 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 8, 2024 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var OutputModeIds = map[OutputMode][]string{
	OutputModePretty: {"pretty"},
	OutputModePlain:  {"plain"},
	OutputModeYaml:   {"yaml"},
	OutputModeJson:   {"json"},
}

③ Map enumeration values to their textual representations (value identifiers).

Functions

This section is empty.

Types

type APIVersionRequestURI 

type APIVersionRequestURI struct {
	APIVersion string `uri:"api_version" binding:"required,flowpipe_api_version"`
}

APIVersionRequestURI defines the requested API version.

type CmdPipeline 

type CmdPipeline struct {
	Command       string                 `json:"command" binding:"required,oneof=run"`
	Args          map[string]interface{} `json:"args,omitempty"`
	ArgsString    map[string]string      `json:"args_string,omitempty"`
	ExecutionMode *string                `json:"execution_mode,omitempty" binding:"omitempty,oneof=synchronous asynchronous"`
	WaitRetry     *int                   `json:"wait_retry,omitempty" binding:"omitempty"`
}

func (*CmdPipeline) GetExecutionMode 

func (c *CmdPipeline) GetExecutionMode() string

func (*CmdPipeline) GetWaitRetry 

func (c *CmdPipeline) GetWaitRetry() int

type CmdProcess 

type CmdProcess struct {
	Command             string `json:"command" binding:"required,oneof=run cancel pause resume"`
	PipelineExecutionID string `json:"pipeline_execution_id,omitempty" format:"^(pexec|exec)_[0-9a-v]{20}$"`
	Reason              string `json:"reason,omitempty"`
}

type EventLogEntry 

type EventLogEntry struct {
	EventType string          `json:"event_type"`
	Timestamp *time.Time      `json:"ts"`
	Payload   json.RawMessage `json:"payload"`
}

type FlowpipeRequire 

type FlowpipeRequire struct {
	MinVersionString string `json:"min_version,omitempty"`
}

type FpPipeline 

type FpPipeline struct {
	Name            string                     `json:"name"`
	Description     *string                    `json:"description,omitempty"`
	Mod             string                     `json:"mod"`
	Title           *string                    `json:"title,omitempty"`
	Documentation   *string                    `json:"documentation,omitempty"`
	FileName        string                     `json:"file_name,omitempty"`
	StartLineNumber int                        `json:"start_line_number,omitempty"`
	EndLineNumber   int                        `json:"end_line_number,omitempty"`
	Tags            map[string]string          `json:"tags,omitempty"`
	Steps           []modconfig.PipelineStep   `json:"steps,omitempty"`
	OutputConfig    []modconfig.PipelineOutput `json:"outputs,omitempty"`
	Params          []FpPipelineParam          `json:"params,omitempty"`
}

func FpPipelineFromAPIResponse 

func FpPipelineFromAPIResponse(apiResp flowpipeapiclient.FpPipeline) (*FpPipeline, error)

func FpPipelineFromModPipeline 

func FpPipelineFromModPipeline(pipeline *modconfig.Pipeline) (*FpPipeline, error)

func (FpPipeline) String 

func (p FpPipeline) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type FpPipelineExecution 

type FpPipelineExecution struct {
	ExecutionId         string                `json:"execution_id"`
	PipelineExecutionId string                `json:"pipeline_execution_id"`
	Status              string                `json:"status"`
	PipelineName        *string               `json:"pipeline,omitempty"`
	CreatedAt           *time.Time            `json:"created_at,omitempty"`
	Outputs             map[string]any        `json:"outputs,omitempty"`
	Errors              []modconfig.StepError `json:"errors,omitempty"`
}

func FpPipelineExecutionFromAPIResponse 

func FpPipelineExecutionFromAPIResponse(apiResp map[string]any) (*FpPipelineExecution, error)

func (FpPipelineExecution) String 

func (p FpPipelineExecution) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type FpPipelineParam 

type FpPipelineParam struct {
	Name        string  `json:"name"`
	Description *string `json:"description,omitempty"`
	Optional    *bool   `json:"optional,omitempty"`
	Default     any     `json:"default,omitempty"`
	Type        string  `json:"type"`
}

func (FpPipelineParam) String 

func (p FpPipelineParam) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type FpTrigger 

type FpTrigger struct {
	Name            string            `json:"name"`
	Type            string            `json:"type"`
	Description     *string           `json:"description,omitempty"`
	Pipeline        string            `json:"pipeline"`
	Url             *string           `json:"url,omitempty"`
	Title           *string           `json:"title,omitempty"`
	FileName        string            `json:"file_name,omitempty"`
	StartLineNumber int               `json:"start_line_number,omitempty"`
	EndLineNumber   int               `json:"end_line_number,omitempty"`
	Documentation   *string           `json:"documentation,omitempty"`
	Tags            map[string]string `json:"tags,omitempty"`
	Schedule        *string           `json:"schedule,omitempty"`
}

func FpTriggerFromAPI 

func FpTriggerFromAPI(apiTrigger flowpipeapiclient.FpTrigger) FpTrigger

func (FpTrigger) String 

func (t FpTrigger) String(_ *sanitize.Sanitizer, opts RenderOptions) string

type InputRequestQuery 

type InputRequestQuery struct {
	ExecutionMode       *string `json:"execution_mode" form:"execution_mode" binding:"omitempty,oneof=synchronous asynchronous"`
	ExecutionID         string  `json:"execution_id" form:"execution_id" binding:"omitempty"`
	PipelineExecutionID string  `json:"pipeline_execution_id" form:"pipeline_execution_id" binding:"omitempty"`
	StepExecutionID     string  `json:"step_execution_id" form:"step_execution_id" binding:"omitempty"`
	Value               string  `json:"value" form:"value"`
}

type InputRequestUri 

type InputRequestUri struct {
	Input string `json:"input" uri:"input" binding:"required"`
	Hash  string `json:"hash" uri:"hash" binding:"required"`
}

type ListPipelineResponse 

type ListPipelineResponse struct {
	Items     []FpPipeline `json:"items"`
	NextToken *string      `json:"next_token,omitempty"`
}

This type is used by the API to return a list of pipelines.

func ListPipelineResponseFromAPIResponse 

func ListPipelineResponseFromAPIResponse(apiResp *flowpipeapiclient.ListPipelineResponse) (*ListPipelineResponse, error)

func (ListPipelineResponse) GetResourceType 

func (o ListPipelineResponse) GetResourceType() string

type ListProcessLogJSONResponse 

type ListProcessLogJSONResponse struct {
	Items     []ProcessEventLog `json:"items"`
	NextToken *string           `json:"next_token,omitempty"`
}

type ListProcessLogResponse 

type ListProcessLogResponse struct {
	Items     []EventLogEntry `json:"items"`
	NextToken *string         `json:"next_token,omitempty"`
}

This type is used by the API to return a list of proces logs.

type ListProcessResponse 

type ListProcessResponse struct {
	Items     []Process `json:"items"`
	NextToken *string   `json:"next_token,omitempty"`
}

This type is used by the API to return a list of processs.

func ListProcessResponseFromAPIResponse 

func ListProcessResponseFromAPIResponse(apiResp *flowpipeapiclient.ListProcessResponse) (*ListProcessResponse, error)

type ListRequestQuery 

type ListRequestQuery struct {
	NextToken string `json:"next_token" form:"next_token" binding:"omitempty"`
	Limit     *int   `json:"limit,omitempty" form:"limit" binding:"omitempty"`
}

type ListTriggerResponse 

type ListTriggerResponse struct {
	Items     []FpTrigger `json:"items"`
	NextToken *string     `json:"next_token,omitempty"`
}

This type is used by the API to return a list of triggers.

func ListTriggerResponseFromAPI 

func ListTriggerResponseFromAPI(apiResp *flowpipeapiclient.ListTriggerResponse) *ListTriggerResponse

func (ListTriggerResponse) GetResourceType 

func (o ListTriggerResponse) GetResourceType() string

type ListVariableResponse 

type ListVariableResponse struct {
	Items     []Variable `json:"items"`
	NextToken *string    `json:"next_token,omitempty"`
}

This type is used by the API to return a list of variables.

type Mod 

type Mod struct {
	Name          string     `json:"name"`
	Title         *string    `json:"title,omitempty"`
	Description   *string    `json:"description,omitempty"`
	Documentation *string    `json:"documentation,omitempty"`
	Color         *string    `json:"color,omitempty"`
	Categories    []string   `json:"categories,omitempty"`
	OpenGraph     *OpenGraph `json:"opengraph,omitempty"`
	Require       *Require   `json:"require,omitempty"`
}

func NewModFromModConfigMod 

func NewModFromModConfigMod(mod *modconfig.Mod) *Mod

type ModRequestURI 

type ModRequestURI struct {
	ModName string `uri:"mod_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type ModVersionConstraint 

type ModVersionConstraint struct {
	// the fully qualified mod name, e.g. github.com/turbot/mod1
	Name          string `json:"name"`
	VersionString string `json:"version,omitempty"`
}

type OpenGraph 

type OpenGraph struct {
	// The opengraph description (og:description) of the mod, for use in social media applications
	Description *string `json:"description,omitempty"`
	Title       *string `json:"title,omitempty"`
}

type OutputMode 

type OutputMode enumflag.Flag

① Define your new enum flag type. It can be derived from enumflag.Flag, but it doesn't need to be as long as it satisfies constraints.Integer. 

const (
	OutputModePretty OutputMode = iota
	OutputModePlain
	OutputModeYaml
	OutputModeJson
)

② Define the enumeration values for FooMode.

type ParsedErrorEvent 

type ParsedErrorEvent struct {
	ParsedEvent
	Errors   []modconfig.StepError `json:"errors"`
	Output   map[string]any        `json:"attributes"`
	Duration *string               `json:"duration,omitempty"`
	// contains filtered or unexported fields
}

ParsedErrorEvent is a ParsedEvent which Failed.

func (ParsedErrorEvent) String 

func (p ParsedErrorEvent) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ParsedEvent 

type ParsedEvent struct {
	ParsedEventPrefix
	Type     string `json:"event_type"`
	StepType string `json:"step_type"`
	Message  string `json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (ParsedEvent) String 

func (p ParsedEvent) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ParsedEventPrefix 

type ParsedEventPrefix struct {
	FullPipelineName string  `json:"full_pipeline_name"`
	PipelineName     string  `json:"pipeline_name"`
	FullStepName     *string `json:"full_step_name,omitempty"`
	StepName         *string `json:"step_name,omitempty"`
	ForEachKey       *string `json:"for_each_key,omitempty"`
	LoopIndex        *int    `json:"loop_index,omitempty"`
	RetryIndex       *int    `json:"retry_index,omitempty"`
}

func NewPrefix 

func NewPrefix(fullPipelineName string) ParsedEventPrefix

func (ParsedEventPrefix) String 

func (p ParsedEventPrefix) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ParsedEventRegistryItem 

type ParsedEventRegistryItem struct {
	Name    string
	Started time.Time
	Args    *modconfig.Input
}

type ParsedEventWithInput 

type ParsedEventWithInput struct {
	ParsedEvent
	Input map[string]any `json:"args"`
	// contains filtered or unexported fields
}

func (ParsedEventWithInput) String 

func (p ParsedEventWithInput) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ParsedEventWithOutput 

type ParsedEventWithOutput struct {
	ParsedEvent
	Output     map[string]any `json:"attributes"`
	StepOutput map[string]any `json:"step_output"`
	Duration   *string        `json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (ParsedEventWithOutput) String 

func (p ParsedEventWithOutput) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ParsedHeader 

type ParsedHeader struct {
	ExecutionId string `json:"execution_id"`
	IsStale     bool   `json:"is_stale"`
	LastLoaded  string `json:"last_loaded"`
}

func (ParsedHeader) String 

func (p ParsedHeader) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type PipelineExecutionResponse 

type PipelineExecutionResponse map[string]interface{}

type PipelineRequestQuery 

type PipelineRequestQuery struct {
	ExecutionMode *string `json:"execution_mode" form:"execution_mode" binding:"omitempty,oneof=synchronous asynchronous"`
}

type PipelineRequestURI 

type PipelineRequestURI struct {
	PipelineName string `uri:"pipeline_name" binding:"required" format:"^[a-z_]{0,32}$"`
}

type PrintableParsedEvent 

type PrintableParsedEvent struct {
	Items    []SanitizedStringer
	Registry map[string]ParsedEventRegistryItem
	// contains filtered or unexported fields
}

func NewPrintableParsedEvent 

func NewPrintableParsedEvent(pipelineId string) *PrintableParsedEvent

func (*PrintableParsedEvent) GetItems 

func (p *PrintableParsedEvent) GetItems() []SanitizedStringer

func (*PrintableParsedEvent) GetTable 

func (p *PrintableParsedEvent) GetTable() (Table, error)

func (*PrintableParsedEvent) SetEvents 

func (p *PrintableParsedEvent) SetEvents(logs ProcessEventLogs) error

type PrintablePipeline 

type PrintablePipeline struct {
	Items []FpPipeline
}

func NewPrintablePipeline 

func NewPrintablePipeline(resp *ListPipelineResponse) *PrintablePipeline

func NewPrintablePipelineFromSingle 

func NewPrintablePipelineFromSingle(input *FpPipeline) *PrintablePipeline

func (PrintablePipeline) GetItems 

func (p PrintablePipeline) GetItems() []FpPipeline

func (PrintablePipeline) GetTable 

func (p PrintablePipeline) GetTable() (Table, error)

type PrintablePipelineExecution 

type PrintablePipelineExecution struct {
	Items []FpPipelineExecution
}

func (PrintablePipelineExecution) GetItems 

func (p PrintablePipelineExecution) GetItems() []FpPipelineExecution

func (PrintablePipelineExecution) GetTable 

func (p PrintablePipelineExecution) GetTable() (Table, error)

type PrintableProcess 

type PrintableProcess struct {
	Items []Process
}

func NewPrintableProcess 

func NewPrintableProcess(resp *ListProcessResponse) *PrintableProcess

func NewPrintableProcessFromSingle 

func NewPrintableProcessFromSingle(input *Process) *PrintableProcess

func (PrintableProcess) GetItems 

func (p PrintableProcess) GetItems() []Process

func (PrintableProcess) GetTable 

func (p PrintableProcess) GetTable() (Table, error)

type PrintableResource 

type PrintableResource[T any] interface {
	GetItems() []T
	GetTable() (Table, error)
}

type PrintableServerOutput added in v0.2.0 

type PrintableServerOutput struct {
	Items []SanitizedStringer
}

func NewPrintableServerOutput added in v0.2.0 

func NewPrintableServerOutput() *PrintableServerOutput

func (*PrintableServerOutput) GetItems added in v0.2.0 

func (p *PrintableServerOutput) GetItems() []SanitizedStringer

func (*PrintableServerOutput) GetTable added in v0.2.0 

func (p *PrintableServerOutput) GetTable() (Table, error)

type PrintableTrigger 

type PrintableTrigger struct {
	Items []FpTrigger
}

func NewPrintableTrigger 

func NewPrintableTrigger(resp *ListTriggerResponse) *PrintableTrigger

func NewPrintableTriggerFromSingle 

func NewPrintableTriggerFromSingle(input *FpTrigger) *PrintableTrigger

func (PrintableTrigger) GetItems 

func (p PrintableTrigger) GetItems() []FpTrigger

func (PrintableTrigger) GetTable 

func (p PrintableTrigger) GetTable() (Table, error)

type PrintableVariable 

type PrintableVariable struct {
	Items []Variable
}

func (PrintableVariable) GetItems 

func (p PrintableVariable) GetItems() []Variable

func (PrintableVariable) GetTable 

func (p PrintableVariable) GetTable() (Table, error)

type Process 

type Process struct {
	ID        string    `json:"execution_id"`
	Pipeline  string    `json:"pipeline"`
	Status    string    `json:"status"`
	CreatedAt time.Time `json:"created_at"`
}

The definition of a single Flowpipe Process

func ProcessFromAPIResponse 

func ProcessFromAPIResponse(apiResp flowpipeapiclient.Process) (*Process, error)

func (Process) String 

func (p Process) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ProcessEventLog 

type ProcessEventLog struct {
	EventType string     `json:"event_type"`
	Timestamp *time.Time `json:"ts"`
	// Setting the type as string for now, as the CLI need to print the payload
	Payload string `json:"payload"`
}

Identical to the EventLogEntry struct in internal/types/execution.go Using the EventLogEntry returned an error at the time of openapi generation: cannot find type definition: json.RawMessage TODO - Recheck to use the EventLogEntry struct

type ProcessEventLogs 

type ProcessEventLogs []ProcessEventLog

func (ProcessEventLogs) GetResourceType 

func (ProcessEventLogs) GetResourceType() string

GetResourceType is used to satisfy the interface requirements of types.PrintableResource Transform function

type ProcessOutputData 

type ProcessOutputData struct {
	ID     string                 `json:"process_id"`
	Output map[string]interface{} `json:"output"`
}

type ProcessPayload 

type ProcessPayload struct {
	PipelineName        string              `json:"name"`
	PipelineExecutionID string              `json:"pipeline_execution_id"`
	Event               ProcessPayloadEvent `json:"event"`
}

Process log payload definition

type ProcessPayloadEvent 

type ProcessPayloadEvent struct {
	CreatedAt time.Time `json:"created_at"`
}

type ProcessRequestURI 

type ProcessRequestURI struct {
	// TODO: do we want to pass the ExecutionID or PipelineExecutionID? The log is stored under ExecutionID but the execution works with PipelineExecutionID
	// ProcessId string `uri:"process_id" binding:"required" format:"^(pexec|exec)_[0-9a-v]{20}$"`
	ProcessId string `uri:"process_id" binding:"required" format:"^exec_[0-9a-v]{20}$"`
}

type RenderOptions 

type RenderOptions struct {
	ColorEnabled   bool
	ColorGenerator *color.DynamicColorGenerator
	Verbose        bool
	JsonFormatter  *prettyjson.Formatter
}

type Require 

type Require struct {
	Flowpipe *FlowpipeRequire       `json:"flowpipe,omitempty"`
	Mods     []ModVersionConstraint `json:"mods,omitempty"`
}

type SanitizedStringer 

type SanitizedStringer interface {
	String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string
}

type ServerOutput added in v0.2.0 

type ServerOutput struct {
	ServerOutputPrefix
	Message string
}

func NewServerOutput added in v0.2.0 

func NewServerOutput(ts time.Time, category string, msg string) ServerOutput

func (ServerOutput) String added in v0.2.0 

func (o ServerOutput) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputError added in v0.2.0 

type ServerOutputError struct {
	ServerOutputPrefix
	Message string
	Error   error
}

func NewServerOutputError added in v0.2.0 

func NewServerOutputError(serverOutputPrefix ServerOutputPrefix, message string, error error) *ServerOutputError

func (ServerOutputError) String added in v0.2.0 

func (o ServerOutputError) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputLoaded added in v0.2.0 

type ServerOutputLoaded struct {
	ServerOutputPrefix
	ModName  string
	IsReload bool
}

func NewServerOutputLoaded added in v0.2.0 

func NewServerOutputLoaded(serverOutputPrefix ServerOutputPrefix, modName string, isReload bool) *ServerOutputLoaded

func (ServerOutputLoaded) String added in v0.2.0 

func (o ServerOutputLoaded) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputPipelineExecution 

type ServerOutputPipelineExecution struct {
	ServerOutputPrefix
	ExecutionID  string
	PipelineName string
	Status       string
	Output       map[string]any
	Errors       []modconfig.StepError
}

func NewServerOutputPipelineExecution 

func NewServerOutputPipelineExecution(prefix ServerOutputPrefix, execId string, name string, status string) *ServerOutputPipelineExecution

func (ServerOutputPipelineExecution) String 

func (o ServerOutputPipelineExecution) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputPrefix added in v0.2.0 

type ServerOutputPrefix struct {
	TimeStamp time.Time
	Category  string
}

func NewServerOutputPrefix added in v0.2.0 

func NewServerOutputPrefix(ts time.Time, category string) ServerOutputPrefix

func (ServerOutputPrefix) String added in v0.2.0 

func (o ServerOutputPrefix) String(_ *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputStatusChange added in v0.2.0 

type ServerOutputStatusChange struct {
	ServerOutputPrefix
	Status     string
	Additional string
}

func NewServerOutputStatusChange added in v0.2.0 

func NewServerOutputStatusChange(ts time.Time, status string, additional string) ServerOutputStatusChange

func (ServerOutputStatusChange) String added in v0.2.0 

func (o ServerOutputStatusChange) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputStepExecution 

type ServerOutputStepExecution struct {
	ServerOutputPrefix
	ExecutionID  string
	PipelineName string
	StepName     string
	StepType     string
	Status       string
	Output       map[string]any
	Errors       []modconfig.StepError
}

func NewServerOutputStepExecution 

func NewServerOutputStepExecution(prefix ServerOutputPrefix, execId string, pipelineName string, stepName string, stepType string, status string) *ServerOutputStepExecution

func (ServerOutputStepExecution) String 

func (o ServerOutputStepExecution) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputTrigger added in v0.2.0 

type ServerOutputTrigger struct {
	ServerOutputPrefix
	Name     string
	Type     string
	Schedule *string
	Method   *string
	Url      *string
	Sql      *string
}

func NewServerOutputTrigger added in v0.2.0 

func NewServerOutputTrigger(prefix ServerOutputPrefix, n string, t string) *ServerOutputTrigger

func (ServerOutputTrigger) String added in v0.2.0 

func (o ServerOutputTrigger) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type ServerOutputTriggerExecution added in v0.2.0 

type ServerOutputTriggerExecution struct {
	ServerOutputPrefix
	ExecutionID  string
	TriggerName  string
	PipelineName string
}

func NewServerOutputTriggerExecution added in v0.2.0 

func NewServerOutputTriggerExecution(prefix ServerOutputPrefix, execId string, name string, pipeline string) *ServerOutputTriggerExecution

func (ServerOutputTriggerExecution) String added in v0.2.0 

func (o ServerOutputTriggerExecution) String(sanitizer *sanitize.Sanitizer, opts RenderOptions) string

type Stack 

type Stack struct {
	ID         string            `json:"id"`
	Status     string            `json:"status"`
	StepStatus map[int]string    `json:"pipeline_step_status"`
	Stacks     map[string]*Stack `json:"children"`
}

type Table 

type Table struct {
	Rows    []TableRow
	Columns []TableColumnDefinition
}

func NewTable 

func NewTable(tableRows []TableRow, columns []TableColumnDefinition) Table

type TableColumnDefinition 

type TableColumnDefinition struct {
	// name is a human readable name for the column.
	Name string `json:"name"`
	// type is an OpenAPI type definition for this column, such as number, integer, string, or
	// array.
	// See https://github.com/OAI/OpenAPI-Specification/blob/master/versions/2.0.md#data-types for more.
	Type string `json:"type"`
	// format is an optional OpenAPI type modifier for this column. A format modifies the type and
	// imposes additional rules, like date or time formatting for a string. The 'name' format is applied
	// to the primary identifier column which has type 'string' to assist in clients identifying column
	// is the resource name.
	// See https://github.com/OAI/OpenAPI-Specification/blob/master/versions/2.0.md#data-types for more.
	Format string `json:"format"`
	// description is a human readable description of this column.
	Description string `json:"description"`
	// priority is an integer defining the relative importance of this column compared to others. Lower
	// numbers are considered higher priority. Columns that may be omitted in limited space scenarios
	// should be given a higher priority.
	Priority int32 `json:"priority"`
}

Taken from kubectl

func (*TableColumnDefinition) Formatter 

func (t *TableColumnDefinition) Formatter() string

type TableRow 

type TableRow struct {
	Cells []any
}

type TriggerRequestURI 

type TriggerRequestURI struct {
	TriggerName string `uri:"trigger_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type Variable 

type Variable struct {
	Type        string  `json:"type"`
	Name        string  `json:"name"`
	Description *string `json:"description,omitempty"`
	Default     any     `json:"default"`
	Value       any     `json:"value"`
}

The definition of a single Flowpipe Variable

type VariableRequestURI 

type VariableRequestURI struct {
	VariableName string `uri:"variable_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type WebhookRequestQuery 

type WebhookRequestQuery struct {
	WaitTime *int `json:"wait_time" form:"wait_time" binding:"omitempty"`
}

func (*WebhookRequestQuery) GetWaitTime 

func (c *WebhookRequestQuery) GetWaitTime() int

type WebhookRequestUri 

type WebhookRequestUri struct {
	Trigger string `json:"trigger" uri:"trigger" binding:"required"`
	Hash    string `json:"hash" uri:"hash" binding:"required"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.