service

Documentation

Index

• Variables
• func NewEvictorFactory() *evictorFactory
• func NewOperatorFactory() *operatorFactory
• func NewProcessorFactory(ctx context.Context, db *mongo.Database) *processorFactory
• func NewTriggerFactory() *triggerFactory
• func NewWindowFactory() *windowFactory
• type EvictorCreateDTO
• type OperatorCreateDTO
• type ProcessorCreateDTO
• type PushDataToProcessorDTO
• type TriggerCreateDTO
• type WindowCreateDTO

Variables

var GlobalResourcePool = new(resourcesPool)

Functions

func NewEvictorFactory

func NewEvictorFactory() *evictorFactory

func NewOperatorFactory

func NewOperatorFactory() *operatorFactory

func NewProcessorFactory

func NewProcessorFactory(ctx context.Context, db *mongo.Database) *processorFactory

func NewTriggerFactory

func NewTriggerFactory() *triggerFactory

func NewWindowFactory

func NewWindowFactory() *windowFactory

Types

type EvictorCreateDTO

type EvictorCreateDTO struct {
	Type int32
}

type OperatorCreateDTO

type OperatorCreateDTO struct {
	Type     int32
	DataType int32
}

type ProcessorCreateDTO

type ProcessorCreateDTO struct {
	WindowId   string
	TriggerId  string
	EvictorId  string
	OperatorId string
}

type PushDataToProcessorDTO

type PushDataToProcessorDTO struct {
	ProcessorId string
	Key         string
	Value       string
	HappendTime string
}

type TriggerCreateDTO

type TriggerCreateDTO struct {
	Type   int32
	Count  int32
	Period int32
}

type WindowCreateDTO

type WindowCreateDTO struct {
	Type   core.WindowType
	Size   int32
	Period int32
	Gap    int32
}