pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

root.proto

It has these top-level messages:

Benchmark
WriteStatus

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

• func RegisterIngesterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
• func RegisterIngesterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
• func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)
• type Benchmark
  • func (*Benchmark) Descriptor() ([]byte, []int)
  • func (m *Benchmark) GetGoTestBench() *Benchmark_GoTestBench
  • func (m *Benchmark) GetKind() isBenchmark_Kind
  • func (*Benchmark) ProtoMessage()
  • func (m *Benchmark) Reset()
  • func (m *Benchmark) String() string
  • func (*Benchmark) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Benchmark_GoTestBench
  • func (*Benchmark_GoTestBench) Descriptor() ([]byte, []int)
  • func (*Benchmark_GoTestBench) ProtoMessage()
  • func (m *Benchmark_GoTestBench) Reset()
  • func (m *Benchmark_GoTestBench) String() string
• type Benchmark_GoTestBench_
• type IngesterClient
  • func NewIngesterClient(cc *grpc.ClientConn) IngesterClient
• type IngesterServer
• type Ingester_AddBenchmarkClient
• type Ingester_AddBenchmarkServer
• type WriteStatus
  • func (*WriteStatus) Descriptor() ([]byte, []int)
  • func (m *WriteStatus) GetError() string
  • func (m *WriteStatus) GetStats() *WriteStatus_Stats
  • func (m *WriteStatus) GetStatus() isWriteStatus_Status
  • func (*WriteStatus) ProtoMessage()
  • func (m *WriteStatus) Reset()
  • func (m *WriteStatus) String() string
  • func (*WriteStatus) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type WriteStatus_Error
• type WriteStatus_Stats
  • func (*WriteStatus_Stats) Descriptor() ([]byte, []int)
  • func (*WriteStatus_Stats) ProtoMessage()
  • func (m *WriteStatus_Stats) Reset()
  • func (m *WriteStatus_Stats) String() string
• type WriteStatus_Stats_

Functions

func RegisterIngesterHandler

func RegisterIngesterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterIngesterHandler registers the http handlers for service Ingester to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterIngesterHandlerFromEndpoint

func RegisterIngesterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterIngesterHandlerFromEndpoint is same as RegisterIngesterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterIngesterServer

func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)

Types

type Benchmark

type Benchmark struct {
	Project   string `protobuf:"bytes,1,opt,name=project" json:"project,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Kind:
	//	*Benchmark_GoTestBench_
	Kind isBenchmark_Kind `protobuf_oneof:"kind"`
}

func (*Benchmark) Descriptor

func (*Benchmark) Descriptor() ([]byte, []int)

func (*Benchmark) GetGoTestBench

func (m *Benchmark) GetGoTestBench() *Benchmark_GoTestBench

func (*Benchmark) GetKind

func (m *Benchmark) GetKind() isBenchmark_Kind

func (*Benchmark) ProtoMessage

func (*Benchmark) ProtoMessage()

func (*Benchmark) Reset

func (m *Benchmark) Reset()

func (*Benchmark) String

func (m *Benchmark) String() string

func (*Benchmark) XXX_OneofFuncs

func (*Benchmark) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Benchmark_GoTestBench

type Benchmark_GoTestBench struct {
	Name              string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Package           string  `protobuf:"bytes,2,opt,name=package" json:"package,omitempty"`
	N                 uint64  `protobuf:"varint,3,opt,name=n" json:"n,omitempty"`
	NsPerOp           float64 `protobuf:"fixed64,4,opt,name=nsPerOp" json:"nsPerOp,omitempty"`
	AllocedBytesPerOp uint64  `protobuf:"varint,5,opt,name=allocedBytesPerOp" json:"allocedBytesPerOp,omitempty"`
	AllocsPerOp       uint64  `protobuf:"varint,6,opt,name=allocsPerOp" json:"allocsPerOp,omitempty"`
	MbPerS            float64 `protobuf:"fixed64,7,opt,name=mbPerS" json:"mbPerS,omitempty"`
	Measured          int64   `protobuf:"varint,8,opt,name=measured" json:"measured,omitempty"`
}

metric types

func (*Benchmark_GoTestBench) Descriptor

func (*Benchmark_GoTestBench) Descriptor() ([]byte, []int)

func (*Benchmark_GoTestBench) ProtoMessage

func (*Benchmark_GoTestBench) ProtoMessage()

func (*Benchmark_GoTestBench) Reset

func (m *Benchmark_GoTestBench) Reset()

func (*Benchmark_GoTestBench) String

func (m *Benchmark_GoTestBench) String() string

type Benchmark_GoTestBench_

type Benchmark_GoTestBench_ struct {
	GoTestBench *Benchmark_GoTestBench `protobuf:"bytes,3,opt,name=goTestBench,oneof"`
}

type IngesterClient

type IngesterClient interface {
	AddBenchmark(ctx context.Context, opts ...grpc.CallOption) (Ingester_AddBenchmarkClient, error)
}

func NewIngesterClient

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer

type IngesterServer interface {
	AddBenchmark(Ingester_AddBenchmarkServer) error
}

type Ingester_AddBenchmarkClient

type Ingester_AddBenchmarkClient interface {
	Send(*Benchmark) error
	CloseAndRecv() (*WriteStatus, error)
	grpc.ClientStream
}

type Ingester_AddBenchmarkServer

type Ingester_AddBenchmarkServer interface {
	SendAndClose(*WriteStatus) error
	Recv() (*Benchmark, error)
	grpc.ServerStream
}

type WriteStatus

type WriteStatus struct {
	// Types that are valid to be assigned to Status:
	//	*WriteStatus_Stats_
	//	*WriteStatus_Error
	Status isWriteStatus_Status `protobuf_oneof:"status"`
}

func (*WriteStatus) Descriptor

func (*WriteStatus) Descriptor() ([]byte, []int)

func (*WriteStatus) GetError

func (m *WriteStatus) GetError() string

func (*WriteStatus) GetStats

func (m *WriteStatus) GetStats() *WriteStatus_Stats

func (*WriteStatus) GetStatus

func (m *WriteStatus) GetStatus() isWriteStatus_Status

func (*WriteStatus) ProtoMessage

func (*WriteStatus) ProtoMessage()

func (*WriteStatus) Reset

func (m *WriteStatus) Reset()

func (*WriteStatus) String

func (m *WriteStatus) String() string

func (*WriteStatus) XXX_OneofFuncs

func (*WriteStatus) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type WriteStatus_Error

type WriteStatus_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,oneof"`
}

type WriteStatus_Stats

type WriteStatus_Stats struct {
	Written uint64 `protobuf:"varint,1,opt,name=written" json:"written,omitempty"`
}

func (*WriteStatus_Stats) Descriptor

func (*WriteStatus_Stats) Descriptor() ([]byte, []int)

func (*WriteStatus_Stats) ProtoMessage

func (*WriteStatus_Stats) ProtoMessage()

func (*WriteStatus_Stats) Reset

func (m *WriteStatus_Stats) Reset()

func (*WriteStatus_Stats) String

func (m *WriteStatus_Stats) String() string

type WriteStatus_Stats_

type WriteStatus_Stats_ struct {
	Stats *WriteStatus_Stats `protobuf:"bytes,1,opt,name=stats,oneof"`
}