kvstore

Documentation

Index

• Constants
• func NewK8sServiceDiscovery(namespace, labelSelector string) map[string]interface{}
• type Store
  • func New(namespace, labelSelector string) *Store
  • func (s *Store) NewDMap(name string) (olric.DMap, error)
  • func (s *Store) NewPubSub() (*olric.PubSub, error)
  • func (s *Store) Start(started chan struct{}) error
  • func (s *Store) Stop(ctx context.Context) error

Constants

const (
	PubSubChannel = "_apoxy_pubsub"
)

Functions

func NewK8sServiceDiscovery

func NewK8sServiceDiscovery(namespace, labelSelector string) map[string]interface{}

NewK8sServiceDiscovery creates a new k8s service discovery plugin.

Types

type Store

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

func New

func New(namespace, labelSelector string) *Store

New creates a new kvstore instance.

func (*Store) NewDMap

func (s *Store) NewDMap(name string) (olric.DMap, error)

NewDMap creates a new DMap.

func (*Store) NewPubSub

func (s *Store) NewPubSub() (*olric.PubSub, error)

func (*Store) Start

func (s *Store) Start(started chan struct{}) error

Start starts the kvstore. It returns an error if the kvstore fails to start. Uses background context created by New() method.

func (*Store) Stop

func (s *Store) Stop(ctx context.Context) error

Stop stops the kvstore.