logger

Documentation

Index

• Constants
• Variables
• func Setup(p models.Payload, taskID string) (chan string, string, func(), error)
• func StartStorerWorker(fd *os.File, client Storer, template logging.Resource, control chan string, ...) error
• type Storer
  • func NewHSDPStorer(env map[string]string) (Storer, error)
  • func NewLogDrainerStorer(env map[string]string) (Storer, error)

Constants

const (
	LogIngestorKeyEnv               = "SIDERITE_LOGINGESTOR_KEY"
	LogIngestorSecretEnv            = "SIDERITE_LOGINGESTOR_SECRET"
	LogIngestorServiceIDEnv         = "SIDERITE_LOGINGESTOR_SERVICE_ID"
	LogIngestorServicePrivateKeyEnv = "SIDERITE_LOGINGESTOR_SERVICE_PRIVATE_KEY"
	LogIngestorRegionEnv            = "SIDERITE_LOGINGESTOR_REGION"
	LogIngestorEnvironmentEnv       = "SIDERITE_LOGINGESTOR_ENVIRONMENT"
	LogIngestorProductKeyEnv        = "SIDERITE_LOGINGESTOR_PRODUCT_KEY"
	LogIngestorURLEnv               = "SIDERITE_LOGINGESTOR_URL"
	LogIngestorDebug                = "SIDERITE_LOGINGESTOR_DEBUG"
)

const (
	LogDrainerEnv = "SIDERITE_LOGDRAINER_URL"
)

Variables

var (
	CustomLogEventRegex = regexp.MustCompile(`^(?P<severity>[^\|\s]+)\s*\|\s*CustomLogEvent\s*\|\s*(?P<transaction_id>[^\|\s]*)\s*\|\s*(?P<trace_id>[^\|\s]*)\s*\|\s*(?P<span_id>[^\|\s]*)\s*\|\s*(?P<component_name>[^\|\s]*)\s*\|\s*(?P<logdata_message>.*)$`)
)

Functions

func Setup

func Setup(p models.Payload, taskID string) (chan string, string, func(), error)

func StartStorerWorker

func StartStorerWorker(fd *os.File, client Storer, template logging.Resource, control chan string, marker string) error

Types

type Storer

type Storer interface {
	StoreResources(messages []logging.Resource, count int) (*logging.StoreResponse, error)
}

func NewHSDPStorer

func NewHSDPStorer(env map[string]string) (Storer, error)

func NewLogDrainerStorer

func NewLogDrainerStorer(env map[string]string) (Storer, error)