stulbe

Documentation

Index

• Constants
• Variables
• type Config
• type Manager
  • func Initialize(manager *modules.Manager) (*Manager, error)
  • func (m *Manager) Close() error
  • func (m *Manager) ReceiveEvents() error
  • func (m *Manager) ReplicateKey(prefix string) error
  • func (m *Manager) ReplicateKeys(prefixes []string) error

Constants

const ConfigKey = "stulbe/config"

Variables

var (
	ErrNotAuthenticated = errors.New("not authenticated")
)

Types

type Config

type Config struct {
	Endpoint string `json:"endpoint"`
	Username string `json:"username"`
	AuthKey  string `json:"auth_key"`
}

type Manager

type Manager struct {
	Client *stulbe.Client
	// contains filtered or unexported fields
}

func Initialize

func Initialize(manager *modules.Manager) (*Manager, error)

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) ReceiveEvents

func (m *Manager) ReceiveEvents() error

func (*Manager) ReplicateKey

func (m *Manager) ReplicateKey(prefix string) error

func (*Manager) ReplicateKeys

func (m *Manager) ReplicateKeys(prefixes []string) error