orchestrator

Documentation

Index

• Constants
• func GetFormatterString(url string) string
• func Setup(cfg config.Config, background bool)
• func SetupWithFile(configPath string, background bool)
• type ControllerServer
  • func (s *ControllerServer) ConnectClouds(ctx context.Context, req *paragliderpb.ConnectCloudsRequest) (*paragliderpb.ConnectCloudsResponse, error)
  • func (s *ControllerServer) DeleteValue(c context.Context, req *paragliderpb.DeleteValueRequest) (*paragliderpb.DeleteValueResponse, error)
  • func (s *ControllerServer) FindUnusedAddressSpaces(c context.Context, req *paragliderpb.FindUnusedAddressSpacesRequest) (*paragliderpb.FindUnusedAddressSpacesResponse, error)
  • func (s *ControllerServer) FindUnusedAsn(c context.Context, _ *paragliderpb.FindUnusedAsnRequest) (*paragliderpb.FindUnusedAsnResponse, error)
  • func (s *ControllerServer) GetUsedAddressSpaces(c context.Context, _ *emptypb.Empty) (*paragliderpb.GetUsedAddressSpacesResponse, error)
  • func (s *ControllerServer) GetValue(c context.Context, req *paragliderpb.GetValueRequest) (*paragliderpb.GetValueResponse, error)
  • func (s *ControllerServer) SetValue(c context.Context, req *paragliderpb.SetValueRequest) (*paragliderpb.SetValueResponse, error)
• type ResourceInfo
• type Warning

Constants

const (
	GetPermitListRulesURL    string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName/rules"
	PermitListRulePOSTURL    string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName/rules"
	PermitListRulePUTURL     string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName/rules/:ruleName"
	AddPermitListRulesURL    string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName/applyRules"
	DeletePermitListRulesURL string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName/deleteRules"
	CreateResourcePUTURL     string = "/namespaces/:namespace/clouds/:cloud/resources/:resourceName"
	CreateResourcePOSTURL    string = "/namespaces/:namespace/clouds/:cloud/resources"
	ListTagURL               string = "/tags"
	GetTagURL                string = "/tags/:tag"
	ResolveTagURL            string = "/tags/:tag/resolveMembers"
	SetTagURL                string = "/tags/:tag/applyMembers"
	DeleteTagURL             string = "/tags/:tag"
	DeleteTagMemberURL       string = "/tags/:tag/members/:member"
	ListNamespacesURL        string = "/namespaces"
)

const (
	MIN_PRIVATE_ASN_2BYTE uint32 = 64512
	MAX_PRIVATE_ASN_2BYTE uint32 = 65534
	MIN_PRIVATE_ASN_4BYTE uint32 = 4200000000
	MAX_PRIVATE_ASN_4BYTE uint32 = 4294967294
)

Private ASN ranges (RFC 6996)

Functions

func GetFormatterString

func GetFormatterString(url string) string

Return a string usable with Sprintf for inserting URL params

func Setup

func Setup(cfg config.Config, background bool)

Setup and run the server

func SetupWithFile

func SetupWithFile(configPath string, background bool)

Setup with config file

Types

type ControllerServer

type ControllerServer struct {
	paragliderpb.UnimplementedControllerServer
	// contains filtered or unexported fields
}

func (*ControllerServer) ConnectClouds

func (s *ControllerServer) ConnectClouds(ctx context.Context, req *paragliderpb.ConnectCloudsRequest) (*paragliderpb.ConnectCloudsResponse, error)

Connects two clouds with VPN gateways

func (*ControllerServer) DeleteValue

func (s *ControllerServer) DeleteValue(c context.Context, req *paragliderpb.DeleteValueRequest) (*paragliderpb.DeleteValueResponse, error)

Delete a value in the KV store

func (*ControllerServer) FindUnusedAddressSpaces

func (s *ControllerServer) FindUnusedAddressSpaces(c context.Context, req *paragliderpb.FindUnusedAddressSpacesRequest) (*paragliderpb.FindUnusedAddressSpacesResponse, error)

Get a new address block for a new virtual network TODO @smcclure20: Later, this should allocate more efficiently and with different size address blocks (eg, GCP needs larger than Azure since a VPC will span all regions)

func (*ControllerServer) FindUnusedAsn

func (s *ControllerServer) FindUnusedAsn(c context.Context, _ *paragliderpb.FindUnusedAsnRequest) (*paragliderpb.FindUnusedAsnResponse, error)

func (*ControllerServer) GetUsedAddressSpaces

func (s *ControllerServer) GetUsedAddressSpaces(c context.Context, _ *emptypb.Empty) (*paragliderpb.GetUsedAddressSpacesResponse, error)

Gets unused address spaces across all clouds

func (*ControllerServer) GetValue

func (s *ControllerServer) GetValue(c context.Context, req *paragliderpb.GetValueRequest) (*paragliderpb.GetValueResponse, error)

Get a value from the KV store

func (*ControllerServer) SetValue

func (s *ControllerServer) SetValue(c context.Context, req *paragliderpb.SetValueRequest) (*paragliderpb.SetValueResponse, error)

Set a value in the KV store

type ResourceInfo

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

type Warning

type Warning struct {
	Message string
}