middleware

package
v0.0.0-...-028b8ad Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 16, 2019 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PolicyAwareHandler 

func PolicyAwareHandler(policy ComputationPolicy) http.HandlerFunc

PolicyAwareHandler returns a http.Handler based on the passed ComputationPolicy. It also performs some basic logging of requests received.

Types

type ColumnTransform 

type ColumnTransform func(interface{}) (transformedValue interface{}, excludeRow bool, err error)

type ComputationLevel 

type ComputationLevel int

ComputationLevel specifies whether a handler for a http request can compute no globalResult, just provide the raw data or compute a full globalResult 

const (
	NoComputation ComputationLevel = iota
	RawData       ComputationLevel = iota
	CanCompute    ComputationLevel = iota
)

func ComputationLevelFromString 

func ComputationLevelFromString(level string) (ComputationLevel, error)

ComputationLevelFromString converts a string to the relevant ComputationLevel

func (ComputationLevel) ToString 

func (c ComputationLevel) ToString() string

ToString converts from a ComputationLevel to the relevant string

type ComputationPolicy 

type ComputationPolicy interface {
	Register(string, ComputationLevel, http.Handler)
	UnregisterAll(string)
	UnregisterOne(string, ComputationLevel)
	Resolve(string, ProcessingLocation) (ComputationLevel, http.Handler)
}

ComputationPolicy stores the computation capabilities of a node

type DataPolicy 

type DataPolicy interface {
	// resolve takes an identifier for an entity and returns the TableOperatoinsg for the entity
	Resolve(string) (*TableOperations, error)
	LastUpdated() time.Time
}

DataPolicy allow us to get a function which must be applied to data before returning for a given identifier

type DataTransforms 

type DataTransforms map[*PrivacyGroup]*TableOperations

transforms is a map from privacyGroups to TableOperations

type DynamicComputationPolicy 

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

DynamicComputationPolicy holds a set of computation capabilities for paths, these must be set manually

func NewDynamicComputationPolicy 

func NewDynamicComputationPolicy() *DynamicComputationPolicy

NewDynamicComputationPolicy returns a pointer to a DynamicComputationPolicy with an empty, initialised internal map

func (*DynamicComputationPolicy) Activate 

func (p *DynamicComputationPolicy) Activate(path string, level ComputationLevel) error

Activate marks a handler for a specific request path and computation level as active and hence it will appear as registered

func (*DynamicComputationPolicy) Deactivate 

func (p *DynamicComputationPolicy) Deactivate(path string, level ComputationLevel) error

Deactivate marks the handler for a specific request path and computation level as deactivated which means it will appear not be registered but can easily be re-activated with a call to Activate

func (*DynamicComputationPolicy) Register 

func (p *DynamicComputationPolicy) Register(path string, level ComputationLevel, handler http.Handler)

Register adds a capability for a path at a specific ComputationLevel

func (*DynamicComputationPolicy) Resolve 

func (p *DynamicComputationPolicy) Resolve(path string, preferredLocation ProcessingLocation) (ComputationLevel, http.Handler)

Resolve takes a path and preferred processing location and returns a handler and the computation level which that handler provides. It does this based on the capabilities for this path registered with the StaticComputationPolicy. The preferred processing location is used to break ties when we can offer full computation and raw data.

func (*DynamicComputationPolicy) UnregisterAll 

func (p *DynamicComputationPolicy) UnregisterAll(path string)

UnregisterAll removes all capabilities for a path

func (*DynamicComputationPolicy) UnregisterOne 

func (p *DynamicComputationPolicy) UnregisterOne(path string, level ComputationLevel)

UnregisterOne removes a capability for a path at a specific computation level

type MySQLPrivateDatabase 

type MySQLPrivateDatabase struct {
	DataPolicy  DataPolicy
	CacheTables bool
	// contains filtered or unexported fields
}

MySQLPrivateDatabase is a wrapper around a MySQL database which implements the PrivateRelationalDatabase interface, it supports DataPolicies which specify transforms for columns and excluded columns on a per PrivacyGroup basis

func (*MySQLPrivateDatabase) Close 

func (mspd *MySQLPrivateDatabase) Close() error

Close closes the connection to the MySQL database

func (*MySQLPrivateDatabase) Connect 

func (mspd *MySQLPrivateDatabase) Connect(user, password, databaseName, uri string, port int) error

Connect opens the connection to the MySQL database

func (*MySQLPrivateDatabase) Exec 

func (mspd *MySQLPrivateDatabase) Exec(query string, requestPolicy *RequestPolicy, args ...interface{}) (sql.Result, error)

Exec takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) ExecContext 

func (mspd *MySQLPrivateDatabase) ExecContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (sql.Result, error)

ExecContext takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) Ping 

func (mspd *MySQLPrivateDatabase) Ping() error

Ping verifies a connection to the database is still alive, establishing a connection if necessary.

