bqtail.go

package bqtail

import (
	"cloud.google.com/go/functions/metadata"
	"context"
	"errors"
	"github.com/viant/bqtail/shared"
	"github.com/viant/bqtail/tail"
	"github.com/viant/bqtail/tail/contract"
	_ "github.com/GoogleCloudPlatform/functions-framework-go/funcframework"
)

const maxStackDriver = 265 * 1024

//BqTail storage trigger background cloud function entry point
func BqTail(ctx context.Context, event contract.GSEvent) (err error) {
	meta, err := metadata.FromContext(ctx)
	if err != nil {
		return err
	}
	request := &contract.Request{
		EventID:   meta.EventID,
		SourceURL: event.URL(),
		Started:   meta.Timestamp,
	}

	_, err = handleTailEvent(ctx, request)
	if err != nil {
		return err
	}
	return nil
}

func handleTailEvent(ctx context.Context, request *contract.Request) (*contract.Response, error) {
	service, err := tail.Singleton(ctx)
	if err != nil {
		return nil, err
	}
	response := service.Tail(ctx, request)
	shared.LogLn(response)
	if response.Error != "" {
		return response, errors.New(response.Error)
	}
	return response, nil
}