api

package
v0.11.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 3, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlertAPI added in v0.11.0 

type AlertAPI struct {
	*opensearchtransport.Client
}

func (*AlertAPI) AcknowledgeAlert added in v0.11.0 

func (a *AlertAPI) AcknowledgeAlert(ctx context.Context, monitorId string, body io.Reader) (*Response, error)

func (*AlertAPI) ListAlerts added in v0.11.0 

func (a *AlertAPI) ListAlerts(ctx context.Context) (*Response, error)

type AlertingAPI added in v0.11.0 

type AlertingAPI struct {
	MonitorAPI
	NotificationAPI
	AlertAPI
}

type ClusterAPI 

type ClusterAPI struct {
	*opensearchtransport.Client
}

func (*ClusterAPI) GetClusterHealth 

func (a *ClusterAPI) GetClusterHealth(ctx context.Context) (*Response, error)

type ISMApi 

type ISMApi struct {
	*opensearchtransport.Client
}

func (*ISMApi) CreateISM 

func (c *ISMApi) CreateISM(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*ISMApi) GetISM 

func (c *ISMApi) GetISM(ctx context.Context, name string) (*Response, error)

func (*ISMApi) UpdateISM 

func (c *ISMApi) UpdateISM(ctx context.Context, name string, body io.Reader, seqNo int, primaryTerm int) (*Response, error)

type IndicesAPI 

type IndicesAPI struct {
	*opensearchtransport.Client
}

func (*IndicesAPI) AddDocument added in v0.9.1 

func (a *IndicesAPI) AddDocument(ctx context.Context, index, documentID string, body io.Reader) (*Response, error)

func (*IndicesAPI) AsyncDeleteByQuery 

func (a *IndicesAPI) AsyncDeleteByQuery(ctx context.Context, indices []string, body io.Reader) (*Response, error)

func (*IndicesAPI) CatIndices 

func (a *IndicesAPI) CatIndices(ctx context.Context, indices []string) (*Response, error)

func (*IndicesAPI) CreateIndex 

func (a *IndicesAPI) CreateIndex(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*IndicesAPI) DeleteByID added in v0.10.0 

func (a *IndicesAPI) DeleteByID(ctx context.Context, index, id string) (*Response, error)

func (*IndicesAPI) DeleteIndexTemplate 

func (a *IndicesAPI) DeleteIndexTemplate(ctx context.Context, name string) (*Response, error)

func (*IndicesAPI) DeleteIndices 

func (a *IndicesAPI) DeleteIndices(ctx context.Context, names []string) (*Response, error)

func (*IndicesAPI) GetDocument 

func (a *IndicesAPI) GetDocument(ctx context.Context, index, documentID string) (*Response, error)

func (*IndicesAPI) GetIndexTemplates 

func (a *IndicesAPI) GetIndexTemplates(ctx context.Context, names []string) (*Response, error)

func (*IndicesAPI) PutIndexTemplate 

func (a *IndicesAPI) PutIndexTemplate(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*IndicesAPI) SynchronousReindex 

func (a *IndicesAPI) SynchronousReindex(ctx context.Context, body io.Reader) (*Response, error)

func (*IndicesAPI) UpdateAlias 

func (a *IndicesAPI) UpdateAlias(ctx context.Context, body io.Reader) (*Response, error)

func (*IndicesAPI) UpdateDocument 

func (a *IndicesAPI) UpdateDocument(ctx context.Context, index, documentID string, body io.Reader) (*Response, error)

func (*IndicesAPI) UpdateIndicesSettings 

func (a *IndicesAPI) UpdateIndicesSettings(ctx context.Context, indices []string, body io.Reader) (*Response, error)

type IngestAPI 

type IngestAPI struct {
	*opensearchtransport.Client
}

func (*IngestAPI) DeleteIngestPipeline 

func (a *IngestAPI) DeleteIngestPipeline(ctx context.Context, pipelineID string) (*Response, error)

