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 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)
Click to show internal directories.
Click to hide internal directories.