actor

Documentation

Index

• type Actor
• type ActorManager
  • func NewActorManager() *ActorManager
  • func (m *ActorManager) Add(a Actor) error
  • func (m *ActorManager) All(cmd Command) (ret [][]Actor)
  • func (m *ActorManager) Get(cmd Command) []Actor
• type ActorResult
  • func NewResult(cmd Command) *ActorResult
  • func NewResultWithError(cmd Command, err error) *ActorResult
  • func NewResultWithValue(cmd Command, val interface{}) *ActorResult
  • func (c *ActorResult) Err() error
  • func (c *ActorResult) NextCommand() Command
  • func (c *ActorResult) Result() interface{}
• type Command

Types

type Actor

type Actor interface {
	SupportedCommands() []Command
	Do(ctx context.Context, cluster types.RedisInstance) *ActorResult
}

Actor actor is used process instance with specified state

type ActorManager

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

ActorManager

func NewActorManager

func NewActorManager() *ActorManager

NewActorManager

func (*ActorManager) Add

func (m *ActorManager) Add(a Actor) error

Add

func (*ActorManager) All

func (m *ActorManager) All(cmd Command) (ret [][]Actor)

GetAll

func (*ActorManager) Get

func (m *ActorManager) Get(cmd Command) []Actor

Get

type ActorResult

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

ActorResult

func NewResult

func NewResult(cmd Command) *ActorResult

func NewResultWithError

func NewResultWithError(cmd Command, err error) *ActorResult

func NewResultWithValue

func NewResultWithValue(cmd Command, val interface{}) *ActorResult

func (*ActorResult) Err

func (c *ActorResult) Err() error

Err

func (*ActorResult) NextCommand

func (c *ActorResult) NextCommand() Command

Next

func (*ActorResult) Result

func (c *ActorResult) Result() interface{}

Result

type Command

type Command interface {
	String() string
}