testing

package

v6.0.0-beta1+incompatible Latest Latest Go to latest Published: Aug 2, 2017 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

func PublisherWithClient(client beat.Client) publisher.Publisher

type ChanClient struct {
	Channel chan beat.Event
	// contains filtered or unexported fields
}

given channel only.

func NewChanClient(bufSize int) *ChanClient

func NewChanClientWith(ch chan beat.Event) *ChanClient

func (c *ChanClient) Close() error

func (c *ChanClient) Publish(event beat.Event)

PublishEvent will publish the event on the channel. Options will be ignored. Always returns true.

func (c *ChanClient) PublishAll(event []beat.Event)

func (c *ChanClient) ReceiveEvent() beat.Event

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

func (pub *TestPublisher) Connect() publisher.Client

func (pub *TestPublisher) ConnectX(_ beat.ClientConfig) (beat.Client, error)

func (pub *TestPublisher) SetACKHandler(_ beat.PipelineACKHandler) error