exporter

Documentation

Index

• Constants
• Variables
• func JSONBytes(data any) ([]byte, error)
• func JSONString(data any) (string, error)
• func NewExporterService(lis *DBListener) (*exporterService, error)
• type CloudEventListener
• type DBListener
  • func NewDBListener(client *rdb.DBClient) *DBListener
  • func (l *DBListener) Client() *rdb.DBClient
  • func (l *DBListener) SendEvents(events []vo.ExecutionEvent)
  • func (l *DBListener) SyncSchema() error
• type ExporterService
• type Listener
• type QueueListener
  • func NewQueueListener(queue mq.MessageQueue) *QueueListener
  • func (q *QueueListener) SendEvents(events []vo.ExecutionEvent)
  • func (q *QueueListener) SyncSchema() error

Constants

const (
	// DefaultPoolSize default pool size
	DefaultPoolSize = 1000
)

Variables

var (
	ContentType_JSON          = "application/json"
	ContentType_CloudEvent2_0 = "cloudevent2.0"
)

Functions

func JSONBytes

func JSONBytes(data any) ([]byte, error)

func JSONString

func JSONString(data any) (string, error)

func NewExporterService

func NewExporterService(lis *DBListener) (*exporterService, error)

NewExporterService create a new exporter instance

Types

type CloudEventListener

type CloudEventListener struct {
}

type DBListener

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

DBListener db as listener

func NewDBListener

func NewDBListener(client *rdb.DBClient) *DBListener

func (*DBListener) Client

func (l *DBListener) Client() *rdb.DBClient

func (*DBListener) SendEvents

func (l *DBListener) SendEvents(events []vo.ExecutionEvent)

SendEvents implements Listener Interface.

func (*DBListener) SyncSchema

func (l *DBListener) SyncSchema() error

SyncSchema implements Listener.

type ExporterService

type ExporterService = *exporterService

type Listener

type Listener interface {
	SendEvents([]vo.ExecutionEvent)
	SyncSchema() error
}

Listener 日志监听器

type QueueListener

type QueueListener struct {
	ContentType string
	// contains filtered or unexported fields
}

func NewQueueListener

func NewQueueListener(queue mq.MessageQueue) *QueueListener

func (*QueueListener) SendEvents

func (q *QueueListener) SendEvents(events []vo.ExecutionEvent)

SendEvents implements Listener Interface.

func (*QueueListener) SyncSchema

func (q *QueueListener) SyncSchema() error

SyncSchema implements Listener.