api

Documentation

Index

• type ClusterAPI
  • func (a *ClusterAPI) GetClusterHealth(ctx context.Context) (*Response, error)
• type ISMApi
  • func (c *ISMApi) CreateISM(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (c *ISMApi) GetISM(ctx context.Context, name string) (*Response, error)
  • func (c *ISMApi) UpdateISM(ctx context.Context, name string, body io.Reader, seqNo int, primaryTerm int) (*Response, error)
• type IndicesAPI
  • func (a *IndicesAPI) AddDocument(ctx context.Context, index, documentID string, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) AsyncDeleteByQuery(ctx context.Context, indices []string, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) CatIndices(ctx context.Context, indices []string) (*Response, error)
  • func (a *IndicesAPI) CreateIndex(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) DeleteIndexTemplate(ctx context.Context, name string) (*Response, error)
  • func (a *IndicesAPI) DeleteIndices(ctx context.Context, names []string) (*Response, error)
  • func (a *IndicesAPI) GetDocument(ctx context.Context, index, documentID string) (*Response, error)
  • func (a *IndicesAPI) GetIndexTemplates(ctx context.Context, names []string) (*Response, error)
  • func (a *IndicesAPI) PutIndexTemplate(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) SynchronousReindex(ctx context.Context, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) UpdateAlias(ctx context.Context, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) UpdateDocument(ctx context.Context, index, documentID string, body io.Reader) (*Response, error)
  • func (a *IndicesAPI) UpdateIndicesSettings(ctx context.Context, indices []string, body io.Reader) (*Response, error)
• type IngestAPI
  • func (a *IngestAPI) DeleteIngestPipeline(ctx context.Context, pipelineID string) (*Response, error)
  • func (a *IngestAPI) GetIngestPipeline(ctx context.Context, pipelineID string) (*Response, error)
  • func (a *IngestAPI) PutIngestTemplate(ctx context.Context, pipelineID string, body io.Reader) (*Response, error)
• type Response
  • func (r *Response) IsError() bool
  • func (r *Response) String() string
• type SecurityAPI
  • func (c *SecurityAPI) CreateRole(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (c *SecurityAPI) CreateRolesMapping(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (c *SecurityAPI) CreateUser(ctx context.Context, name string, body io.Reader) (*Response, error)
  • func (c *SecurityAPI) DeleteRole(ctx context.Context, name string) (*Response, error)
  • func (c *SecurityAPI) DeleteRolesMapping(ctx context.Context, name string) (*Response, error)
  • func (c *SecurityAPI) DeleteUser(ctx context.Context, name string) (*Response, error)
  • func (c *SecurityAPI) GetRole(ctx context.Context, name string) (*Response, error)
  • func (c *SecurityAPI) GetRolesMapping(ctx context.Context, name string) (*Response, error)
  • func (c *SecurityAPI) GetUser(ctx context.Context, name string) (*Response, error)
• type TasksAPI
  • func (a *TasksAPI) GetTask(ctx context.Context, id string) (*Response, error)

Types

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

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) 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 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)