zookeeper

Documentation

Index

• type Options
• type Store
  • func NewStore(opt *Options) (*Store, error)
  • func (s *Store) Create(ctx context.Context, obj *types.RawObject, opt *store.CreateOptions) error
  • func (s *Store) Delete(ctx context.Context, obj *types.RawObject, opt *store.DeleteOptions) error
  • func (s *Store) Get(ctx context.Context, resourceType types.ObjectType, key types.ObjectKey, ...) (*types.RawObject, error)
  • func (s *Store) List(ctx context.Context, objectType types.ObjectType, opts *store.ListOptions) ([]*types.RawObject, error)
  • func (s *Store) Update(ctx context.Context, obj *types.RawObject, opt *store.UpdateOptions) error
  • func (s *Store) Watch(ctx context.Context, resourceType types.ObjectType, opts *store.WatchOptions) (chan *store.Event, error)

Types

type Options

type Options struct {
	BasePath              string
	Addrs                 []string
	ConnectTimeoutSeconds int
	Database              string
	Username              string
	Password              string
}

Options options for zookeeper store

type Store

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

Store client for zookeeper

func NewStore

func NewStore(opt *Options) (*Store, error)

NewStore create zk store

func (*Store) Create

func (s *Store) Create(ctx context.Context, obj *types.RawObject, opt *store.CreateOptions) error

Create implement Store

func (*Store) Delete

func (s *Store) Delete(ctx context.Context, obj *types.RawObject, opt *store.DeleteOptions) error

Delete implement Store

func (*Store) Get

func (s *Store) Get(ctx context.Context, resourceType types.ObjectType, key types.ObjectKey, opt *store.GetOptions) (
	*types.RawObject, error)

Get implement Store

func (*Store) List

func (s *Store) List(ctx context.Context, objectType types.ObjectType, opts *store.ListOptions) (
	[]*types.RawObject, error)

List implement Store

func (*Store) Update

func (s *Store) Update(ctx context.Context, obj *types.RawObject, opt *store.UpdateOptions) error

Update implement Store

func (*Store) Watch

func (s *Store) Watch(ctx context.Context, resourceType types.ObjectType, opts *store.WatchOptions) (
	chan *store.Event, error)

Watch implement Store