orchestrator

Documentation

Index

• func LoadHandlers(configHandler *dataConfigGateway.ConfigData, ...) func(router *mux.Router)
• type Application
• type Applications
• type ApplicationsHandler
  • func (handler ApplicationsHandler) GetPolicies(w http.ResponseWriter, r *http.Request)
  • func (handler ApplicationsHandler) List(w http.ResponseWriter, r *http.Request)
  • func (handler ApplicationsHandler) SetPolicies(w http.ResponseWriter, r *http.Request)
  • func (handler ApplicationsHandler) Show(w http.ResponseWriter, r *http.Request)
• type ApplicationsService
  • func (service ApplicationsService) Apply(jsonRequest Orchestration) error
  • func (service ApplicationsService) GatherRecords(identifier string) (policyprovider.ApplicationInfo, policyprovider.IntegrationInfo, ...)
  • func (service ApplicationsService) RetainAction(fromPolicies, toPolicies []hexapolicy.PolicyInfo) ([]hexapolicy.PolicyInfo, error)
  • func (service ApplicationsService) RetainResource(fromPolicies, toPolicies []hexapolicy.PolicyInfo) ([]hexapolicy.PolicyInfo, error)
• type Integration
• type Integrations
• type IntegrationsHandler
  • func (handler IntegrationsHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (handler IntegrationsHandler) Delete(w http.ResponseWriter, r *http.Request)
  • func (handler IntegrationsHandler) List(w http.ResponseWriter, _ *http.Request)
• type Orchestration
• type OrchestrationHandler
  • func (o OrchestrationHandler) Update(writer http.ResponseWriter, request *http.Request)
• type ProviderBuilder
  • func NewProviderBuilder() *ProviderBuilder
  • func (b *ProviderBuilder) AddProviders(cacheProviders map[string]policyprovider.Provider)
  • func (b *ProviderBuilder) GetAppsProvider(id string, providerType string, key []byte) (policyprovider.Provider, error)

Functions

func LoadHandlers

func LoadHandlers(configHandler *dataConfigGateway.ConfigData, cacheProviders map[string]policyprovider.Provider) func(router *mux.Router)

Types

type Application

type Application struct {
	ID            string `json:"id"`
	IntegrationId string `json:"integration_id"`
	ObjectId      string `json:"object_id"`
	Name          string `json:"name"`
	Description   string `json:"description"`
	ProviderName  string `json:"provider_name"`
	Service       string `json:"service"`
}

type Applications

type Applications struct {
	Applications []Application `json:"applications"`
}

type ApplicationsHandler

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

func (ApplicationsHandler) GetPolicies

func (handler ApplicationsHandler) GetPolicies(w http.ResponseWriter, r *http.Request)

func (ApplicationsHandler) List

func (handler ApplicationsHandler) List(w http.ResponseWriter, r *http.Request)

func (ApplicationsHandler) SetPolicies

func (handler ApplicationsHandler) SetPolicies(w http.ResponseWriter, r *http.Request)

func (ApplicationsHandler) Show

func (handler ApplicationsHandler) Show(w http.ResponseWriter, r *http.Request)

type ApplicationsService

type ApplicationsService struct {
	ApplicationsGateway dataConfigGateway.ApplicationsDataGateway
	IntegrationsGateway dataConfigGateway.IntegrationsDataGateway
	ProviderBuilder     *ProviderBuilder
	DisableChecks       bool // Only set to true by tests
}

func (ApplicationsService) Apply

func (service ApplicationsService) Apply(jsonRequest Orchestration) error

func (ApplicationsService) GatherRecords

func (service ApplicationsService) GatherRecords(identifier string) (policyprovider.ApplicationInfo, policyprovider.IntegrationInfo, policyprovider.Provider, error)

func (ApplicationsService) RetainAction

func (service ApplicationsService) RetainAction(fromPolicies, toPolicies []hexapolicy.PolicyInfo) ([]hexapolicy.PolicyInfo, error)

func (ApplicationsService) RetainResource

func (service ApplicationsService) RetainResource(fromPolicies, toPolicies []hexapolicy.PolicyInfo) ([]hexapolicy.PolicyInfo, error)

type Integration

type Integration struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	Provider string `json:"provider"`
	Key      []byte `json:"key"`
}

type Integrations

type Integrations struct {
	Integrations []Integration `json:"integrations"`
}

type IntegrationsHandler

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

func (IntegrationsHandler) Create

func (handler IntegrationsHandler) Create(w http.ResponseWriter, r *http.Request)

func (IntegrationsHandler) Delete

func (handler IntegrationsHandler) Delete(w http.ResponseWriter, r *http.Request)

func (IntegrationsHandler) List

func (handler IntegrationsHandler) List(w http.ResponseWriter, _ *http.Request)

type Orchestration

type Orchestration struct {
	From string `json:"from"`
	To   string `json:"to"`
}

type OrchestrationHandler

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

func (OrchestrationHandler) Update

func (o OrchestrationHandler) Update(writer http.ResponseWriter, request *http.Request)

type ProviderBuilder

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

func NewProviderBuilder

func NewProviderBuilder() *ProviderBuilder

func (*ProviderBuilder) AddProviders

func (b *ProviderBuilder) AddProviders(cacheProviders map[string]policyprovider.Provider)

AddProviders is primarily used in testing to allow a test provider to be directly injected rather than from the sdk integration providers

func (*ProviderBuilder) GetAppsProvider

func (b *ProviderBuilder) GetAppsProvider(id string, providerType string, key []byte) (policyprovider.Provider, error)

GetAppsProvider returns a policyprovider.Provider that can be used to retrieve applications, as well as get and set policies