go-train-delay-listener.go

go-train-delay-listener.go

type Lister struct {
	pubsub *pubsub.Client
	ctx    context.Context
}

func NewPubSub(projectID string) (*Lister, error) {
	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, projectID)

	if err != nil {
		log.Fatalf("[getPubSub] Unable to get pubsub new client: %v", err)
		return nil, err
	}

	return &Lister{
		pubsub: client,
		ctx:    ctx,
	}, nil
}