repo

Documentation

Overview

Package repo contains the repository for the gateway

Index

• type GatewayConfGeneratorJob
  • func (job *GatewayConfGeneratorJob) GetDoneCh() <-chan struct{}
  • func (job *GatewayConfGeneratorJob) JobName() string
  • func (job *GatewayConfGeneratorJob) Run()
• type Server
  • func NewServer(cfg configurator.Configurator, msgBroker *messaging.Broker, ...) *Server
  • func (s *Server) BroadcastListener()

Types

type GatewayConfGeneratorJob

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

GatewayConfGeneratorJob is the job to generate pipy policy json

func (*GatewayConfGeneratorJob) GetDoneCh

func (job *GatewayConfGeneratorJob) GetDoneCh() <-chan struct{}

GetDoneCh returns the channel, which when closed, indicates the job has been finished.

func (*GatewayConfGeneratorJob) JobName

func (job *GatewayConfGeneratorJob) JobName() string

JobName implementation for this job, for logging purposes

func (*GatewayConfGeneratorJob) Run

func (job *GatewayConfGeneratorJob) Run()

Run is the logic unit of job

type Server

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

Server is the gateway server

func NewServer

func NewServer(cfg configurator.Configurator, msgBroker *messaging.Broker, processor processor.Processor) *Server

NewServer creates a new gateway server

func (*Server) BroadcastListener

func (s *Server) BroadcastListener()

BroadcastListener listens for broadcast messages from the message broker