rules

Documentation

Index

• type HTTPOutput
• type HTTPSink
  • func (s *HTTPSink) Send(data []byte)
  • func (s *HTTPSink) Start()
• type RuleConfig
  • func NewRuleConfig(log logger.Logger, ruleConfigPath string) (*RuleConfig, error)
  • func (c *RuleConfig) Send(record *record.LogRecord) error
• type Rules

Types

type HTTPOutput

type HTTPOutput struct {
	Method         string
	Endpoint       string
	Headers        map[string]string
	Params         map[string]string
	Authentication struct {
		Header map[string]string
	}
}

type HTTPSink

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

func (*HTTPSink) Send

func (s *HTTPSink) Send(data []byte)

func (*HTTPSink) Start

func (s *HTTPSink) Start()

type RuleConfig

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

func NewRuleConfig

func NewRuleConfig(log logger.Logger, ruleConfigPath string) (*RuleConfig, error)

func (*RuleConfig) Send

func (c *RuleConfig) Send(record *record.LogRecord) error

type Rules

type Rules struct {
	Admin struct {
		Namespaces         []string
		DeadLetters        bool `yaml:"dead-letters"`
		ErrorOnDeadLetters bool `yaml:"error-on-dead-letters"`
		Output             struct {
			HTTP HTTPOutput `yaml:"http"`
		}
	}
	Output []struct {
		Namespace string
		HTTP      HTTPOutput `yaml:"http"`
	}
}