completedaction

Documentation

Index

• type Converter
  • func NewConverter(contentAddressableStorage blobstore.BlobAccess, maximumMessageSizeBytes int) Converter
• type Ingester
  • func NewIngester(uploader elasticsearch.Uploader, converter Converter) *Ingester
  • func (cai *Ingester) LogCompletedActions(stream cal_proto.CompletedActionLogger_LogCompletedActionsServer) error

Types

type Converter

type Converter interface {
	FlattenCompletedAction(ctx context.Context, completedAction *cal_proto.CompletedAction) (map[string]interface{}, error)
}

Converter converts a CompletedAction into a format that is suitable for Elasticsearch.

func NewConverter

func NewConverter(
	contentAddressableStorage blobstore.BlobAccess,
	maximumMessageSizeBytes int,
) Converter

NewConverter creates a new Converter.

type Ingester

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

The Ingester can be used to receive CompletedActions and push them into some database. This allows for realtime or post-build analysis in a remote service. This is particularly useful for understanding how build actions change over time by inspecting the aggregated CompletedAction metadata.

func NewIngester

func NewIngester(
	uploader elasticsearch.Uploader,
	converter Converter,
) *Ingester

NewIngester creates a new Ingester that uploads CompletedActions to Elasticsearch.

func (*Ingester) LogCompletedActions

func (cai *Ingester) LogCompletedActions(stream cal_proto.CompletedActionLogger_LogCompletedActionsServer) error

LogCompletedActions is part of the API of the CompletedActionLogger service.