service

Documentation

Index

• Variables
• func NewFirewall(ds *datastore.RethinkStore, ipamer ipam.IPAMer, mdc mdm.Client) *restful.WebService
• func NewIP(ds *datastore.RethinkStore, ipamer ipam.IPAMer, mdc mdm.Client) *restful.WebService
• func NewImage(ds *datastore.RethinkStore) *restful.WebService
• func NewMachine(ds *datastore.RethinkStore, pub bus.Publisher, ipamer ipam.IPAMer, ...) *restful.WebService
• func NewNetwork(ds *datastore.RethinkStore, ipamer ipam.IPAMer, mdc mdm.Client) *restful.WebService
• func NewPartition(ds *datastore.RethinkStore, tc TopicCreater) *restful.WebService
• func NewProject(ds *datastore.RethinkStore, mdc mdm.Client) *restful.WebService
• func NewSize(ds *datastore.RethinkStore) *restful.WebService
• func NewSwitch(ds *datastore.RethinkStore) *restful.WebService
• func ResurrectMachines(ds *datastore.RethinkStore, publisher bus.Publisher, ipamer ipam.IPAMer, ...) error
• type Allocation
• type Allocator
• type MachineAllocation
• type TenantEnsurer
  • func NewTenantEnsurer(tenants, excludedPathSuffixes []string) TenantEnsurer
  • func (e *TenantEnsurer) EnsureAllowedTenantFilter(req *restful.Request, resp *restful.Response, chain *restful.FilterChain)
• type TopicCreater
• type UserDirectory
  • func NewUserDirectory(providerTenant string) *UserDirectory
  • func (ud *UserDirectory) Get(user string) security.User
  • func (ud *UserDirectory) UserNames() []string

Variables

var (
	BasePath = "/"
)

Functions

func NewFirewall

func NewFirewall(
	ds *datastore.RethinkStore,
	ipamer ipam.IPAMer,
	mdc mdm.Client) *restful.WebService

NewFirewall returns a webservice for firewall specific endpoints.

func NewIP

func NewIP(ds *datastore.RethinkStore, ipamer ipam.IPAMer, mdc mdm.Client) *restful.WebService

NewIP returns a webservice for ip specific endpoints.

func NewImage

func NewImage(ds *datastore.RethinkStore) *restful.WebService

NewImage returns a webservice for image specific endpoints.

func NewMachine

func NewMachine(
	ds *datastore.RethinkStore,
	pub bus.Publisher,
	ipamer ipam.IPAMer,
	mdc mdm.Client) *restful.WebService

NewMachine returns a webservice for machine specific endpoints.

func NewNetwork

func NewNetwork(ds *datastore.RethinkStore, ipamer ipam.IPAMer, mdc mdm.Client) *restful.WebService

NewNetwork returns a webservice for network specific endpoints.

func NewPartition

func NewPartition(ds *datastore.RethinkStore, tc TopicCreater) *restful.WebService

NewPartition returns a webservice for partition specific endpoints.

func NewProject

func NewProject(ds *datastore.RethinkStore, mdc mdm.Client) *restful.WebService

NewProject returns a webservice for project specific endpoints.

func NewSize

func NewSize(ds *datastore.RethinkStore) *restful.WebService

NewSize returns a webservice for size specific endpoints.

func NewSwitch

func NewSwitch(ds *datastore.RethinkStore) *restful.WebService

NewSwitch returns a webservice for switch specific endpoints.

func ResurrectMachines

func ResurrectMachines(ds *datastore.RethinkStore, publisher bus.Publisher, ipamer ipam.IPAMer, logger *zap.SugaredLogger) error

Types

type Allocation

type Allocation <-chan MachineAllocation

An Allocation is a queue of allocated machines. You can read the machines to get the next allocated one.

type Allocator

type Allocator func(Allocation) error

An Allocator is a callback for some piece of code if this wants to read allocated machines.

type MachineAllocation

type MachineAllocation struct {
	Machine *metal.Machine
	Err     error
}

The MachineAllocation contains the allocated machine or an error.

type TenantEnsurer

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

func NewTenantEnsurer

func NewTenantEnsurer(tenants, excludedPathSuffixes []string) TenantEnsurer

NewTenantEnsurer creates a new ensurer with the given tenants.

func (*TenantEnsurer) EnsureAllowedTenantFilter

func (e *TenantEnsurer) EnsureAllowedTenantFilter(req *restful.Request, resp *restful.Response, chain *restful.FilterChain)

EnsureAllowedTenantFilter checks if the tenant of the user is allowed.

type TopicCreater

type TopicCreater interface {
	CreateTopic(partitionID, topicFQN string) error
}

type UserDirectory

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

func NewUserDirectory

func NewUserDirectory(providerTenant string) *UserDirectory

func (*UserDirectory) Get

func (ud *UserDirectory) Get(user string) security.User

func (*UserDirectory) UserNames

func (ud *UserDirectory) UserNames() []string