store

Documentation

Index

• func SetClient(factory Factory)
• type EtcdModifyEventFunc
• type Factory
  • func Client() Factory
• type NsqStore

Functions

func SetClient

func SetClient(factory Factory)

SetClient sets the consumer store client.

Types

type EtcdModifyEventFunc

type EtcdModifyEventFunc func(ctx context.Context, key, oldvalue, value []byte)

EtcdModifyEventFunc defines etcd update event function handler.

type Factory

type Factory interface {
	Nsqs() NsqStore
	GetKey(string) string
	Watch(context.Context, string, EtcdModifyEventFunc) error
	Close() error
}

Factory defines the consumer storage interface.

func Client

func Client() Factory

Client returns the store client instance.

type NsqStore

type NsqStore interface {
	Get(ctx context.Context, key string) (*genericoptions.NsqOptions, error)
	GetKey(key string) string
}