etcd

Documentation

Index

• type Registry
  • func NewRegistry(client *clientv3.Client, logger *log.Logger, namespace string) (*Registry, error)
  • func (r *Registry) Close() error
  • func (r *Registry) Create(backendName, topicName string) error
  • func (r *Registry) RegisterBackend(name string, backend lobby.Backend)
  • func (r *Registry) Topic(name string) (lobby.Topic, error)

Types

type Registry

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

Registry is an etcd registry.

func NewRegistry

func NewRegistry(client *clientv3.Client, logger *log.Logger, namespace string) (*Registry, error)

NewRegistry returns an etcd Registry.

func (*Registry) Close

func (r *Registry) Close() error

Close etcd connection and registered backends.

func (*Registry) Create

func (r *Registry) Create(backendName, topicName string) error

Create a topic in the registry.

func (*Registry) RegisterBackend

func (r *Registry) RegisterBackend(name string, backend lobby.Backend)

RegisterBackend registers a backend under the given name.

func (*Registry) Topic

func (r *Registry) Topic(name string) (lobby.Topic, error)

Topic returns the selected topic from the Backend.