redis

Documentation

Index

• Constants
• type Command
  • func NewCommand(cmd CommandName, consulState state.Consul) Command
  • func (c *Command) Name() CommandName
  • func (c *Command) String() string
• type CommandName
• type Config
• type Manager
  • func NewConnection(m *cli.Context) (*Manager, error)
  • func (m *Manager) CommandChWriter() chan<- Command
  • func (m *Manager) CommandRunner()
  • func (m *Manager) Config() Config
  • func (m *Manager) StateChReader() <-chan state.Redis

Constants

const (
	StartCommand       = CommandName("start")
	StopCommand        = CommandName("stop")
	RunAsSlaveCommand  = CommandName("run_as_slave")
	RunAsMasterCommand = CommandName("run_as_master")
)

Types

type Command

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

func NewCommand

func NewCommand(cmd CommandName, consulState state.Consul) Command

func (*Command) Name

func (c *Command) Name() CommandName

func (*Command) String

func (c *Command) String() string

type CommandName

type CommandName string

type Config

type Config struct {
	Address string // address (IP+Port) used to talk to Redis
}

type Manager

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

func NewConnection

func NewConnection(m *cli.Context) (*Manager, error)

func (*Manager) CommandChWriter

func (m *Manager) CommandChWriter() chan<- Command

func (*Manager) CommandRunner

func (m *Manager) CommandRunner()

func (*Manager) Config

func (m *Manager) Config() Config

func (*Manager) StateChReader

func (m *Manager) StateChReader() <-chan state.Redis