checkpoints

type Barrier struct {
	CheckpointId int64
	OpId         string
}

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

type BarrierHandler interface {
	Process(data *BufferOrEvent, ctx api.StreamContext) bool //If data is barrier return true, else return false
	SetOutput(chan<- *BufferOrEvent)                         //It is using for block a channel
}

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

type BufferOrEvent struct {
	Data    interface{}
	Channel string
}

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

type Message int

type NonSourceTask interface {
	StreamTask
	GetInputCount() int
	AddInputCount()

	SetBarrierHandler(BarrierHandler)
}

type Responder interface {
	TriggerCheckpoint(checkpointId int64) error
	GetName() string
}

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

type Signal struct {
	Message Message
	Barrier
}

type SinkTask interface {
	NonSourceTask

	SaveCache()
}

type StreamCheckpointContext interface {
	Snapshot() error
	SaveState(checkpointId int64) error
}

type StreamTask interface {
	Broadcast(data interface{}) error
	GetName() string
	GetStreamContext() api.StreamContext
	SetQos(api.Qos)
}