backends

Documentation

Index

• type BackendInterface
• type LocalBackend
  • func NewLocalBackend() LocalBackend
  • func (l *LocalBackend) Activate()
  • func (l *LocalBackend) Clone() BackendInterface
  • func (l LocalBackend) GetPoolSize() int
  • func (l *LocalBackend) GetResult(key string) (message.Result, error)
  • func (l *LocalBackend) SetPoolSize(i int)
  • func (l *LocalBackend) SetResult(result message.Result, exTime int) error

Types

type BackendInterface

type BackendInterface interface {
	SetResult(result message.Result, exTime int) error
	GetResult(key string) (message.Result, error)
	// 如果使用连接池，调用Activate后才真正建立连接
	Activate()
	SetPoolSize(int)
	GetPoolSize() int
	Clone() BackendInterface
}

type LocalBackend

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

func NewLocalBackend

func NewLocalBackend() LocalBackend

func (*LocalBackend) Activate

func (l *LocalBackend) Activate()

func (*LocalBackend) Clone

func (l *LocalBackend) Clone() BackendInterface

func (LocalBackend) GetPoolSize

func (l LocalBackend) GetPoolSize() int

func (*LocalBackend) GetResult

func (l *LocalBackend) GetResult(key string) (message.Result, error)

func (*LocalBackend) SetPoolSize

func (l *LocalBackend) SetPoolSize(i int)

func (*LocalBackend) SetResult

func (l *LocalBackend) SetResult(result message.Result, exTime int) error