package driver import ( "context" "onehouse/protocol" ) // Transport sends a complete protocol publication. The caller owns the // connection. Publish must stop when ctx stops and must not mutate publication. type Transport interface { Publish(ctx context.Context, publication protocol.Publication) error }