cyclemanager

Documentation

Index

• Constants
• type CycleFunc
• type CycleManager
  • func New(cycleInterval time.Duration, cycleFunc CycleFunc) *CycleManager
  • func (c *CycleManager) Running() bool
  • func (c *CycleManager) Start()
  • func (c *CycleManager) Stop(ctx context.Context) (stopResult chan bool)
  • func (c *CycleManager) StopAndWait(ctx context.Context) error
• type StopFunc

Constants

const (
	DefaultLSMCompactionInterval = 3 * time.Second
	DefaultMemtableFlushInterval = 500 * time.Millisecond
)

Types

type CycleFunc

type CycleFunc func(StopFunc)

type CycleManager

type CycleManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(cycleInterval time.Duration, cycleFunc CycleFunc) *CycleManager

func (*CycleManager) Running

func (c *CycleManager) Running() bool

func (*CycleManager) Start

func (c *CycleManager) Start()

Starts instance, does not block Does nothing if instance is already started

func (*CycleManager) Stop

func (c *CycleManager) Stop(ctx context.Context) (stopResult chan bool)

Stops running instance, does not block Returns channel with final stop result - true / false

If given context is cancelled before it is handled by stop logic, instance is not stopped If called multiple times, all contexts have to be cancelled to cancel stop (any valid will result in stopping instance) stopResult is the same (consistent) for multiple calls

func (*CycleManager) StopAndWait

func (c *CycleManager) StopAndWait(ctx context.Context) error

Stops running instance, waits for stop to occur or context to expire (which comes first) Returns error if instance was not stopped

type StopFunc

type StopFunc func() bool