opensearch

package

v0.5.4-rc7 Latest Latest Go to latest Published: Jul 24, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rancher/opni

Documentation ¶

Index ¶

Constants
type ExtendedClient
type ISMApi
type Reconciler
- func NewReconciler(ctx context.Context, namespace string, username string, password string, ...) *Reconciler
type SecurityAPI

Constants ¶

View Source

const (
	ISMChangeVersion = "1.1.0"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.5.0

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 ¶ added in v0.5.0

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

func (*Reconciler) MaybeDeleteIngestPipeline ¶ added in v0.5.0

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

func (*Reconciler) MaybeDeleteRole ¶ added in v0.4.0

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

func (*Reconciler) MaybeDeleteUser ¶ added in v0.4.0

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

func (*Reconciler) MaybeRemoveRolesMapping ¶ added in v0.4.0

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) TemplateExists ¶ added in v0.5.4

func (r *Reconciler) TemplateExists(name string) (bool, error)

func (*Reconciler) UpdateDefaultIngestPipelineForIndex ¶ added in v0.5.0

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 ¶ added in v0.4.0

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

func (*SecurityAPI) DeleteRolesMapping ¶ added in v0.4.0

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

func (*SecurityAPI) DeleteUser ¶ added in v0.4.0

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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
types

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL