metathings_deviced_flow

Documentation

Index

• Variables
• type Flow
• type FlowFactory
  • func NewFlowFactory(name string, args ...interface{}) (FlowFactory, error)
• type FlowFilter
• type FlowOption

Variables

var (
	ErrUnknownFlowFactory = errors.New("unknown flow factory")
)

Types

type Flow

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

type FlowFactory

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

func NewFlowFactory

func NewFlowFactory(name string, args ...interface{}) (FlowFactory, error)

type FlowFilter

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

type FlowOption

type FlowOption struct {
	FlowId   string
	DeviceId string
}