brain

Documentation

Index

• func BroadcastStatistics()
• type Brain
  • func (b *Brain) Emit(e *types.Event)
  • func (b *Brain) GetBufferMaxSizeAndCommitInterval(id uuid.UUID) (uint64, uint64)
  • func (b *Brain) GetBufferType(id uuid.UUID) types.BufferType
  • func (b *Brain) GetCacheMaxSize() uint64
  • func (b *Brain) GetKAndVForNewTimeSeries(id uuid.UUID) (K uint16, V uint32)
  • func (b *Brain) GetReadAndWriteLimiter() (int64, int64)
  • func (b *Brain) RegisterEventHandler(tp types.EventType, handler types.EventHandler)
• type Distance

Functions

func BroadcastStatistics

func BroadcastStatistics()

Types

type Brain

type Brain struct {
	SystemStats      *stats.SystemStats
	ApplicationStats *stats.ApplicationStats
	DecisionTimes    int64
	// contains filtered or unexported fields
}

var B *Brain

func (*Brain) Emit

func (b *Brain) Emit(e *types.Event)

func (*Brain) GetBufferMaxSizeAndCommitInterval

func (b *Brain) GetBufferMaxSizeAndCommitInterval(id uuid.UUID) (uint64, uint64)

func (*Brain) GetBufferType

func (b *Brain) GetBufferType(id uuid.UUID) types.BufferType

func (*Brain) GetCacheMaxSize

func (b *Brain) GetCacheMaxSize() uint64

func (*Brain) GetKAndVForNewTimeSeries

func (b *Brain) GetKAndVForNewTimeSeries(id uuid.UUID) (K uint16, V uint32)

func (*Brain) GetReadAndWriteLimiter

func (b *Brain) GetReadAndWriteLimiter() (int64, int64)

func (*Brain) RegisterEventHandler

func (b *Brain) RegisterEventHandler(tp types.EventType, handler types.EventHandler)

type Distance

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