cmd

Documentation

Index

• func ConnectAll(s Settings) (*nats.Conn, *dgo.Dgraph, error)
• func Execute()
• type DgraphSettings
• type IngestSettings
• type NATSSettings
• type Settings

Functions

func ConnectAll

func ConnectAll(s Settings) (*nats.Conn, *dgo.Dgraph, error)

ConnectAll Connects to all the things

func Execute

func Execute()

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.

Types

type DgraphSettings

type DgraphSettings struct {
	Host           string
	Port           int
	ConnectTimeout time.Duration
}

DgraphSettings Settings for connecting to dgraph

type IngestSettings

type IngestSettings struct {
	MaxWait   time.Duration
	BatchSize int
}

IngestSettings Settings for actually ingesting

type NATSSettings

type NATSSettings struct {
	ConnectionRetries int // Times to retry connection, 0 == infinite
	ConnectionTimeout time.Duration
	URLs              []string
}

NATSSettings Settings for the NATS connection

type Settings

type Settings struct {
	NATS        NATSSettings
	Dgraph      DgraphSettings
	Ingest      IngestSettings
	HealthyFile string
}

Settings for the ingestion process