exporter

package

v1.4.0 Latest Latest Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	DefaultBatchSize    = 200
	DefaultBatchTime    = 30 * time.Second
	DefaultRetryCount   = 3
	DefaultRetryBackoff = 300 * time.Millisecond
)

This section is empty.

func WithBatchSize(n int) func(*Options)

func WithBatchTime(t time.Duration) func(*Options)

func WithRetryPolicy(count int, backoff time.Duration) func(*Options)

func WithTLS(cfg *tls.Config) func(*Options)

type Exporter interface {
	Export(event *pbflow.FlowEvent) error
}

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

func NewFlowGrpcClient(serverURL string, optFns ...func(*Options)) *FlowGrpcClient

func (c *FlowGrpcClient) Export(event *pbflow.FlowEvent) error

func (c *FlowGrpcClient) Start() error

func (c *FlowGrpcClient) Stop() error

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

type StdoutExporter struct{}

func NewStdoutExporter() *StdoutExporter

func (s *StdoutExporter) Export(event *pbflow.FlowEvent) error