Product
Introducing License Enforcement in Socket
Ensure open-source compliance with Socket’s License Enforcement Beta. Set up your License Policy and secure your software!
github.com/ZachtimusPrime/Go-Splunk-HTTP
A simple and lightweight HTTP Splunk logging package for Go. Instantiates a logging connection object to your Splunk server and allows you to submit log events as desired. Uses HTTP event collection on a Splunk server.
go get "github.com/ZachtimusPrime/Go-Splunk-HTTP/splunk/v2"
Construct a new Splunk HTTP client, then send log events as desired.
For example:
package main
import "github.com/ZachtimusPrime/Go-Splunk-HTTP/splunk/v2"
func main() {
// Create new Splunk client
splunk := splunk.NewClient(
nil,
"https://{your-splunk-URL}:8088/services/collector",
"{your-token}",
"{your-source}",
"{your-sourcetype}",
"{your-index}"
)
// Use the client to send a log with the go host's current time
err := splunk.Log(
interface{"msg": "send key/val pairs or json objects here", "msg2": "anything that is useful to you in the log event"}
)
if err != nil {
return err
}
// Use the client to send a log with a provided timestamp
err = splunk.LogWithTime(
time.Now(),
interface{"msg": "send key/val pairs or json objects here", "msg2": "anything that is useful to you in the log event"}
)
if err != nil {
return err
}
// Use the client to send a batch of log events
var events []splunk.Event
events = append(
events,
splunk.NewEvent(
interface{"msg": "event1"},
"{desired-source}",
"{desired-sourcetype}",
"{desired-index}"
)
)
events = append(
events,
splunk.NewEvent(
interface{"msg": "event2"},
"{desired-source}",
"{desired-sourcetype}",
"{desired-index}"
)
)
err = splunk.LogEvents(events)
if err != nil {
return err
}
}
To support logging libraries, and other output, we've added an asynchronous Writer. It supports retries, and different intervals for flushing messages & max log messages in its buffer
The easiest way to get access to the writer with an existing client is to do:
writer := splunkClient.Writer()
This will give you an io.Writer you can use to direct output to splunk. However, since the io.Writer() is asynchronous, it will never return an error from its Write() function. To access errors generated from the Client, Instantiate your Writer this way:
splunk.Writer{
Client: splunkClient
}
Since the type will now be splunk.Writer(), you can access the Errors()
function, which returns a channel of errors. You can then spin up a goroutine to listen on this channel and report errors, or you can handle however you like.
Optionally, you can add more configuration to the writer.
splunk.Writer {
Client: splunkClient,
FlushInterval: 10 *time.Second, // How often we'll flush our buffer
FlushThreshold: 25, // Max messages we'll keep in our buffer, regardless of FlushInterval
MaxRetries: 2, // Number of times we'll retry a failed send
}
FAQs
Unknown package
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Product
Ensure open-source compliance with Socket’s License Enforcement Beta. Set up your License Policy and secure your software!
Product
We're launching a new set of license analysis and compliance features for analyzing, managing, and complying with licenses across a range of supported languages and ecosystems.
Product
We're excited to introduce Socket Optimize, a powerful CLI command to secure open source dependencies with tested, optimized package overrides.