client

Documentation

Index

• type BaseClient
  • func NewBaseClient(baseURL string) *BaseClient
  • func (b *BaseClient) Bind(body []byte, rv interface{}) error
  • func (b *BaseClient) Post(url string, pv interface{}) (*fasthttp.Response, error)
  • func (b *BaseClient) Put(url string, pv interface{}) (*fasthttp.Response, error)
• type ElasticsearchAPIClient
  • func NewElasticsearchAPI(client string) (*ElasticsearchAPIClient, error)
  • func (es *ElasticsearchAPIClient) CreateMonitors(preparedMonitors map[string]model.Monitor) []model.UpdateMonitorResponse
  • func (es *ElasticsearchAPIClient) FetchDestinations() (map[string]model.Destination, error)
  • func (es *ElasticsearchAPIClient) FetchMonitors() (map[string]model.Monitor, mapset.Set, error)
  • func (es *ElasticsearchAPIClient) UpdateMonitors(preparedMonitors map[string]model.Monitor) []model.UpdateMonitorResponse
• type ElasticsearchAPIClientInterface
• type ElasticsearchQuery

Types

type BaseClient

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

func NewBaseClient

func NewBaseClient(baseURL string) *BaseClient

func (*BaseClient) Bind

func (b *BaseClient) Bind(body []byte, rv interface{}) error

func (*BaseClient) Post

func (b *BaseClient) Post(url string, pv interface{}) (*fasthttp.Response, error)

func (*BaseClient) Put

func (b *BaseClient) Put(url string, pv interface{}) (*fasthttp.Response, error)

type ElasticsearchAPIClient

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

func NewElasticsearchAPI

func NewElasticsearchAPI(client string) (*ElasticsearchAPIClient, error)

func (*ElasticsearchAPIClient) CreateMonitors

func (es *ElasticsearchAPIClient) CreateMonitors(preparedMonitors map[string]model.Monitor) []model.UpdateMonitorResponse

func (*ElasticsearchAPIClient) FetchDestinations

func (es *ElasticsearchAPIClient) FetchDestinations() (map[string]model.Destination, error)

func (*ElasticsearchAPIClient) FetchMonitors

func (es *ElasticsearchAPIClient) FetchMonitors() (map[string]model.Monitor, mapset.Set, error)

func (*ElasticsearchAPIClient) UpdateMonitors

func (es *ElasticsearchAPIClient) UpdateMonitors(preparedMonitors map[string]model.Monitor) []model.UpdateMonitorResponse

type ElasticsearchAPIClientInterface

type ElasticsearchAPIClientInterface interface {
	FetchDestinations() (map[string]model.Destination, error)
	FetchMonitors() (map[string]model.Monitor, mapset.Set, error)
	UpdateMonitors(preparedMonitors map[string]model.Monitor) []model.UpdateMonitorResponse
	CreateMonitors(monitors map[string]model.Monitor) []model.UpdateMonitorResponse
}

type ElasticsearchQuery

type ElasticsearchQuery map[string]interface{}