indices

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, opniCluster *v1beta1.OpniCluster, c client.Client) *Reconciler
  • func (r *Reconciler) Reconcile() (retResult *reconcile.Result, retErr error)

Constants

const (
	ISMChangeVersion = "1.1.0"
)

Types

type ExtendedClient

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

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, opniCluster *v1beta1.OpniCluster, c client.Client) *Reconciler

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile() (retResult *reconcile.Result, retErr error)