putwatch

Documentation

Overview

Creates a new watch, or updates an existing one.

Index

• Variables
• type NewPutWatch
  • func NewPutWatchFunc(tp elastictransport.Interface) NewPutWatch
• type PutWatch
  • func New(tp elastictransport.Interface) *PutWatch
  • func (r *PutWatch) Active(b bool) *PutWatch
  • func (r PutWatch) Do(ctx context.Context) (*http.Response, error)
  • func (r *PutWatch) Header(key, value string) *PutWatch
  • func (r *PutWatch) HttpRequest(ctx context.Context) (*http.Request, error)
  • func (r *PutWatch) Id(v string) *PutWatch
  • func (r *PutWatch) IfPrimaryTerm(value string) *PutWatch
  • func (r *PutWatch) IfSeqNo(value string) *PutWatch
  • func (r *PutWatch) Raw(raw json.RawMessage) *PutWatch
  • func (r *PutWatch) Request(req *Request) *PutWatch
  • func (r *PutWatch) Version(value string) *PutWatch
• type Request
  • func NewRequest() *Request
  • func (rb *Request) FromJSON(data string) (*Request, error)

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 NewPutWatch

type NewPutWatch func(id string) *PutWatch

NewPutWatch type alias for index.

func NewPutWatchFunc

func NewPutWatchFunc(tp elastictransport.Interface) NewPutWatch

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

type PutWatch

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

func New

func New(tp elastictransport.Interface) *PutWatch

Creates a new watch, or updates an existing one.

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

func (*PutWatch) Active

func (r *PutWatch) Active(b bool) *PutWatch

Active Specify whether the watch is in/active by default API name: active

func (PutWatch) Do

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

Do runs the http.Request through the provided transport.

func (*PutWatch) Header

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

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

func (*PutWatch) HttpRequest

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

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

func (*PutWatch) Id

func (r *PutWatch) Id(v string) *PutWatch

Id Watch ID API Name: id

func (*PutWatch) IfPrimaryTerm

func (r *PutWatch) IfPrimaryTerm(value string) *PutWatch

IfPrimaryTerm only update the watch if the last operation that has changed the watch has the specified primary term API name: if_primary_term

func (*PutWatch) IfSeqNo

func (r *PutWatch) IfSeqNo(value string) *PutWatch

IfSeqNo only update the watch if the last operation that has changed the watch has the specified sequence number API name: if_seq_no

func (*PutWatch) Raw

func (r *PutWatch) Raw(raw json.RawMessage) *PutWatch

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

func (*PutWatch) Request

func (r *PutWatch) Request(req *Request) *PutWatch

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

func (*PutWatch) Version

func (r *PutWatch) Version(value string) *PutWatch

Version Explicit version number for concurrency control API name: version

type Request

type Request struct {
	Actions        map[string]types.WatcherAction `json:"actions,omitempty"`
	Condition      *types.WatcherCondition        `json:"condition,omitempty"`
	Input          *types.WatcherInput            `json:"input,omitempty"`
	Metadata       map[string]interface{}         `json:"metadata,omitempty"`
	ThrottlePeriod *string                        `json:"throttle_period,omitempty"`
	Transform      *types.TransformContainer      `json:"transform,omitempty"`
	Trigger        *types.TriggerContainer        `json:"trigger,omitempty"`
}

Request holds the request body struct for the package putwatch

https://github.com/elastic/elasticsearch-specification/blob/7f49eec1f23a5ae155001c058b3196d85981d5c2/specification/watcher/put_watch/WatcherPutWatchRequest.ts#L30-L54

func NewRequest

func NewRequest() *Request

NewRequest returns a Request

func (*Request) FromJSON

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

FromJSON allows to load an arbitrary json into the request structure