api

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 9 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 SnapshotAPI added in v0.11.2 

type SnapshotAPI struct {
	*opensearchtransport.Client
}

func (*SnapshotAPI) CreateSnapshot added in v0.11.2 

func (a *SnapshotAPI) CreateSnapshot(
	ctx context.Context,
	name, repository string,
	body io.Reader,
	wait bool,
) (*Response, error)

func (*SnapshotAPI) CreateSnapshotPolicy added in v0.11.2 

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

func (*SnapshotAPI) DeleteRepository added in v0.11.2 

func (a *SnapshotAPI) DeleteRepository(ctx context.Context, name string) (*Response, error)

func (*SnapshotAPI) DeleteSnapshot added in v0.11.2 

func (a *SnapshotAPI) DeleteSnapshot(ctx context.Context, name, repository string) (*Response, error)

func (*SnapshotAPI) DeleteSnapshotPolicy added in v0.11.2 

func (a *SnapshotAPI) DeleteSnapshotPolicy(ctx context.Context, name string) (*Response, error)

func (*SnapshotAPI) ExplainSnapshotPolicy added in v0.11.2 

func (a *SnapshotAPI) ExplainSnapshotPolicy(ctx context.Context, name string) (*Response, error)

func (*SnapshotAPI) GetRepository added in v0.11.2 

func (a *SnapshotAPI) GetRepository(ctx context.Context, name string) (*Response, error)

func (*SnapshotAPI) GetSnapshot added in v0.11.2 

func (a *SnapshotAPI) GetSnapshot(ctx context.Context, name, repository string) (*Response, error)

func (*SnapshotAPI) GetSnapshotPolicy added in v0.11.2 

func (a *SnapshotAPI) GetSnapshotPolicy(ctx context.Context, name string) (*Response, error)

func (*SnapshotAPI) PutRepository added in v0.11.2 

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

func (*SnapshotAPI) UpdateSnapshotPolicy added in v0.11.2 

func (a *SnapshotAPI) UpdateSnapshotPolicy(
	ctx context.Context,
	name string,
	seqNo int,
	primaryTerm int,
	body io.Reader,
) (*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.