func (*IngestAPI) GetIngestPipeline 

func (a *IngestAPI) GetIngestPipeline(ctx context.Context, pipelineID string) (*Response, error)

func (*IngestAPI) PutIngestTemplate 

func (a *IngestAPI) PutIngestTemplate(ctx context.Context, pipelineID string, body io.Reader) (*Response, error)

type MonitorAPI added in v0.11.0 

type MonitorAPI struct {
	*opensearchtransport.Client
}

func (*MonitorAPI) CreateMonitor added in v0.11.0 

func (m *MonitorAPI) CreateMonitor(ctx context.Context, body io.Reader) (*Response, error)

func (*MonitorAPI) DeleteMonitor added in v0.11.0 

func (m *MonitorAPI) DeleteMonitor(ctx context.Context, monitorId string) (*Response, error)

func (*MonitorAPI) GetMonitor added in v0.11.0 

func (m *MonitorAPI) GetMonitor(ctx context.Context, monitorId string) (*Response, error)

func (*MonitorAPI) UpdateMonitor added in v0.11.0 

func (m *MonitorAPI) UpdateMonitor(ctx context.Context, monitorId string, body io.Reader) (*Response, error)

type NotificationAPI added in v0.11.0 

type NotificationAPI struct {
	*opensearchtransport.Client
}

func (*NotificationAPI) CreateNotification added in v0.11.0 

func (d *NotificationAPI) CreateNotification(ctx context.Context, body io.Reader) (*Response, error)

func (*NotificationAPI) DeleteNotification added in v0.11.0 

func (d *NotificationAPI) DeleteNotification(ctx context.Context, channelId string) (*Response, error)

func (*NotificationAPI) GetNotification added in v0.11.0 

func (d *NotificationAPI) GetNotification(ctx context.Context, channelId string) (*Response, error)

func (*NotificationAPI) ListNotifications added in v0.11.0 

func (d *NotificationAPI) ListNotifications(ctx context.Context) (*Response, error)

func (*NotificationAPI) UpdateNotification added in v0.11.0 

func (d *NotificationAPI) UpdateNotification(ctx context.Context, channelId string, body io.Reader) (*Response, error)

type Response 

type Response http.Response

func (*Response) IsError 

func (r *Response) IsError() bool

func (*Response) String 

func (r *Response) String() string

type SecurityAPI 

type SecurityAPI struct {
	*opensearchtransport.Client
}

func (*SecurityAPI) CreateRole 

func (c *SecurityAPI) CreateRole(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*SecurityAPI) CreateRolesMapping 

func (c *SecurityAPI) CreateRolesMapping(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*SecurityAPI) CreateUser 

func (c *SecurityAPI) CreateUser(ctx context.Context, name string, body io.Reader) (*Response, error)

func (*SecurityAPI) DeleteRole 

func (c *SecurityAPI) DeleteRole(ctx context.Context, name string) (*Response, error)

func (*SecurityAPI) DeleteRolesMapping 

func (c *SecurityAPI) DeleteRolesMapping(ctx context.Context, name string) (*Response, error)

func (*SecurityAPI) DeleteUser 

func (c *SecurityAPI) DeleteUser(ctx context.Context, name string) (*Response, error)

func (*SecurityAPI) GetRole 

func (c *SecurityAPI) GetRole(ctx context.Context, name string) (*Response, error)

func (*SecurityAPI) GetRolesMapping 

func (c *SecurityAPI) GetRolesMapping(ctx context.Context, name string) (*Response, error)

func (*SecurityAPI) GetUser 

func (c *SecurityAPI) GetUser(ctx context.Context, name string) (*Response, error)

type TasksAPI 

type TasksAPI struct {
	*opensearchtransport.Client
}

func (*TasksAPI) GetTask 

func (a *TasksAPI) GetTask(ctx context.Context, id string) (*Response, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