load2logs

Documentation

Index

• func ConstructQuery(datasetId string, tableId, uuid string) string
• func HandleLoadEvent(ctx context.Context, e event.Event) error
• func HandleLogLoadEvent(ctx context.Context, e event.Event) error
• func Load2Bq(ctx context.Context, client common.BigQueryClient, srcFileId string, ...) error
• type EnvConfig
  • func NewEnvConfig() (*EnvConfig, error)
• type MessagePublishedData
• type PubSubMessage

Functions

func ConstructQuery

func ConstructQuery(datasetId string, tableId, uuid string) string

func HandleLoadEvent

func HandleLoadEvent(ctx context.Context, e event.Event) error

func HandleLogLoadEvent

func HandleLogLoadEvent(ctx context.Context, e event.Event) error

func Load2Bq

func Load2Bq(ctx context.Context, client common.BigQueryClient, srcFileId string, datasetId string, tableId string) error

Types

type EnvConfig

type EnvConfig struct {
	ProjectID string
	DatasetID string
	TableID   string
}

func NewEnvConfig

func NewEnvConfig() (*EnvConfig, error)

type MessagePublishedData

type MessagePublishedData struct {
	Message PubSubMessage
}

type PubSubMessage

type PubSubMessage struct {
	ID              string
	Data            []byte `json:"data"`
	Attributes      map[string]string
	PublishTime     time.Time
	DeliveryAttempt *int
	OrderingKey     string
}