convox/provider/gcp/log.go

package gcp

import (
	"fmt"
	"io"
	"time"

	"github.com/convox/convox/pkg/structs"
)

func (p *Provider) Log(app, stream string, ts time.Time, message string) error {
	index := fmt.Sprintf("convox.%s.%s", p.Name, app)

	tags := map[string]string{
		"stream": stream,
	}

	if err := p.elastic.Write(index, ts, message, tags); err != nil {
		return err
	}

	return nil
}

func (p *Provider) AppLogs(name string, opts structs.LogsOptions) (io.ReadCloser, error) {
	r, w := io.Pipe()

	go p.elastic.Stream(p.Context(), w, fmt.Sprintf("convox.%s.%s", p.Name, name), opts)

	return r, nil
}

func (p *Provider) SystemLogs(opts structs.LogsOptions) (io.ReadCloser, error) {
	return p.AppLogs("system", opts)
}