apiserver

Documentation

Index

• Constants
• Variables
• func AlertCmd(message *Message, p *Papi, sync bool) error
• func CustomRecoveryWithWriter() gin.HandlerFunc
• func DecisionCmd(message *Message, p *Papi, sync bool) error
• func ManagementCmd(message *Message, p *Papi, sync bool) error
• func NewAPIC(config *csconfig.OnlineApiClientCfg, dbClient *database.Client, ...) (*apic, error)
• type APIServer
  • func NewServer(config *csconfig.LocalApiServerCfg) (*APIServer, error)
  • func (s *APIServer) AttachPluginBroker(broker *csplugin.PluginBroker)
  • func (s *APIServer) Close()
  • func (s *APIServer) InitController() error
  • func (s *APIServer) Router() (*gin.Engine, error)
  • func (s *APIServer) Run(apiReady chan bool) error
  • func (s *APIServer) Shutdown() error
• type Header
• type Message
• type OperationChannels
• type Papi
  • func NewPAPI(apic *apic, dbClient *database.Client, consoleConfig *csconfig.ConsoleConfig, ...) (*Papi, error)
  • func (p *Papi) GetPermissions() (PapiPermCheckSuccess, error)
  • func (p *Papi) Pull() error
  • func (p *Papi) PullOnce(since time.Time, sync bool) error
  • func (p *Papi) SendDeletedDecisions(cacheOrig *models.DecisionsDeleteRequest)
  • func (p *Papi) Shutdown()
  • func (p *Papi) SyncDecisions() error
• type PapiPermCheckError
• type PapiPermCheckSuccess
• type Source

Constants

const PapiPullKey = "papi:last_pull"

Variables

var SyncInterval = time.Second * 10

Functions

func AlertCmd

func AlertCmd(message *Message, p *Papi, sync bool) error

func CustomRecoveryWithWriter

func CustomRecoveryWithWriter() gin.HandlerFunc

CustomRecoveryWithWriter returns a middleware for a writer that recovers from any panics and writes a 500 if there was one.

func DecisionCmd

func DecisionCmd(message *Message, p *Papi, sync bool) error

func ManagementCmd

func ManagementCmd(message *Message, p *Papi, sync bool) error

func NewAPIC

func NewAPIC(config *csconfig.OnlineApiClientCfg, dbClient *database.Client, consoleConfig *csconfig.ConsoleConfig, apicWhitelist *csconfig.CapiWhitelist) (*apic, error)

Types

type APIServer

type APIServer struct {
	URL        string
	UnixSocket string
	TLS        *csconfig.TLSCfg
	// contains filtered or unexported fields
}

func NewServer

func NewServer(config *csconfig.LocalApiServerCfg) (*APIServer, error)

NewServer creates a LAPI server. It sets up a gin router, a database client, and a controller.

func (*APIServer) AttachPluginBroker

func (s *APIServer) AttachPluginBroker(broker *csplugin.PluginBroker)

func (*APIServer) Close

func (s *APIServer) Close()

func (*APIServer) InitController

func (s *APIServer) InitController() error

func (*APIServer) Router

func (s *APIServer) Router() (*gin.Engine, error)

func (*APIServer) Run

func (s *APIServer) Run(apiReady chan bool) error

func (*APIServer) Shutdown

func (s *APIServer) Shutdown() error

type Header

type Header struct {
	OperationType string    `json:"operation_type"`
	OperationCmd  string    `json:"operation_cmd"`
	Timestamp     time.Time `json:"timestamp"`
	Message       string    `json:"message"`
	UUID          string    `json:"uuid"`
	Source        *Source   `json:"source"`
	Destination   string    `json:"destination"`
}

type Message

type Message struct {
	Header *Header
	Data   interface{} `json:"data"`
}

type OperationChannels

type OperationChannels struct {
	AddAlertChannel       chan []*models.Alert
	DeleteDecisionChannel chan []*models.Decision
}

type Papi

type Papi struct {
	URL      string
	Client   *longpollclient.LongPollClient
	DBClient *database.Client

	Channels *OperationChannels

	SyncInterval time.Duration

	Logger *log.Entry
	// contains filtered or unexported fields
}

func NewPAPI

func NewPAPI(apic *apic, dbClient *database.Client, consoleConfig *csconfig.ConsoleConfig, logLevel log.Level) (*Papi, error)

func (*Papi) GetPermissions

func (p *Papi) GetPermissions() (PapiPermCheckSuccess, error)

func (*Papi) Pull

func (p *Papi) Pull() error

PullPAPI is the long polling client for real-time decisions from PAPI

func (*Papi) PullOnce

func (p *Papi) PullOnce(since time.Time, sync bool) error

func (*Papi) SendDeletedDecisions

func (p *Papi) SendDeletedDecisions(cacheOrig *models.DecisionsDeleteRequest)

func (*Papi) Shutdown

func (p *Papi) Shutdown()

func (*Papi) SyncDecisions

func (p *Papi) SyncDecisions() error

type PapiPermCheckError

type PapiPermCheckError struct {
	Error string `json:"error"`
}

type PapiPermCheckSuccess

type PapiPermCheckSuccess struct {
	Status     string   `json:"status"`
	Plan       string   `json:"plan"`
	Categories []string `json:"categories"`
}

type Source

type Source struct {
	User string `json:"user"`
}