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) (*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(v string) *PutWatch
  • func (r *PutWatch) IfSeqNo(v string) *PutWatch
  • func (r PutWatch) Perform(ctx context.Context) (*http.Response, error)
  • func (r *PutWatch) Raw(raw io.Reader) *PutWatch
  • func (r *PutWatch) Request(req *Request) *PutWatch
  • func (r *PutWatch) Version(v string) *PutWatch
• 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 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) (*Response, error)

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

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(v 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(v 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) Perform

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

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

func (*PutWatch) Raw

func (r *PutWatch) Raw(raw io.Reader) *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(v 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]json.RawMessage     `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/1ad7fe36297b3a8e187b2259dedaf68a47bc236e/specification/watcher/put_watch/WatcherPutWatchRequest.ts#L30-L54

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 {
	Created      bool   `json:"created"`
	Id_          string `json:"_id"`
	PrimaryTerm_ int64  `json:"_primary_term"`
	SeqNo_       int64  `json:"_seq_no"`
	Version_     int64  `json:"_version"`
}

func NewResponse

func NewResponse() *Response

NewResponse returns a Response