store

Documentation

Index

• type Store
  • func NewEtcd2(endpoints []string, prefix string) (Store, error)
  • func NewEtcd3(endpoints []string, prefix string) (Store, error)
  • func NewStore(storeBackend string, endpoints []string, prefix string) (Store, error)

Types

type Store

type Store interface {
	GetService(ctx context.Context, serviceID string) (*types.VirtualService, error)
	PutService(context.Context, *types.VirtualService) error
	DeleteService(ctx context.Context, serviceID string) error
	GetServer(ctx context.Context, serviceID string, key *types.RealServer_Key) (*types.RealServer, error)
	PutServer(ctx context.Context, server *types.RealServer) error
	DeleteServer(ctx context.Context, serviceID string, key *types.RealServer_Key) error
	ListServices(context.Context) ([]*types.VirtualService, error)
	ListServers(ctx context.Context, serviceID string) ([]*types.RealServer, error)
	// Subscribe to changes. subscriber is called whenever a change occurs in the store.
	Subscribe(subscriber func(), stopCh <-chan struct{})
}

Store for saving desired IPVS state.

func NewEtcd2

func NewEtcd2(endpoints []string, prefix string) (Store, error)

NewEtcd2 returns a Store implementation using an etcd2 backing store.

func NewEtcd3

func NewEtcd3(endpoints []string, prefix string) (Store, error)

NewEtcd3 returns a Store implementation using an etcd3 backing store.

func NewStore

func NewStore(storeBackend string, endpoints []string, prefix string) (Store, error)

NewStore returns a Store implementation based upon the storeBackend parameter