metathings_deviced_flow

type Flow interface {
	Id() string
	Device() string
	PushFrame(*pb.Frame) error
	PullFrame() <-chan *pb.Frame
	QueryFrame(...*FlowFilter) ([]*pb.Frame, error)
	Err() error
	Close() error
}

type FlowFactory interface {
	New(*FlowOption) (Flow, error)
}

type FlowFilter struct {
	BeginAt time.Time
	EndAt   time.Time
}

type FlowOption struct {
	FlowId   string
	DeviceId string
}

type FlowSet interface {
	Id() string
	PushFrame(*FlowSetFrame) error
	PullFrame() <-chan *FlowSetFrame
	Err() error
	Close() error
}

type FlowSetFactory interface {
	New(*FlowSetOption) (FlowSet, error)
}

type FlowSetFrame struct {
	Device *pb.Device `json:"device"`
	Frame  *pb.Frame  `json:"frame"`
}

type FlowSetOption struct {
	FlowSetId string
}

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

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

type RedisStreamFlowSetFactoryOption struct {
	RedisStreamAddr        string
	RedisStreamDB          int
	RedisStreamPassword    string
	RedisStreamPoolInitial int
	RedisStreamPoolMax     int
}

type RedisStreamFlowSetOption struct {
	Id string

	ReadStreamGroupBlockTime time.Duration
	StreamExpireTime         time.Duration
	StreamTrimLimit          int64
	StreamTrimProb           float32
}