func (*MySQLPrivateDatabase) PingContext 

func (mspd *MySQLPrivateDatabase) PingContext(ctx context.Context) error

PingContext verifies a connection to the database is still alive, establishing a connection if necessary.

func (*MySQLPrivateDatabase) Query 

func (mspd *MySQLPrivateDatabase) Query(query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Rows, error)

Query takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) QueryContext 

func (mspd *MySQLPrivateDatabase) QueryContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Rows, error)

QueryContext takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) QueryRow 

func (mspd *MySQLPrivateDatabase) QueryRow(query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Row, error)

QueryRow takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the // request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) QueryRowContext 

func (mspd *MySQLPrivateDatabase) QueryRowContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Row, error)

QueryRowContext takes a query string and a RequestPolicy and resolves the DataPolicy from the MySQLPrivateDatabase with the request policy to give a globalResult to the query on transformed versions of the actual database tables

func (*MySQLPrivateDatabase) SetConnMaxLifetime 

func (mspd *MySQLPrivateDatabase) SetConnMaxLifetime(d time.Duration)

SetConnMaxLifetime sets the maximum amount of time a connection may be reused.

Expired connections may be closed lazily before reuse.

If d <= 0, connections are reused forever.

func (*MySQLPrivateDatabase) SetMaxIdleConns 

func (mspd *MySQLPrivateDatabase) SetMaxIdleConns(n int)

SetMaxIdleConns sets the maximum number of connections in the idle connection pool.

If MaxOpenConns is greater than 0 but less than the new MaxIdleConns, then the new MaxIdleConns will be reduced to match the MaxOpenConns limit.

If n <= 0, no idle connections are retained.

The default max idle connections is currently 2. This may change in a future release.

func (*MySQLPrivateDatabase) SetMaxOpenConns 

func (mspd *MySQLPrivateDatabase) SetMaxOpenConns(n int)

SetMaxOpenConns sets the maximum number of open connections to the database.

If MaxIdleConns is greater than 0 and the new MaxOpenConns is less than MaxIdleConns, then MaxIdleConns will be reduced to match the new MaxOpenConns limit.

If n <= 0, then there is no limit on the number of open connections. The default is 0 (unlimited).

func (*MySQLPrivateDatabase) Stats 

func (mspd *MySQLPrivateDatabase) Stats() sql.DBStats

Stats returns database statistics

type PamRequest 

type PamRequest struct {
	Policy      *RequestPolicy
	HttpRequest *http.Request
}

PamRequest contains a RequestPolicy and a http request

func BuildPamRequest 

func BuildPamRequest(req *http.Request) (PamRequest, error)

BuildPamRequest takes a pointer to a http request and returns a PamRequest with policy values taken from the parameters of the passed request

func (*PamRequest) AddParam 

func (r *PamRequest) AddParam(key, value string)

AddParam adds a parameter to the contained http request with the same semantics as adding to the URL.Values of the http request

func (*PamRequest) DelParam 

func (r *PamRequest) DelParam(key string)

AddParam deletes a parameter from the contained http request with the same semantics as adding to the URL.Values of the http request

func (*PamRequest) GetParam 

func (r *PamRequest) GetParam(key string) string

AddParam gets a parameter from the contained http request with the same semantics as adding to the URL.Values of the http request

func (*PamRequest) SetParam 

func (r *PamRequest) SetParam(key, value string)

AddParam sets a parameter on the contained http request with the same semantics as adding to the URL.Values of the http request

type PamResponse 

type PamResponse struct {
	ComputationLevel ComputationLevel
	HttpResponse     *http.Response
}

PamResponse contains a http response and its associated computation level

func BuildPamResponse 

func BuildPamResponse(resp *http.Response) (PamResponse, error)

BuildPamResponse takes a pointer to a http response and returns a PamResponse with the ComputationLevel taken from the response header

type PolicyAwareClient 

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

PolicyAwareClient wraps a http client with a ComputationPolicy

func MakePolicyAwareClient 

func MakePolicyAwareClient(policy ComputationPolicy) PolicyAwareClient

MakePolicyAwareClient returns an PolicyAwareClient with initialised fields

func (PolicyAwareClient) Send 

func (c PolicyAwareClient) Send(req PamRequest) (PamResponse, error)

Send takes a PamRequest and martials the RequestPolicy into the http request parameters before sending it using the contained http client. If the ComputationPolicy has a local handler for the requested path, and the preferred location is local, and all of the data required for a globalResult is contained within the request then the request will instead be handled locally.

type PrivacyGroup 

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

PrivacyGroup a struct which contain a data structure of RequesterID's which we can Add to and Remove from

func NewPrivacyGroup 

func NewPrivacyGroup(name string) *PrivacyGroup

func (*PrivacyGroup) Add 

func (pg *PrivacyGroup) Add(id string)

func (*PrivacyGroup) AddMany 

func (pg *PrivacyGroup) AddMany(ids []string)

