opensearch

Documentation

Index

• Constants
• type ExtendedClient
• type ISMApi
  • func (c *ISMApi) CreateISM(ctx context.Context, name string, body io.Reader) (*opensearchapi.Response, error)
  • func (c *ISMApi) GetISM(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *ISMApi) UpdateISM(ctx context.Context, name string, body io.Reader, seqNo int, primaryTerm int) (*opensearchapi.Response, error)
• type Reconciler
  • func NewReconciler(ctx context.Context, namespace string, username string, password string, ...) *Reconciler
  • func (r *Reconciler) ImportKibanaObjects(indexName string, docID string, version string, kibanaObjects string) error
  • func (r *Reconciler) MaybeBootstrapIndex(prefix string, alias string, oldPrefixes []string) error
  • func (r *Reconciler) MaybeCreateIndex(name string, settings map[string]opensearchapiext.TemplateMappingsSpec) error
  • func (r *Reconciler) MaybeCreateIndexTemplate(template opensearchapiext.IndexTemplateSpec) error
  • func (r *Reconciler) MaybeCreateIngestPipeline(name string, pipeline opensearchapiext.IngestPipeline) error
  • func (r *Reconciler) MaybeCreateRole(role opensearchapiext.RoleSpec) error
  • func (r *Reconciler) MaybeCreateUser(user opensearchapiext.UserSpec) error
  • func (r *Reconciler) MaybeDeleteIndexTemplate(name string) error
  • func (r *Reconciler) MaybeDeleteIngestPipeline(name string) error
  • func (r *Reconciler) MaybeDeleteRole(rolename string) error
  • func (r *Reconciler) MaybeDeleteUser(username string) error
  • func (r *Reconciler) MaybeRemoveRolesMapping(roleName string, userName string) error
  • func (r *Reconciler) MaybeUpdateRolesMapping(roleName string, userName string) error
  • func (r *Reconciler) ReconcileISM(policy interface{}) error
  • func (r *Reconciler) UpdateDefaultIngestPipelineForIndex(index string, pipelineName string) error
• type SecurityAPI
  • func (c *SecurityAPI) CreateRole(ctx context.Context, name string, body io.Reader) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) CreateRolesMapping(ctx context.Context, name string, body io.Reader) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) CreateUser(ctx context.Context, name string, body io.Reader) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) DeleteRole(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) DeleteRolesMapping(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) DeleteUser(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) GetRole(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) GetRolesMapping(ctx context.Context, name string) (*opensearchapi.Response, error)
  • func (c *SecurityAPI) GetUser(ctx context.Context, name string) (*opensearchapi.Response, error)

Constants

const (
	ISMChangeVersion = "1.1.0"
)

Types

type ExtendedClient

type ExtendedClient struct {
	*opensearch.Client
	ISM      *ISMApi
	Security *SecurityAPI
}

type ISMApi

type ISMApi struct {
	*opensearch.Client
}

func (*ISMApi) CreateISM

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

func (*ISMApi) GetISM

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

func (*ISMApi) UpdateISM

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

type Reconciler

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

func NewReconciler

func NewReconciler(
	ctx context.Context,
	namespace string,
	username string,
	password string,
	osServiceName string,
	kbServiceName string,
) *Reconciler

func (*Reconciler) ImportKibanaObjects

func (r *Reconciler) ImportKibanaObjects(indexName string, docID string, version string, kibanaObjects string) error

func (*Reconciler) MaybeBootstrapIndex

func (r *Reconciler) MaybeBootstrapIndex(prefix string, alias string, oldPrefixes []string) error

func (*Reconciler) MaybeCreateIndex

func (r *Reconciler) MaybeCreateIndex(name string, settings map[string]opensearchapiext.TemplateMappingsSpec) error

func (*Reconciler) MaybeCreateIndexTemplate

func (r *Reconciler) MaybeCreateIndexTemplate(template opensearchapiext.IndexTemplateSpec) error

func (*Reconciler) MaybeCreateIngestPipeline

func (r *Reconciler) MaybeCreateIngestPipeline(name string, pipeline opensearchapiext.IngestPipeline) error

func (*Reconciler) MaybeCreateRole

func (r *Reconciler) MaybeCreateRole(role opensearchapiext.RoleSpec) error

func (*Reconciler) MaybeCreateUser

func (r *Reconciler) MaybeCreateUser(user opensearchapiext.UserSpec) error

func (*Reconciler) MaybeDeleteIndexTemplate

func (r *Reconciler) MaybeDeleteIndexTemplate(name string) error

func (*Reconciler) MaybeDeleteIngestPipeline

func (r *Reconciler) MaybeDeleteIngestPipeline(name string) error

func (*Reconciler) MaybeDeleteRole

func (r *Reconciler) MaybeDeleteRole(rolename string) error

func (*Reconciler) MaybeDeleteUser

func (r *Reconciler) MaybeDeleteUser(username string) error

func (*Reconciler) MaybeRemoveRolesMapping

func (r *Reconciler) MaybeRemoveRolesMapping(roleName string, userName string) error

func (*Reconciler) MaybeUpdateRolesMapping

func (r *Reconciler) MaybeUpdateRolesMapping(roleName string, userName string) error

func (*Reconciler) ReconcileISM

func (r *Reconciler) ReconcileISM(policy interface{}) error

func (*Reconciler) UpdateDefaultIngestPipelineForIndex

func (r *Reconciler) UpdateDefaultIngestPipelineForIndex(index string, pipelineName string) error

type SecurityAPI

type SecurityAPI struct {
	*opensearch.Client
}

func (*SecurityAPI) CreateRole

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

func (*SecurityAPI) CreateRolesMapping

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

func (*SecurityAPI) CreateUser

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

func (*SecurityAPI) DeleteRole

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

func (*SecurityAPI) DeleteRolesMapping

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

func (*SecurityAPI) DeleteUser

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

func (*SecurityAPI) GetRole

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

func (*SecurityAPI) GetRolesMapping

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

func (*SecurityAPI) GetUser

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