universal

Documentation

Index

• type Pipeline
  • func Execute(ctx context.Context, p *pipepb.Pipeline, opts beamopts.Struct) (*Pipeline, error)
  • func (p *Pipeline) Cancel(ctx context.Context) (jobpb.JobState_Enum, error)
  • func (p *Pipeline) Metrics(ctx context.Context) (*Results, error)
  • func (p *Pipeline) Wait(ctx context.Context) error
• type Results
  • func (r *Results) Committed(name string) int64
  • func (r *Results) UserCounters() map[string]int64
  • func (r *Results) UserDistributions() map[string]struct{ ... }

Types

type Pipeline

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

func Execute

func Execute(ctx context.Context, p *pipepb.Pipeline, opts beamopts.Struct) (*Pipeline, error)

func (*Pipeline) Cancel

func (p *Pipeline) Cancel(ctx context.Context) (jobpb.JobState_Enum, error)

func (*Pipeline) Metrics

func (p *Pipeline) Metrics(ctx context.Context) (*Results, error)

func (*Pipeline) Wait

func (p *Pipeline) Wait(ctx context.Context) error

type Results

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

func (*Results) Committed

func (r *Results) Committed(name string) int64

func (*Results) UserCounters

func (r *Results) UserCounters() map[string]int64

func (*Results) UserDistributions

func (r *Results) UserDistributions() map[string]struct{ Count, Sum, Min, Max int64 }