executewatch

Documentation

Overview

Forces the execution of a stored watch.

Index

• Variables
• type ExecuteWatch
  • func New(tp elastictransport.Interface) *ExecuteWatch
  • func (r *ExecuteWatch) ActionModes(actionmodes map[string]actionexecutionmode.ActionExecutionMode) *ExecuteWatch
  • func (r *ExecuteWatch) AlternativeInput(alternativeinput map[string]json.RawMessage) *ExecuteWatch
  • func (r *ExecuteWatch) Debug(debug bool) *ExecuteWatch
  • func (r ExecuteWatch) Do(ctx context.Context) (*Response, error)
  • func (r *ExecuteWatch) Header(key, value string) *ExecuteWatch
  • func (r *ExecuteWatch) HttpRequest(ctx context.Context) (*http.Request, error)
  • func (r *ExecuteWatch) Id(id string) *ExecuteWatch
  • func (r *ExecuteWatch) IgnoreCondition(ignorecondition bool) *ExecuteWatch
  • func (r ExecuteWatch) Perform(ctx context.Context) (*http.Response, error)
  • func (r *ExecuteWatch) Raw(raw io.Reader) *ExecuteWatch
  • func (r *ExecuteWatch) RecordExecution(recordexecution bool) *ExecuteWatch
  • func (r *ExecuteWatch) Request(req *Request) *ExecuteWatch
  • func (r *ExecuteWatch) SimulatedActions(simulatedactions *types.SimulatedActions) *ExecuteWatch
  • func (r *ExecuteWatch) TriggerData(triggerdata *types.ScheduleTriggerEvent) *ExecuteWatch
  • func (r *ExecuteWatch) Watch(watch *types.Watch) *ExecuteWatch
• type NewExecuteWatch
  • func NewExecuteWatchFunc(tp elastictransport.Interface) NewExecuteWatch
• type Request
  • func NewRequest() *Request
  • func (r *Request) FromJSON(data string) (*Request, error)
• type Response
  • func NewResponse() *Response

Variables

var ErrBuildPath = errors.New("cannot build path, check for missing path parameters")

ErrBuildPath is returned in case of missing parameters within the build of the request.

Types

type ExecuteWatch

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

func New

func New(tp elastictransport.Interface) *ExecuteWatch

Forces the execution of a stored watch.

https://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-execute-watch.html

func (*ExecuteWatch) ActionModes

func (r *ExecuteWatch) ActionModes(actionmodes map[string]actionexecutionmode.ActionExecutionMode) *ExecuteWatch

ActionModes Determines how to handle the watch actions as part of the watch execution. API name: action_modes

func (*ExecuteWatch) AlternativeInput

func (r *ExecuteWatch) AlternativeInput(alternativeinput map[string]json.RawMessage) *ExecuteWatch

AlternativeInput When present, the watch uses this object as a payload instead of executing its own input. API name: alternative_input

func (*ExecuteWatch) Debug

func (r *ExecuteWatch) Debug(debug bool) *ExecuteWatch

Debug Defines whether the watch runs in debug mode. API name: debug

func (ExecuteWatch) Do

func (r ExecuteWatch) Do(ctx context.Context) (*Response, error)

Do runs the request through the transport, handle the response and returns a executewatch.Response

func (*ExecuteWatch) Header

func (r *ExecuteWatch) Header(key, value string) *ExecuteWatch

Header set a key, value pair in the ExecuteWatch headers map.

func (*ExecuteWatch) HttpRequest

func (r *ExecuteWatch) HttpRequest(ctx context.Context) (*http.Request, error)

HttpRequest returns the http.Request object built from the given parameters.

func (*ExecuteWatch) Id

func (r *ExecuteWatch) Id(id string) *ExecuteWatch

Id Identifier for the watch. API Name: id

func (*ExecuteWatch) IgnoreCondition

func (r *ExecuteWatch) IgnoreCondition(ignorecondition bool) *ExecuteWatch

IgnoreCondition When set to `true`, the watch execution uses the always condition. This can also be specified as an HTTP parameter. API name: ignore_condition

func (ExecuteWatch) Perform

