initializers

Documentation

Index

• func AddrClient() am.AddressService
• func AddrClientWithTimeout(timeout time.Duration) am.AddressService
• func BigDataClient() am.BigDataService
• func BigQueryClient(cfg *bq.ClientConfig, credentials []byte) bq.BigQuerier
• func CoordClient() am.CoordinatorService
• func DB(appConfig *AppConfig) (string, *pgx.ConnPool)
• func DispatcherClient() am.DispatcherService
• func EventClient() am.EventService
• func Module(state *redis.State, moduleType am.ModuleType) am.ModuleService
• func Modules(state *redis.State) map[am.ModuleType]am.ModuleService
• func OrgClient() am.OrganizationService
• func PortScanModule(server, token string) am.PortScannerService
• func SGClient() am.ScanGroupService
• func Self(ctx context.Context, appConfig *AppConfig)
• func ServiceDiscovery(appConfig *AppConfig) string
• func State(appConfig *AppConfig) *redis.State
• func WebDataClient() am.WebDataService
• func WebDataClientWithTimeout(timeout time.Duration) am.WebDataService
• type AppConfig

Functions

func AddrClient

func AddrClient() am.AddressService

AddrClient connects to the address service

func AddrClientWithTimeout

func AddrClientWithTimeout(timeout time.Duration) am.AddressService

AddrClientWithTimeout connects to the address service with specified timeout for all calls

func BigDataClient

func BigDataClient() am.BigDataService

BigDataClient connects to the bigdata service

func BigQueryClient

func BigQueryClient(cfg *bq.ClientConfig, credentials []byte) bq.BigQuerier

func CoordClient

func CoordClient() am.CoordinatorService

CoordClient connects to the coordinator service

func DB

func DB(appConfig *AppConfig) (string, *pgx.ConnPool)

DB for environment, in region, for serviceKey service.

func DispatcherClient

func DispatcherClient() am.DispatcherService

DispatcherClient connects to the dispatcher service

func EventClient

func EventClient() am.EventService

EventClient connects to the address service

func Module

func Module(state *redis.State, moduleType am.ModuleType) am.ModuleService

Module returns the connected module depending on moduleType

func Modules

func Modules(state *redis.State) map[am.ModuleType]am.ModuleService

Modules initializes all modules and connects to them

func OrgClient

func OrgClient() am.OrganizationService

OrgClient connects to the organization service

func PortScanModule

func PortScanModule(server, token string) am.PortScannerService

PortScanModule connects directly with our port scanner service

func SGClient

func SGClient() am.ScanGroupService

SGClient connects to the scangroup service

func Self

func Self(ctx context.Context, appConfig *AppConfig)

Self registers if SelfRegister is set to anything. Assumes valid host:port pair in appConfig.Addr is set

func ServiceDiscovery

func ServiceDiscovery(appConfig *AppConfig) string

func State

func State(appConfig *AppConfig) *redis.State

State connects to the state system (redis)

func WebDataClient

func WebDataClient() am.WebDataService

WebDataClient connects to the webdata service

func WebDataClientWithTimeout

func WebDataClientWithTimeout(timeout time.Duration) am.WebDataService

WebDataClient connects to the webdata service with specified timeout for all calls

Types

type AppConfig

type AppConfig struct {
	Env          string
	Region       string
	SelfRegister string
	ServiceKey   string
	Addr         string
}

AppConfig represents values taken from environment variables