package driver

import "context"

// Driver owns one integration. Run returns its failures without logging and
// stops on cancellation. Refresh requests a snapshot after broker reconnect.
// Refresh must be safe during Run and must not block the caller.
type Driver interface {
	Run(ctx context.Context) error
	Refresh()
}