platform

Documentation

Index

• Constants
• func ConvertPullPolicyStringToType(pullPolicy string) apiv1.PullPolicy
• type ContainerDetails
• type Settings
  • func GetSettings() *Settings
• type Store

Constants

const AnalyzerSvcAddress = "analyzer_svc_address"

AnalyzerSvcAddress analyzer service address

const AnonymizerImageSvcAddress = "anonymizer_image_svc_address"

AnonymizerImageSvcAddress anonymizer image service address

const AnonymizerSvcAddress = "anonymizer_svc_address"

AnonymizerSvcAddress anonymizer service address

const CollectorImageName = "collector_image_name"

CollectorImageName collector docker image name

const CollectorImagePullPolicy = "collector_image_pull_policy"

CollectorImagePullPolicy collector image k8s pull policy

const DatasinkGrpcPort = "datasink_grpc_port"

DatasinkGrpcPort for data sink GRPC server

const DatasinkImageName = "datasink_image_name"

DatasinkImageName datasink docker image name

const DatasinkImagePullPolicy = "datasink_image_pull_policy"

DatasinkImagePullPolicy datasink image k8s pull policy

const GrpcPort = "grpc_port"

GrpcPort for GRPC server

const LogLevel = "log_level"

LogLevel debug/info/warn/error/fatal

const OcrSvcAddress = "ocr_svc_address"

OcrSvcAddress ocr service address

const PresidioNamespace = "presidio_namespace"

PresidioNamespace for k8s deployment

const QueueURL = "queue_url"

QueueURL rabbitmq url

const RedisDb = "redis_db"

RedisDb redis db number

const RedisPassword = "redis_password"

RedisPassword redis db password

const RedisSSL = "redis_ssl"

RedisSSL redis ssl

const RedisURL = "redis_url"

RedisURL redis address

const ScannerRequest = "scanner_request"

ScannerRequest template

const SchedulerSvcAddress = "scheduler_svc_address"

SchedulerSvcAddress scheduler service address

const StreamRequest = "stream_request"

StreamRequest template

const WebPort = "web_port"

WebPort for http server

Functions

func ConvertPullPolicyStringToType

func ConvertPullPolicyStringToType(pullPolicy string) apiv1.PullPolicy

ConvertPullPolicyStringToType converts job policy string to pull polcy type

Types

type ContainerDetails

type ContainerDetails struct {
	Name            string
	Image           string
	EnvVars         []apiv1.EnvVar
	ImagePullPolicy apiv1.PullPolicy
}

ContainerDetails ...

type Settings

type Settings struct {
	WebPort                   int
	GrpcPort                  int
	DatasinkGrpcPort          int
	Namespace                 string
	AnalyzerSvcAddress        string
	AnonymizerSvcAddress      string
	AnonymizerImageSvcAddress string
	OcrSvcAddress             string
	SchedulerSvcAddress       string
	RedisURL                  string
	RedisPassword             string
	RedisDB                   int
	RedisSSL                  bool
	DatasinkImage             string
	CollectorImage            string
	DatasinkImagePullPolicy   string
	CollectorImagePullPolicy  string
	ScannerRequest            string
	StreamRequest             string
	QueueURL                  string
	LogLevel                  string
}

Settings from all services

func GetSettings

func GetSettings() *Settings

GetSettings from env vars

type Store

type Store interface {
	PutKVPair(key string, value string) error
	GetKVPair(key string) (string, error)
	DeleteKVPair(key string) error
	CreateJob(name string, containerDetailsArray []ContainerDetails) error
	CreateCronJob(name string, schedule string, containerDetailsArray []ContainerDetails) error
	ListJobs() ([]string, error)
	ListCronJobs() ([]string, error)
	DeleteJob(name string) error
	DeleteCronJob(name string) error
}

Store interface