handler

type DataSync struct {
	// contains filtered or unexported fields
}

type Factory interface {
	New(ctx context.Context, options ...Option) (Handler, error)
}

type Handler interface {
	Exec(ctx context.Context, session Session) (interface{}, error)
}

type Option func(o *Options)

type Options struct {
	Arguments  []string
	InputType  reflect.Type
	OutputType reflect.Type
	LookupType func(name string) (reflect.Type, error)
}

type Session interface {
	Validator() *validator.Service
	Differ() *differ.Service
	MessageBus() *mbus.Service
	Db(opts ...sqlx.Option) (*sqlx.Service, error)
	Stater() *state.Service
	FlushTemplate(ctx context.Context) error
	Session(ctx context.Context, route *http.Route, opts ...state.Option) (Session, error)
	Http() http.Http
	Auth() auth.Auth
	Logger() logger.Logger
}