Publish typed values with bounded repeat timing

[onehouse] / driver / driver.go

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()
}