backendstore

Documentation

Index

• func AddBackend(cluster string, cfg *v1alpha1.BackendStoreConfig)
• func DeleteBackend(cluster string)
• func Init(cs *kubernetes.Clientset)
• type BackendStore
  • func GetBackend(cluster string) BackendStore
• type Default
  • func NewDefaultBackend(cluster string) *Default
  • func (*Default) Close()
  • func (d *Default) ResourceEventHandlerFuncs() cache.ResourceEventHandler
• type OpenSearch
  • func NewOpenSearch(cluster string, cfg *v1alpha1.BackendStoreConfig) (*OpenSearch, error)
  • func (os *OpenSearch) Close()
  • func (os *OpenSearch) ResourceEventHandlerFuncs() cache.ResourceEventHandler

Functions

func AddBackend

func AddBackend(cluster string, cfg *v1alpha1.BackendStoreConfig)

AddBackend add backend store

func DeleteBackend

func DeleteBackend(cluster string)

DeleteBackend delete backend store

func Init

func Init(cs *kubernetes.Clientset)

Init init backend store manager

Types

type BackendStore

type BackendStore interface {
	ResourceEventHandlerFuncs() cache.ResourceEventHandler
	Close()
}

BackendStore define BackendStore interface

func GetBackend

func GetBackend(cluster string) BackendStore

GetBackend get backend store

type Default

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

Default is the default BackendStore

func NewDefaultBackend

func NewDefaultBackend(cluster string) *Default

NewDefaultBackend create a new default BackendStore

func (*Default) Close

func (*Default) Close()

Close close the BackendStore

func (*Default) ResourceEventHandlerFuncs

func (d *Default) ResourceEventHandlerFuncs() cache.ResourceEventHandler

ResourceEventHandlerFuncs return the ResourceEventHandlerFuncs

type OpenSearch

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

OpenSearch implements backendstore.BackendStore

func NewOpenSearch

func NewOpenSearch(cluster string, cfg *v1alpha1.BackendStoreConfig) (*OpenSearch, error)

NewOpenSearch returns a new OpenSearch

func (*OpenSearch) Close

func (os *OpenSearch) Close()

Close the client

func (*OpenSearch) ResourceEventHandlerFuncs

func (os *OpenSearch) ResourceEventHandlerFuncs() cache.ResourceEventHandler

ResourceEventHandlerFuncs implements cache.ResourceEventHandler