nozzle

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

type FirehoseClient interface {
	Connect() (<-chan *events.Envelope, <-chan error)
	CloseConsumer() error
}

type FirehoseConfig struct {
	SubscriptionId       string
	TrafficControllerUrl string
	IdleTimeout          time.Duration
}

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

type NozzleConfig struct {
	HumioBatchTime         time.Duration
	HumioMaxMsgNumPerBatch int
}