func (*PrivacyGroup) Name 

func (pg *PrivacyGroup) Name() string

func (*PrivacyGroup) Remove 

func (pg *PrivacyGroup) Remove(id string) error

type PrivateRelationalDatabase 

type PrivateRelationalDatabase interface {
	Connect(user, password, databaseName, uri string, port int) error
	Close() error
	Query(query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Row, error)
	QueryRowContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (*sql.Row, error)
	Exec(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (sql.Result, error)
	ExecContext(ctx context.Context, query string, requestPolicy *RequestPolicy, args ...interface{}) (sql.Result, error)
	Stats() sql.DBStats
	SetConnMaxLifetime(d time.Duration)
	SetMaxOpenConns(n int)
	SetMaxIdleConns(n int)
	Ping() error
	PingContext(ctx context.Context) error
}

PrivateRelationalDatabase wraps an SQL database and edits queries so that they operate over tables adjusted to match privacy policies

type ProcessingLocation 

type ProcessingLocation string

ProcessingLocation refers to either local or remote computation over data 

const (
	// Specified if the request should ideally be executed locally and never leave the device
	Local ProcessingLocation = "local"
	// Specified if the returned data would ideally be unprocessed
	Remote ProcessingLocation = "remote"
)

func ProcessingLocationFromString 

func ProcessingLocationFromString(loc string) (ProcessingLocation, error)

ProcessingLocationFromString converts from a string to the relevant ProcessingLocation

func (ProcessingLocation) ToString 

func (p ProcessingLocation) ToString() string

ToString coverts from a ProcessingLocation to the relevant string

type RequestPolicy 

type RequestPolicy struct {
	RequesterID                 string
	PreferredProcessingLocation ProcessingLocation
	HasAllRequiredData          bool
}

RequestPolicy stores the preferred location for processing of a request (and the identity of the requester?)

func BuildRequestPolicy 

func BuildRequestPolicy(req *http.Request) (*RequestPolicy, error)

BuildRequestPolicy takes a http request and extracts the values for a RequestPolicy from its parameters

func (*RequestPolicy) AddToParams 

func (p *RequestPolicy) AddToParams(params *url.Values)

AddToParams adds each of its fields as a parameter in the passed Values struct

type StaticComputationPolicy 

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

StaticComputationPolicy holds a map from http request paths to computation capabilities which dictate which handlers can be used for the request. A handler can be specified for returning a full globalResult (CanCompute) or just the raw data (RawData)

func NewStaticComputationPolicy 

func NewStaticComputationPolicy() *StaticComputationPolicy

NewStaticComputationPolicy returns a pointer to an initialised StaticComputationPolicy

func (*StaticComputationPolicy) Register 

func (p *StaticComputationPolicy) Register(path string, level ComputationLevel, handler http.Handler)

Register adds a capability for a path at a specific ComputationLevel

func (*StaticComputationPolicy) Resolve 

func (p *StaticComputationPolicy) Resolve(path string, preferredLocation ProcessingLocation) (ComputationLevel, http.Handler)

Resolve takes a path and preferred processing location and returns a handler and the computation level which that handler provides. It does this based on the capabilities for this path registered with the StaticComputationPolicy. The preferred processing location is used to break ties when we can offer full computation and raw data.

func (*StaticComputationPolicy) UnregisterAll 

func (p *StaticComputationPolicy) UnregisterAll(path string)

UnregisterAll removes all capabilities for a path

func (*StaticComputationPolicy) UnregisterOne 

func (p *StaticComputationPolicy) UnregisterOne(path string, level ComputationLevel)

UnregisterOne removes a capability for a path at a specific computation level

type StaticDataPolicy 

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

StaticDataPolicy implements the DataPolicy interface and contains a list of privacyGroups and DataTransforms for them

func NewStaticDataPolicy 

func NewStaticDataPolicy(privacyGroups []*PrivacyGroup, transforms DataTransforms) *StaticDataPolicy

NewStaticDataPolicy returns a pointer to a StaticDataPolicy with initialised fields

func (StaticDataPolicy) LastUpdated 

func (sdp StaticDataPolicy) LastUpdated() time.Time

func (*StaticDataPolicy) Resolve 

func (sdp *StaticDataPolicy) Resolve(entityID string) (*TableOperations, error)

Resolve takes an entity ID and returns a pointer to the relevant TableOperations struct based on the privacyGroups that the entity ID is in and the associated transforms stored in the StaticDataPolicy

type TableOperations 

type TableOperations struct {
	TableTransforms map[string]TableTransform
	ExcludedCols    map[string][]string
}

TableOperations contains functions to apply to tables before sending to an entity and columns to exclude

func NewTableOperations 

func NewTableOperations() *TableOperations

NewTableOperations returns a pointer to a TableOperations struct with initialised fields

type TableTransform 

type TableTransform map[string]ColumnTransform

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.