splunk

Documentation

Index

• func NewSplunkDataWriter(config base.BaseConfig) base.DataWriter
• func SourceAndSourcetype(config base.BaseConfig) (string, string)
• type SplunkDataWriter
  • func (writer *SplunkDataWriter) Start()
  • func (writer *SplunkDataWriter) Stop()
  • func (writer *SplunkDataWriter) WriteData(data *base.Data) error
  • func (writer *SplunkDataWriter) WriteDataAsync(data *base.Data) error
  • func (writer *SplunkDataWriter) WriteDataSync(data *base.Data) error
• type SplunkRest
  • func (rest SplunkRest) IndexData(splunkdURI string, sessionKey string, metaProps *url.Values, data []byte) error
  • func (rest SplunkRest) Login(splunkdURI, username, password string) (string, error)
  • func (rest SplunkRest) SplunkdRequest(splunkdURI string, sessionKey string, method string, headers map[string]string, ...) ([]byte, error)

Functions

func NewSplunkDataWriter

func NewSplunkDataWriter(config base.BaseConfig) base.DataWriter

func SourceAndSourcetype

func SourceAndSourcetype(config base.BaseConfig) (string, string)

Types

type SplunkDataWriter

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

func (*SplunkDataWriter) Start

func (writer *SplunkDataWriter) Start()

func (*SplunkDataWriter) Stop

func (writer *SplunkDataWriter) Stop()

func (*SplunkDataWriter) WriteData

func (writer *SplunkDataWriter) WriteData(data *base.Data) error

func (*SplunkDataWriter) WriteDataAsync

func (writer *SplunkDataWriter) WriteDataAsync(data *base.Data) error

func (*SplunkDataWriter) WriteDataSync

func (writer *SplunkDataWriter) WriteDataSync(data *base.Data) error

type SplunkRest

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

func (SplunkRest) IndexData

func (rest SplunkRest) IndexData(splunkdURI string, sessionKey string,
	metaProps *url.Values, data []byte) error

IndexData: @metaProps: contains "host", "host_regex", "index", "source",

"sourcetype" key/values

func (SplunkRest) Login

func (rest SplunkRest) Login(splunkdURI, username, password string) (string, error)

func (SplunkRest) SplunkdRequest

func (rest SplunkRest) SplunkdRequest(splunkdURI string, sessionKey string,
	method string, headers map[string]string, data []byte, retry int) ([]byte, error)