hacli

Documentation

Index

• Constants
• type HAKeeperClientManager
  • func NewManager(kubeCli client.Client, logger logr.Logger) *HAKeeperClientManager
  • func (m *HAKeeperClientManager) Close()
  • func (m *HAKeeperClientManager) GetClient(ls *v1alpha1.LogSet) (*Handler, error)
• type Handler
  • func (h *Handler) Close() error
• type StoreCache
  • func NewCNCache(client logservice.ProxyHAKeeperClient, refreshInterval time.Duration, ...) *StoreCache
  • func (c *StoreCache) Close()
  • func (c *StoreCache) GetCN(uuid string) (metadata.CNService, bool)

Constants

const (
	HAKeeperTimeout = 2 * time.Second

	RefreshInterval = 15 * time.Second
)

Types

type HAKeeperClientManager

type HAKeeperClientManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewManager

func NewManager(kubeCli client.Client, logger logr.Logger) *HAKeeperClientManager

func (*HAKeeperClientManager) Close

func (m *HAKeeperClientManager) Close()

func (*HAKeeperClientManager) GetClient

func (m *HAKeeperClientManager) GetClient(ls *v1alpha1.LogSet) (*Handler, error)

type Handler

type Handler struct {
	Client     logservice.ProxyHAKeeperClient
	StoreCache *StoreCache
}

func (*Handler) Close

func (h *Handler) Close() error

type StoreCache

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

func NewCNCache

func NewCNCache(
	client logservice.ProxyHAKeeperClient,
	refreshInterval time.Duration,
	logger logr.Logger) *StoreCache

func (*StoreCache) Close

func (c *StoreCache) Close()

func (*StoreCache) GetCN

func (c *StoreCache) GetCN(uuid string) (metadata.CNService, bool)