coralogix

Documentation

Index

• Constants
• Variables
• func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, ...) providers.Provider
• func NewSink(cfg *CoralogixDestination, logger log.Logger, registry metrics.Registry) (abstract.Sinker, error)
• func SubmitLogs(data []HTTPLogItem, domain, token string) error
• type CoralogixDestination
  • func (d *CoralogixDestination) CleanupMode() model.CleanupType
  • func (d *CoralogixDestination) Compatible(src model.Source, transferType abstract.TransferType) error
  • func (d *CoralogixDestination) GetProviderType() abstract.ProviderType
  • func (d *CoralogixDestination) IsDestination()
  • func (d *CoralogixDestination) Validate() error
  • func (d *CoralogixDestination) WithDefaults()
• type HTTPLogItem
• type Provider
  • func (p Provider) Sink(config middlewares.Config) (abstract.Sinker, error)
  • func (p Provider) Type() abstract.ProviderType
• type Severity
• type Sink
  • func (s *Sink) Close() error
  • func (s *Sink) Push(items []abstract.ChangeItem) error

Constants

const (
	Debug    = Severity(1)
	Verbose  = Severity(2)
	Info     = Severity(3)
	Warn     = Severity(4)
	Error    = Severity(5)
	Critical = Severity(6)
)

1 – Debug, 2 – Verbose, 3 – Info, 4 – Warn, 5 – Error, 6 – Critical

const ProviderType = abstract.ProviderType("coralogix")

Variables

var (
	FatalErrors = set.New("403 Forbidden")
)

Functions

func New

func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, transfer *model.Transfer) providers.Provider

func NewSink

func NewSink(cfg *CoralogixDestination, logger log.Logger, registry metrics.Registry) (abstract.Sinker, error)

func SubmitLogs

func SubmitLogs(data []HTTPLogItem, domain, token string) error

Types

type CoralogixDestination

type CoralogixDestination struct {
	Token  model.SecretString
	Domain string

	MessageTemplate string
	ChunkSize       int
	SubsystemColumn string
	ApplicationName string

	// mapping to columns
	TimestampColumn string
	SourceColumn    string
	CategoryColumn  string
	ClassColumn     string
	MethodColumn    string
	ThreadIDColumn  string
	SeverityColumn  string
	HostColumn      string
	KnownSevereties map[string]Severity
}

func (*CoralogixDestination) CleanupMode

func (d *CoralogixDestination) CleanupMode() model.CleanupType

func (*CoralogixDestination) Compatible

func (d *CoralogixDestination) Compatible(src model.Source, transferType abstract.TransferType) error

func (*CoralogixDestination) GetProviderType

func (d *CoralogixDestination) GetProviderType() abstract.ProviderType

func (*CoralogixDestination) IsDestination

func (d *CoralogixDestination) IsDestination()

func (*CoralogixDestination) Validate

func (d *CoralogixDestination) Validate() error

func (*CoralogixDestination) WithDefaults

func (d *CoralogixDestination) WithDefaults()

type HTTPLogItem

type HTTPLogItem struct {
	ApplicationName string   `json:"applicationName"`
	SubsystemName   string   `json:"subsystemName"`
	ComputerName    string   `json:"computerName"`
	Timestamp       int64    `json:"timestamp,omitempty"`
	Severity        Severity `json:"severity"`
	Text            string   `json:"text"`
	Category        string   `json:"category"`
	ClassName       string   `json:"className"`
	MethodName      string   `json:"methodName"`
	ThreadID        string   `json:"threadId"`
	HiResTimestamp  string   `json:"hiResTimestamp,omitempty"`
}

type Provider

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

func (Provider) Sink

func (p Provider) Sink(config middlewares.Config) (abstract.Sinker, error)

func (Provider) Type

func (p Provider) Type() abstract.ProviderType

type Severity

type Severity int

type Sink

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

func (*Sink) Close

func (s *Sink) Close() error

func (*Sink) Push

func (s *Sink) Push(items []abstract.ChangeItem) error