multitenant

package

v0.14.0 Latest Latest Go to latest Published: Apr 19, 2016 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

bitbucket.org/blackxcloudeng/scope

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewConsulPipeRouter(client ConsulClient, prefix, advertise string, userIDer UserIDer) app.PipeRouter
func NewSQSControlRouter(config *aws.Config, userIDer UserIDer) app.ControlRouter
func NoopUserIDer(context.Context) (string, error)
type CASCallback
type ConsulClient
- func NewConsulClient(addr string) (ConsulClient, error)
type DynamoDBCollector
- func NewDynamoDBCollector(config *aws.Config, userIDer UserIDer) DynamoDBCollector
type UserIDer
- func UserIDHeader(headerName string) UserIDer

Constants ¶

This section is empty.

Variables ¶

View Source

var (

	// ErrNotFound is returned by ConsulClient.Get
	ErrNotFound = fmt.Errorf("Not found")
)

View Source

var ErrUserIDNotFound = fmt.Errorf("User ID not found")

ErrUserIDNotFound should be returned by a UserIDer when it fails to ID the user for a request.

Functions ¶

func NewConsulPipeRouter ¶

func NewConsulPipeRouter(client ConsulClient, prefix, advertise string, userIDer UserIDer) app.PipeRouter

NewConsulPipeRouter returns a new consul based router

func NewSQSControlRouter ¶

func NewSQSControlRouter(config *aws.Config, userIDer UserIDer) app.ControlRouter

NewSQSControlRouter the harbinger of death

func NoopUserIDer ¶

func NoopUserIDer(context.Context) (string, error)

NoopUserIDer always returns the empty user ID.

Types ¶

type CASCallback ¶

type CASCallback func(in interface{}) (out interface{}, retry bool, err error)

CASCallback is the type of the callback to CAS. If err is nil, out must be non-nil.

type ConsulClient ¶

type ConsulClient interface {
	Get(key string, out interface{}) error
	CAS(key string, out interface{}, f CASCallback) error
	WatchPrefix(prefix string, out interface{}, done chan struct{}, f func(string, interface{}) bool)
}

ConsulClient is a high-level client for Consul, that exposes operations such as CAS and Watch which take callbacks. It also deals with serialisation.

func NewConsulClient ¶

func NewConsulClient(addr string) (ConsulClient, error)

NewConsulClient returns a new ConsulClient

type DynamoDBCollector ¶

type DynamoDBCollector interface {
	app.Collector
	CreateTables() error
}

DynamoDBCollector is a Collector which can also CreateTables

func NewDynamoDBCollector ¶

func NewDynamoDBCollector(config *aws.Config, userIDer UserIDer) DynamoDBCollector

NewDynamoDBCollector the reaper of souls https://github.com/aws/aws-sdk-go/wiki/common-examples

type UserIDer ¶

type UserIDer func(context.Context) (string, error)

UserIDer identifies users given a request context.

func UserIDHeader ¶

func UserIDHeader(headerName string) UserIDer

UserIDHeader returns a UserIDer which a header by the supplied key.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL