checkpoint

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 NonSinkTask interface {
	Broadcast(data any)
}

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
}

type SourceSubTopoTask interface {
	EnableCheckpoint(sources *[]StreamTask, ops *[]NonSourceTask)
}

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

type StreamTask interface {
	GetName() string
	GetStreamContext() api.StreamContext
	SetQos(qos def.Qos)
}