func (r ExecuteWatch) Perform(ctx context.Context) (*http.Response, error)

Perform runs the http.Request through the provided transport and returns an http.Response.

func (*ExecuteWatch) Raw

func (r *ExecuteWatch) Raw(raw io.Reader) *ExecuteWatch

Raw takes a json payload as input which is then passed to the http.Request If specified Raw takes precedence on Request method.

func (*ExecuteWatch) RecordExecution

func (r *ExecuteWatch) RecordExecution(recordexecution bool) *ExecuteWatch

RecordExecution When set to `true`, the watch record representing the watch execution result is persisted to the `.watcher-history` index for the current time. In addition, the status of the watch is updated, possibly throttling subsequent executions. This can also be specified as an HTTP parameter. API name: record_execution

func (*ExecuteWatch) Request

func (r *ExecuteWatch) Request(req *Request) *ExecuteWatch

Request allows to set the request property with the appropriate payload.

func (*ExecuteWatch) SimulatedActions

func (r *ExecuteWatch) SimulatedActions(simulatedactions *types.SimulatedActions) *ExecuteWatch

API name: simulated_actions

func (*ExecuteWatch) TriggerData

func (r *ExecuteWatch) TriggerData(triggerdata *types.ScheduleTriggerEvent) *ExecuteWatch

TriggerData This structure is parsed as the data of the trigger event that will be used during the watch execution API name: trigger_data

func (*ExecuteWatch) Watch

func (r *ExecuteWatch) Watch(watch *types.Watch) *ExecuteWatch

Watch When present, this watch is used instead of the one specified in the request. This watch is not persisted to the index and record_execution cannot be set. API name: watch

type NewExecuteWatch

type NewExecuteWatch func() *ExecuteWatch

NewExecuteWatch type alias for index.

func NewExecuteWatchFunc

func NewExecuteWatchFunc(tp elastictransport.Interface) NewExecuteWatch

NewExecuteWatchFunc returns a new instance of ExecuteWatch with the provided transport. Used in the index of the library this allows to retrieve every apis in once place.

type Request

type Request struct {

	// ActionModes Determines how to handle the watch actions as part of the watch execution.
	ActionModes map[string]actionexecutionmode.ActionExecutionMode `json:"action_modes,omitempty"`
	// AlternativeInput When present, the watch uses this object as a payload instead of executing
	// its own input.
	AlternativeInput map[string]json.RawMessage `json:"alternative_input,omitempty"`
	// IgnoreCondition When set to `true`, the watch execution uses the always condition. This can
	// also be specified as an HTTP parameter.
	IgnoreCondition *bool `json:"ignore_condition,omitempty"`
	// RecordExecution When set to `true`, the watch record representing the watch execution result
	// is persisted to the `.watcher-history` index for the current time. In
	// addition, the status of the watch is updated, possibly throttling subsequent
	// executions. This can also be specified as an HTTP parameter.
	RecordExecution  *bool                   `json:"record_execution,omitempty"`
	SimulatedActions *types.SimulatedActions `json:"simulated_actions,omitempty"`
	// TriggerData This structure is parsed as the data of the trigger event that will be used
	// during the watch execution
	TriggerData *types.ScheduleTriggerEvent `json:"trigger_data,omitempty"`
	// Watch When present, this watch is used instead of the one specified in the request.
	// This watch is not persisted to the index and record_execution cannot be set.
	Watch *types.Watch `json:"watch,omitempty"`
}

Request holds the request body struct for the package executewatch

https://github.com/elastic/elasticsearch-specification/blob/656080dee792f93a849cd7fbf566f528f858a5ea/specification/watcher/execute_watch/WatcherExecuteWatchRequest.ts#L28-L79

func NewRequest

func NewRequest() *Request

NewRequest returns a Request

func (*Request) FromJSON

func (r *Request) FromJSON(data string) (*Request, error)

FromJSON allows to load an arbitrary json into the request structure

type Response

type Response struct {
	Id_         string            `json:"_id"`
	WatchRecord types.WatchRecord `json:"watch_record"`
}

func NewResponse

func NewResponse() *Response

NewResponse returns a Response