ps

Documentation

Index

• type AOFService
  • func NewAOFService() *AOFService
  • func (aof *AOFService) LoadLocalData()
  • func (aof *AOFService) Start(ctx context.Context)
  • func (aof *AOFService) WriteCmd(index uint32, args [][]byte)
• type EveryScheduler
  • func (s *EveryScheduler) Next(prev time.Time) time.Time
• type PersistentStorageService

Types

type AOFService

type AOFService struct {
	ChBuffer []chan redcon.Command
	// contains filtered or unexported fields
}

func NewAOFService

func NewAOFService() *AOFService

func (*AOFService) LoadLocalData

func (aof *AOFService) LoadLocalData()

func (*AOFService) Start

func (aof *AOFService) Start(ctx context.Context)

func (*AOFService) WriteCmd

func (aof *AOFService) WriteCmd(index uint32, args [][]byte)

type EveryScheduler

type EveryScheduler struct {
	Interval time.Duration
}

func (*EveryScheduler) Next

func (s *EveryScheduler) Next(prev time.Time) time.Time

type PersistentStorageService

type PersistentStorageService interface {
	LoadLocalData()

	Start(ctx context.Context)
	// contains filtered or unexported methods
}