crudinator

type AuthProvider interface{}

type CRUDGetHandler interface {
	Get(ctx *Context, rw web.ResponseWriter, req *web.Request)
}

type Config struct {
	PersistentStore PersistentStoreConfig
	EventSink       EventSinkConfig
	Oauth           OauthConfig
}

type Context struct {
	Validators      *map[reflect.Type]map[string]ValidatorFunc
	EventSink       EventSink
	PersistentStore PersistentStore
	context.Context
}

type ContextKey string

type Core struct {
	Validators      map[reflect.Type]map[string]ValidatorFunc
	Resources       map[string]interface{}
	Router          *web.Router
	EventSink       EventSink
	PersistentStore PersistentStore
	OauthProvider   AuthProvider
	Config          Config
}

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

type EventSink interface {
	Send(interface{}) error
}

type EventSinkConfig struct {
	Host     string
	Port     string
	Protocol string
}

type HandleFunc func(ctx *Context, rw web.ResponseWriter, req *web.Request)

type OauthConfig struct {
	Host     string
	Port     string
	Protocol string
}

type PersistentStore interface {
	// Connect will use the provided config to connect to the persistent store provider
	Connect(PersistentStoreConfig) error

	// Session will be called before handling each request. It should return a new PersistentStore with the object that should be used for querying properly initialised. This is present to support connection pooling, but is not required to be used. If session returns nil then the original PersistentStore will be used
	Session() PersistentStore

	// Get returns the object identified by the given key from the table with the supplied name, and saves the result into the supplied dst object pointer
	Get(key interface{}, tableName string, dst interface{}) error

	// List returns a list of objects filtered using key:value pairs. The interface passed into List will always be a pointer to a slice of the reource to be listed
	List(tableName string, filters map[string]interface{}, dst interface{}) error

	// Insert will create a new entry using the provided key and value and will return an error if the operation has failed.
	Insert(key interface{}, tableName string, value interface{}) error

	// Insert will create a new entry using the provided key and value and overwrite the existing value if it does exist, and will return an error if the operation has failed.
	Set(key interface{}, tableName string, value interface{}) error

	// Update will provide partial modification of objects in a json-patch style update (TBD)
	Update(key interface{}, tableName string, value interface{}) error

	// Delete will remove the entry associated with the provided key
	Delete(key interface{}, tableName string) error

	// Close will close the underlying connection
	Close() error

	// Raw will return a pointer to the underlying db connection
	Raw() interface{}
}

type PersistentStoreConfig struct {
	Engine   string //type of db. Eg: "postgres", "mysql",
	Host     string
	Port     string
	Protocol string
	Username string
	Password string
	Schema   string

	ConnectionString string
}

type StdGetHandler interface {
	Get(rw http.ResponseWriter, req *http.Request)
}

type StdListHandler interface {
	List(rw http.ResponseWriter, req *http.Request)
}

type StdSetHandler interface {
	Set(rw http.ResponseWriter, req *http.Request)
}

type ValidatorFunc func(value interface{}, annotation string) error