utils

Documentation

Index

• Constants
• Variables
• func BufferProcessOutput(output chan interface{}, mq *MessageQueue)
• func IsRunning(pid uint32) bool
• func NewPID() uint32
• func NewProcess(run func(chan interface{}, chan interface{}), parentContext context.Context) (pid uint32)
• type BgWorkerSetting
• type CandleDuration
  • func CandleDurationFromString(tf string) (cd *CandleDuration)
  • func (cd *CandleDuration) Ceil(ts time.Time) time.Time
  • func (cd *CandleDuration) Duration() time.Duration
  • func (cd *CandleDuration) IsWithin(ts, start time.Time) bool
  • func (cd *CandleDuration) QueryableNrecords(tf string, nrecords int) int
  • func (cd *CandleDuration) QueryableTimeframe() string
  • func (cd *CandleDuration) Truncate(ts time.Time) time.Time
• type MessageQueue
  • func NewMessageQueue(length int) *MessageQueue
  • func (mq *MessageQueue) AddMessage(msg interface{})
  • func (mq *MessageQueue) GetMessages() (times []time.Time, messages []interface{})
  • func (mq *MessageQueue) Len() int
  • func (mq *MessageQueue) Less(i, j int) bool
  • func (mq *MessageQueue) Swap(i, j int)
• type MktsConfig
  • func (m *MktsConfig) Parse(data []byte) error
• type Process
  • func GetProcFromPID(pid uint32) *Process
  • func (pr *Process) GetOutput() (timestamps []time.Time, messages []interface{}, err error)
  • func (pr *Process) Kill()
  • func (pr *Process) PutInput(msg interface{}) (err error)
• type Timeframe
  • func NewTimeframe(arg interface{}) (tf *Timeframe)
  • func TimeframeFromDuration(tf time.Duration) *Timeframe
  • func TimeframeFromString(tf string) *Timeframe
  • func (tf *Timeframe) PeriodsPerDay() int
• type TriggerSetting

Constants

const Day = 24 * time.Hour

const Week = 7 * Day

const Year = 365 * Day

Variables

var (
	Tag        string
	GitHash    string
	BuildStamp string
)

var Timeframes = []*Timeframe{
	{"1Min", time.Minute},
	{"5Min", 5 * time.Minute},
	{"15Min", 15 * time.Minute},
	{"1H", time.Hour},
	{"4H", 4 * time.Hour},
	{"1D", Day},
}

Functions

func BufferProcessOutput

func BufferProcessOutput(output chan interface{}, mq *MessageQueue)

func IsRunning

func IsRunning(pid uint32) bool

func NewPID

func NewPID() uint32

func NewProcess

func NewProcess(run func(chan interface{}, chan interface{}), parentContext context.Context) (pid uint32)

Types

type BgWorkerSetting

type BgWorkerSetting struct {
	Module string
	Name   string
	Config map[string]interface{}
}

type CandleDuration

type CandleDuration struct {
	String string
	// contains filtered or unexported fields
}

func CandleDurationFromString

func CandleDurationFromString(tf string) (cd *CandleDuration)

func (*CandleDuration) Ceil

func (cd *CandleDuration) Ceil(ts time.Time) time.Time

Ceil returns the upper boundary time of this candle window that ts belongs to.

func (*CandleDuration) Duration

func (cd *CandleDuration) Duration() time.Duration

func (*CandleDuration) IsWithin

func (cd *CandleDuration) IsWithin(ts, start time.Time) bool

func (*CandleDuration) QueryableNrecords

func (cd *CandleDuration) QueryableNrecords(tf string, nrecords int) int

func (*CandleDuration) QueryableTimeframe

func (cd *CandleDuration) QueryableTimeframe() string

func (*CandleDuration) Truncate

func (cd *CandleDuration) Truncate(ts time.Time) time.Time

Truncate returns the lower boundary time of this candle window that ts belongs to.

type MessageQueue

type MessageQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMessageQueue

func NewMessageQueue(length int) *MessageQueue

func (*MessageQueue) AddMessage

func (mq *MessageQueue) AddMessage(msg interface{})

func (*MessageQueue) GetMessages

func (mq *MessageQueue) GetMessages() (times []time.Time, messages []interface{})

func (*MessageQueue) Len

func (mq *MessageQueue) Len() int

func (*MessageQueue) Less

func (mq *MessageQueue) Less(i, j int) bool

func (*MessageQueue) Swap

func (mq *MessageQueue) Swap(i, j int)

type MktsConfig

type MktsConfig struct {
	RootDirectory     string
	ListenPort        string
	Timezone          *time.Location
	Queryable         bool
	StopGracePeriod   time.Duration
	WALRotateInterval int
	EnableAdd         bool
	EnableRemove      bool
	EnableLastKnown   bool
	StartTime         time.Time
	Triggers          []*TriggerSetting
	BgWorkers         []*BgWorkerSetting
}

var InstanceConfig MktsConfig

func (*MktsConfig) Parse

func (m *MktsConfig) Parse(data []byte) error

type Process

type Process struct {
	PID     uint32
	Context context.Context

	Messages *MessageQueue
	// contains filtered or unexported fields
}

func GetProcFromPID

func GetProcFromPID(pid uint32) *Process

func (*Process) GetOutput

func (pr *Process) GetOutput() (timestamps []time.Time, messages []interface{}, err error)

func (*Process) Kill

func (pr *Process) Kill()

func (*Process) PutInput

func (pr *Process) PutInput(msg interface{}) (err error)

type Timeframe

type Timeframe struct {
	String   string
	Duration time.Duration
}

func NewTimeframe

func NewTimeframe(arg interface{}) (tf *Timeframe)

func TimeframeFromDuration

func TimeframeFromDuration(tf time.Duration) *Timeframe

func TimeframeFromString

func TimeframeFromString(tf string) *Timeframe

func (*Timeframe) PeriodsPerDay

func (tf *Timeframe) PeriodsPerDay() int

type TriggerSetting

type TriggerSetting struct {
	Module string
	On     string
	Config map[string]interface{}
}