Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ChanClient ¶
given channel only.
func NewChanClient ¶
func NewChanClient(bufSize int) *ChanClient
func NewChanClientWith ¶
func NewChanClientWith(ch chan beat.Event) *ChanClient
func (*ChanClient) Close ¶
func (c *ChanClient) Close() error
func (*ChanClient) Publish ¶
func (c *ChanClient) Publish(event beat.Event)
PublishEvent will publish the event on the channel. Options will be ignored. Always returns true.
func (*ChanClient) PublishAll ¶
func (c *ChanClient) PublishAll(event []beat.Event)
func (*ChanClient) ReceiveEvent ¶
func (c *ChanClient) ReceiveEvent() beat.Event
type TestPublisher ¶
type TestPublisher struct {
// contains filtered or unexported fields
}
func (*TestPublisher) ConnectWith ¶
func (pub *TestPublisher) ConnectWith(_ beat.ClientConfig) (beat.Client, error)
func (*TestPublisher) SetACKHandler ¶
func (pub *TestPublisher) SetACKHandler(_ beat.PipelineACKHandler) error
Click to show internal directories.
Click to hide internal directories.