server

type Access struct {
	Allow   bool
	Message string
	// StatusCode (optional) for custom HTTP status (if denied)
	StatusCode int
}

type AccessAction string

type AccessContext interface {
	RealIP() string
	Request() *http.Request
}

type AccessFn func(c AccessContext, resource AccessResource, action AccessAction) Access

type AccessResource string

type Fire interface {
	ds.DocumentStore
	ds.Changes
}

type LogLevel int

type Logger interface {
	Debugf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Errorf(format string, args ...interface{})
}

type MemCache interface {
	// Get returns value at key.
	Get(ctx context.Context, k string) (string, error)
	// Put puts a value at key.
	Set(ctx context.Context, k string, v string) error
	// Delete key.
	Delete(ctx context.Context, k string) error
	// Expire key.
	Expire(ctx context.Context, k string, dt time.Duration) error
	// Increment value at key.
	Increment(ctx context.Context, k string) (int64, error)
}

type PubSub interface {
	Publish(ctx context.Context, name string, b []byte) error
	Subscribe(ctx context.Context, name string, receiveFn func(b []byte)) error
}

type PubSubServer struct {
	URL string
	// contains filtered or unexported fields
}

type Server struct {

	// URL (base) of form http(s)://host:port with no trailing slash to help
	// authorization checks in testing where the host is ambiguous.
	URL string
	// contains filtered or unexported fields
}

type Tasks interface {
	// CreateTask ...
	CreateTask(ctx context.Context, method string, url string, authToken string) error
}