catchup

Documentation

Index

• func IncludeSegmentCheckpoint(m dsl.Module, state *common.State, params *common.ModuleParams, ...)
• func SendDoneMessages(m dsl.Module, state *common.State, params *common.ModuleParams, ...)

Functions

func IncludeSegmentCheckpoint

func IncludeSegmentCheckpoint(
	m dsl.Module,
	state *common.State,
	params *common.ModuleParams,
	moduleConfig common2.ModuleConfig,
	logger logging.Logger,
)

func SendDoneMessages

func SendDoneMessages(
	m dsl.Module,
	state *common.State,
	params *common.ModuleParams,
	moduleConfig common2.ModuleConfig,
	logger logging.Logger,
)

SendDoneMessages sends a Done message to all other nodes as part of the instance-level checkpoint subprotocol. This method is called when all slots have been committed.