repository

Documentation

Index

• Constants
• Variables
• type EtcdRepository
  • func NewEtcdRepository(etcd *etcd.Etcd) *EtcdRepository
  • func (r *EtcdRepository) Publish(ctx context.Context, payload string) error
  • func (r *EtcdRepository) Subscribe(ctx context.Context, callback func(payload string))
  • func (r *EtcdRepository) Unsubscribe()
• type Keys
  • func (k Keys) GetNotifyChannel() string
• type PublishUpdateError
  • func (e PublishUpdateError) Error() string
• type RedisRepository
  • func NewRedisRepository(redis *rds.Redis) *RedisRepository
  • func (r *RedisRepository) Publish(ctx context.Context, payload string) error
  • func (r *RedisRepository) Subscribe(ctx context.Context, callback func(payload string))
  • func (r *RedisRepository) Unsubscribe()
• type Repository
  • func New(ctx context.Context, cfg RepositoryConfig) (Repository, error)
• type RepositoryConfig

Constants

const (
	NotifyPrefix = "configleam:notify"
)

Variables

var PubSubChannel = "channel"

Types

type EtcdRepository

type EtcdRepository struct {
	*etcd.Etcd
	// contains filtered or unexported fields
}

func NewEtcdRepository

func NewEtcdRepository(etcd *etcd.Etcd) *EtcdRepository

func (*EtcdRepository) Publish

func (r *EtcdRepository) Publish(ctx context.Context, payload string) error

Publish updates the value of a key, triggering notifications to watchers.

func (*EtcdRepository) Subscribe

func (r *EtcdRepository) Subscribe(ctx context.Context, callback func(payload string))

Subscribe watches changes on a specific key or prefix.

func (*EtcdRepository) Unsubscribe

func (r *EtcdRepository) Unsubscribe()

Unsubscribe might be more complex in an etcd context; it may involve canceling the context passed to the watch.

type Keys

type Keys struct{}

func (Keys) GetNotifyChannel

func (k Keys) GetNotifyChannel() string

type PublishUpdateError

type PublishUpdateError struct{}

func (PublishUpdateError) Error

func (e PublishUpdateError) Error() string

type RedisRepository

type RedisRepository struct {
	*rds.Redis
	// contains filtered or unexported fields
}

func NewRedisRepository

func NewRedisRepository(redis *rds.Redis) *RedisRepository

func (*RedisRepository) Publish

func (r *RedisRepository) Publish(ctx context.Context, payload string) error

func (*RedisRepository) Subscribe

func (r *RedisRepository) Subscribe(ctx context.Context, callback func(payload string))

func (*RedisRepository) Unsubscribe

func (r *RedisRepository) Unsubscribe()

type Repository

type Repository interface {
	Publish(ctx context.Context, payload string) error
	Subscribe(ctx context.Context, callback func(string))
	Unsubscribe()
}

func New

func New(ctx context.Context, cfg RepositoryConfig) (Repository, error)

type RepositoryConfig

type RepositoryConfig struct {
	RedisAddrs    string
	RedisUsername string
	RedisPassword string
	RedisTLS      bool

	EtcdAddrs    []string
	EtcdUsername string
	EtcdPassword string
	EtcdTLS      bool
}