sink

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

type DecodedLog struct {
	Log         types.Log           `json:"log"`
	DecodedData *decoder.DecodedLog `json:"decoded,omitempty"`
	EventName   string              `json:"event_name,omitempty"`
}

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

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

type Output interface {
	Name() string
	Send(ctx context.Context, logs []DecodedLog) error
	Close() error
}

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

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

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

type WebhookConfig struct {
	URL            string
	Secret         string
	MaxAttempts    int
	InitialBackoff string
	MaxBackoff     string
	Async          bool
	BufferSize     int
	Workers        int
}

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