watcher

Documentation

Index

• func WatcherAck(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherActivate(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherDeactivate(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherDelete(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherExecute(esClient *elastic7.Client, reader io.Reader, cmdOpts *opts.CommandOptions) error
• func WatcherGet(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherGetStats(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherList(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherPut(esClient *elastic7.Client, reader io.Reader, cmdOpts *opts.CommandOptions) error
• func WatcherServiceStart(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherServiceStop(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherShowActive(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• func WatcherShowInactive(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error
• type GetWatcherCountStruct
• type WatcherHits
• type WatcherListOutput
• type WatcherListReq
• type WatcherListRes
• type WatcherStateResponse

Functions

func WatcherAck

func WatcherAck(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherActivate

func WatcherActivate(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherDeactivate

func WatcherDeactivate(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherDelete

func WatcherDelete(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherExecute

func WatcherExecute(esClient *elastic7.Client, reader io.Reader, cmdOpts *opts.CommandOptions) error

func WatcherGet

func WatcherGet(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherGetStats

func WatcherGetStats(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherList

func WatcherList(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

List watchers present on the cluster

func WatcherPut

func WatcherPut(esClient *elastic7.Client, reader io.Reader, cmdOpts *opts.CommandOptions) error

func WatcherServiceStart

func WatcherServiceStart(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

/.watches/_search?filter_path=hits.hits._id

func WatcherServiceStop

func WatcherServiceStop(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherShowActive

func WatcherShowActive(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

func WatcherShowInactive

func WatcherShowInactive(esClient *elastic7.Client, cmdOpts *opts.CommandOptions) error

GET /.watches/_search?filter_path=hits.hits._id,hits.hits._source.status.state.active

Types

type GetWatcherCountStruct

type GetWatcherCountStruct struct {
	Count int `json:"count"`
}

type WatcherHits

type WatcherHits struct {
	ID string `json:"_id"`
}

key-containing struct necessary for WatcherListRes struct

type WatcherListOutput

type WatcherListOutput struct {
	Watchers []string `json:"watchers" yaml:"watchers"`
}

Output format for WatcherList function

type WatcherListReq

type WatcherListReq struct {
	Size int `json:"size"`
}

Request body to WatcherList function

type WatcherListRes

type WatcherListRes struct {
	Hits struct {
		Total struct {
			Value    int    `json:"value"`
			Relation string `json:"relation"`
		} `json:"total"`
		Hits []WatcherHits `json:"hits"`
	} `json:"hits"`
}

Expected response for WatcherList function

type WatcherStateResponse

type WatcherStateResponse struct {
	Hits struct {
		Hits []struct {
			ID     string `json:"_id"`
			Source struct {
				Status struct {
					State struct {
						Active bool `json:"active"`
					} `json:"state"`
				} `json:"status"`
			} `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}