Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

riemanngo

package module

Go to main page

Versions in this module

v0

v0.5.0

Sep 5, 2019

Changes in this version

+ const MaxUDPSize

+ func GetTLSConfig(serverName string, certPath string, keyPath string, insecure bool) (*tls.Config, error)

type Event

+ TTL time.Duration

+ type TCPClient struct

+ func NewTCPClient(addr string, timeout time.Duration) *TCPClient

+ func NewTLSClient(addr string, tlsConfig *tls.Config, timeout time.Duration) (*TCPClient, error)

+ func (c *TCPClient) Close() error

+ func (c *TCPClient) Connect() error

+ func (c *TCPClient) QueryIndex(q string) ([]Event, error)

+ func (c *TCPClient) Send(message *proto.Msg) (*proto.Msg, error)

+ type UDPClient struct

+ func NewUDPClient(addr string, timeout time.Duration) *UDPClient

+ func (c *UDPClient) Close() error

+ func (c *UDPClient) Connect() error

+ func (c *UDPClient) Send(message *proto.Msg) (*proto.Msg, error)

v0.4.0

Mar 25, 2018

v0.3.0

Mar 12, 2018

v0.2.0

Apr 24, 2017

v0.1.0

Apr 6, 2017

Changes in this version

+ const MAX_UDP_SIZE

+ func EventToProtocolBuffer(event *Event) (*proto.Event, error)

+ func SendEvent(c Client, e *Event) (*proto.Msg, error)

+ func SendEvents(c Client, e *[]Event) (*proto.Msg, error)

+ type Client interface

+ Close func() error

+ Connect func(timeout int32) error

+ Send func(message *proto.Msg) (*proto.Msg, error)

+ type Event struct

+ Attributes map[string]string

+ Description string

+ Host string

+ Metric interface{}

+ Service string

+ State string

+ Tags []string

+ Time int64

+ Ttl float32

+ func ProtocolBuffersToEvents(pbEvents []*proto.Event) []Event

+ type IndexClient interface

+ QueryIndex func(q string) ([]Event, error)

+ type TcpClient struct

+ func NewTcpClient(addr string) *TcpClient

+ func (c *TcpClient) Connect(timeout int32) error

+ func (c *TcpClient) QueryIndex(q string) ([]Event, error)

+ func (t *TcpClient) Close() error

+ func (t *TcpClient) Send(message *proto.Msg) (*proto.Msg, error)

+ type TlsClient struct

+ func NewTlsClient(addr string, certPath string, keyPath string, insecure bool) (*TlsClient, error)

+ func (c *TlsClient) Connect(timeout int32) error

+ func (c *TlsClient) QueryIndex(q string) ([]Event, error)

+ func (t *TlsClient) Close() error

+ func (t *TlsClient) Send(message *proto.Msg) (*proto.Msg, error)

+ type UdpClient struct

+ func NewUdpClient(addr string) *UdpClient

+ func (c *UdpClient) Connect(timeout int32) error

+ func (t *UdpClient) Close() error

+ func (t *UdpClient) Send(message *proto.Msg) (*proto.Msg, error)