client

package
v0.0.0-...-70ad22e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2014 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Client package to talk to heka from Go.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	Sender  Sender
	Encoder Encoder
	// contains filtered or unexported fields
}

func NewClient

func NewClient(sender Sender, encoder Encoder) (self *Client)

func (*Client) SendMessage

func (self *Client) SendMessage(msg *message.Message) (err error)

type Encoder

type Encoder interface {
	EncodeMessage(msg *message.Message) ([]byte, error)
	EncodeMessageStream(msg *message.Message, outBytes *[]byte) error
}

type NetworkSender

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

func NewNetworkSender

func NewNetworkSender(proto, addr string) (*NetworkSender, error)

func NewTlsSender

func NewTlsSender(proto, addr string, config *tls.Config) (*NetworkSender, error)

func (*NetworkSender) Close

func (self *NetworkSender) Close()

func (*NetworkSender) SendMessage

func (self *NetworkSender) SendMessage(outBytes []byte) (err error)

type ProtobufEncoder

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

func NewProtobufEncoder

func NewProtobufEncoder(signer *message.MessageSigningConfig) *ProtobufEncoder

func (*ProtobufEncoder) EncodeMessage

func (p *ProtobufEncoder) EncodeMessage(msg *message.Message) ([]byte, error)

func (*ProtobufEncoder) EncodeMessageStream

func (p *ProtobufEncoder) EncodeMessageStream(msg *message.Message, outBytes *[]byte) (err error)

type Sender

type Sender interface {
	SendMessage(outBytes []byte) (err error)
	Close()
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL