internal

package
v0.0.0-...-56cf5a6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CompressionType_name = map[int32]string{
	0: "NONE",
	1: "TARGZ",
	2: "ZIP",
	3: "GZ",
	4: "XZ",
}
View Source 
var CompressionType_value = map[string]int32{
	"NONE":  0,
	"TARGZ": 1,
	"ZIP":   2,
	"GZ":    3,
	"XZ":    4,
}
View Source 
var CreateOptions_EventsCollectorType_name = map[int32]string{
	0:  "UNKNOWN_COLLECTOR",
	1:  "BASIC",
	2:  "PASSTHROUGH",
	3:  "SAMPLING_100",
	4:  "SAMPLING_1K",
	5:  "SAMPLING_10K",
	6:  "SAMPLING_100K",
	7:  "RAND_SAMPLING_50",
	8:  "RAND_SAMPLING_25",
	9:  "RAND_SAMPLING_10",
	10: "INTERVAL_100MS",
	11: "INTERVAL_1S",
}
View Source 
var CreateOptions_EventsCollectorType_value = map[string]int32{
	"UNKNOWN_COLLECTOR": 0,
	"BASIC":             1,
	"PASSTHROUGH":       2,
	"SAMPLING_100":      3,
	"SAMPLING_1K":       4,
	"SAMPLING_10K":      5,
	"SAMPLING_100K":     6,
	"RAND_SAMPLING_50":  7,
	"RAND_SAMPLING_25":  8,
	"RAND_SAMPLING_10":  9,
	"INTERVAL_100MS":    10,
	"INTERVAL_1S":       11,
}
View Source 
var CreateOptions_RecorderType_name = map[int32]string{
	0: "UNKNOWN_RECORDER",
	1: "PERF",
	2: "PERF_SINGLE",
	3: "PERF_100MS",
	4: "PERF_1S",
	6: "HISTOGRAM_SINGLE",
	7: "HISTOGRAM_100MS",
	8: "HISTOGRAM_1S",
	9: "INTERVAL_SUMMARIZATION",
}
View Source 
var CreateOptions_RecorderType_value = map[string]int32{
	"UNKNOWN_RECORDER":       0,
	"PERF":                   1,
	"PERF_SINGLE":            2,
	"PERF_100MS":             3,
	"PERF_1S":                4,
	"HISTOGRAM_SINGLE":       6,
	"HISTOGRAM_100MS":        7,
	"HISTOGRAM_1S":           8,
	"INTERVAL_SUMMARIZATION": 9,
}
View Source 
var DataFormat_name = map[int32]string{
	0: "TEXT",
	1: "FTDC",
	2: "BSON",
	3: "JSON",
	4: "CSV",
}
View Source 
var DataFormat_value = map[string]int32{
	"TEXT": 0,
	"FTDC": 1,
	"BSON": 2,
	"JSON": 3,
	"CSV":  4,
}
View Source 
var RollupType_name = map[int32]string{
	0:  "SUM",
	1:  "MEAN",
	2:  "MEDIAN",
	3:  "MAX",
	4:  "MIN",
	5:  "STANDARD_DEVIATION",
	6:  "THROUGHPUT",
	7:  "LATENCY",
	8:  "PERCENTILE_99TH",
	9:  "PERCENTILE_95TH",
	10: "PERCENTILE_90TH",
	11: "PERCENTILE_80TH",
	12: "PERCENTILE_50TH",
}
View Source 
var RollupType_value = map[string]int32{
	"SUM":                0,
	"MEAN":               1,
	"MEDIAN":             2,
	"MAX":                3,
	"MIN":                4,
	"STANDARD_DEVIATION": 5,
	"THROUGHPUT":         6,
	"LATENCY":            7,
	"PERCENTILE_99TH":    8,
	"PERCENTILE_95TH":    9,
	"PERCENTILE_90TH":    10,
	"PERCENTILE_80TH":    11,
	"PERCENTILE_50TH":    12,
}
View Source 
var SchemaType_name = map[int32]string{
	0: "RAW_EVENTS",
	1: "COLLAPSED_EVENTS",
	2: "INTERVAL_SUMMARIZATION",
	3: "HISTOGRAM",
}
View Source 
var SchemaType_value = map[string]int32{
	"RAW_EVENTS":             0,
	"COLLAPSED_EVENTS":       1,
	"INTERVAL_SUMMARIZATION": 2,
	"HISTOGRAM":              3,
}
View Source 
var StorageLocation_name = map[int32]string{
	0: "UNKNOWN",
	1: "CEDAR_S3",
	2: "PROJECT_S3",
	3: "GRIDFS",
	4: "EPHEMERAL",
	5: "LOCAL",
}
View Source 
var StorageLocation_value = map[string]int32{
	"UNKNOWN":    0,
	"CEDAR_S3":   1,
	"PROJECT_S3": 2,
	"GRIDFS":     3,
	"EPHEMERAL":  4,
	"LOCAL":      5,
}

Functions

func AttachService 

func AttachService(registry *poplar.RecorderRegistry, s *grpc.Server) error

func ExportTimestamp 

func ExportTimestamp(t time.Time) (*timestamp.Timestamp, error)

func RegisterCedarPerformanceMetricsServer 

func RegisterCedarPerformanceMetricsServer(s *grpc.Server, srv CedarPerformanceMetricsServer)

func RegisterPoplarEventCollectorServer 

func RegisterPoplarEventCollectorServer(s *grpc.Server, srv PoplarEventCollectorServer)

func RegisterPoplarMetricsCollectorServer 

func RegisterPoplarMetricsCollectorServer(s *grpc.Server, srv PoplarMetricsCollectorServer)

func RegisterPoplarMetricsRecorderServer 

func RegisterPoplarMetricsRecorderServer(s *grpc.Server, srv PoplarMetricsRecorderServer)

Types

type ArtifactData 

type ArtifactData struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Artifacts            []*ArtifactInfo `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ArtifactData) Descriptor 

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

func (*ArtifactData) GetArtifacts 

func (m *ArtifactData) GetArtifacts() []*ArtifactInfo

func (*ArtifactData) GetId 

func (m *ArtifactData) GetId() string

func (*ArtifactData) ProtoMessage 

func (*ArtifactData) ProtoMessage()

func (*ArtifactData) Reset 

func (m *ArtifactData) Reset()

func (*ArtifactData) String 

func (m *ArtifactData) String() string

func (*ArtifactData) XXX_DiscardUnknown 

func (m *ArtifactData) XXX_DiscardUnknown()

func (*ArtifactData) XXX_Marshal 

func (m *ArtifactData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactData) XXX_Merge 

func (m *ArtifactData) XXX_Merge(src proto.Message)

func (*ArtifactData) XXX_Size 

func (m *ArtifactData) XXX_Size() int

func (*ArtifactData) XXX_Unmarshal 

func (m *ArtifactData) XXX_Unmarshal(b []byte) error

type ArtifactInfo 

type ArtifactInfo struct {
	Location             StorageLocation      `protobuf:"varint,1,opt,name=location,proto3,enum=cedar.StorageLocation" json:"location,omitempty"`
	Bucket               string               `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix               string               `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Path                 string               `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	Format               DataFormat           `protobuf:"varint,5,opt,name=format,proto3,enum=cedar.DataFormat" json:"format,omitempty"`
	Compression          CompressionType      `protobuf:"varint,6,opt,name=compression,proto3,enum=cedar.CompressionType" json:"compression,omitempty"`
	Schema               SchemaType           `protobuf:"varint,7,opt,name=schema,proto3,enum=cedar.SchemaType" json:"schema,omitempty"`
	Tags                 []string             `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func ExportArtifactInfo 

func ExportArtifactInfo(in *poplar.TestArtifact) *ArtifactInfo

func (*ArtifactInfo) Descriptor 

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

func (*ArtifactInfo) GetBucket 

func (m *ArtifactInfo) GetBucket() string

func (*ArtifactInfo) GetCompression 

func (m *ArtifactInfo) GetCompression() CompressionType

func (*ArtifactInfo) GetCreatedAt 

func (m *ArtifactInfo) GetCreatedAt() *timestamp.Timestamp

func (*ArtifactInfo) GetFormat 

func (m *ArtifactInfo) GetFormat() DataFormat

func (*ArtifactInfo) GetLocation 

func (m *ArtifactInfo) GetLocation() StorageLocation

func (*ArtifactInfo) GetPath 

func (m *ArtifactInfo) GetPath() string

func (*ArtifactInfo) GetPrefix 

func (m *ArtifactInfo) GetPrefix() string

func (*ArtifactInfo) GetSchema 

func (m *ArtifactInfo) GetSchema() SchemaType

func (*ArtifactInfo) GetTags 

func (m *ArtifactInfo) GetTags() []string

func (*ArtifactInfo) ProtoMessage 

func (*ArtifactInfo) ProtoMessage()

func (*ArtifactInfo) Reset 

func (m *ArtifactInfo) Reset()

func (*ArtifactInfo) String 

func (m *ArtifactInfo) String() string

func (*ArtifactInfo) XXX_DiscardUnknown 

func (m *ArtifactInfo) XXX_DiscardUnknown()

func (*ArtifactInfo) XXX_Marshal 

func (m *ArtifactInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactInfo) XXX_Merge 

func (m *ArtifactInfo) XXX_Merge(src proto.Message)

func (*ArtifactInfo) XXX_Size 

func (m *ArtifactInfo) XXX_Size() int

func (*ArtifactInfo) XXX_Unmarshal 

func (m *ArtifactInfo) XXX_Unmarshal(b []byte) error

type CedarPerformanceMetricsClient 

type CedarPerformanceMetricsClient interface {
	CreateMetricSeries(ctx context.Context, in *ResultData, opts ...grpc.CallOption) (*MetricsResponse, error)
	AttachResultData(ctx context.Context, in *ResultData, opts ...grpc.CallOption) (*MetricsResponse, error)
	AttachArtifacts(ctx context.Context, in *ArtifactData, opts ...grpc.CallOption) (*MetricsResponse, error)
	AttachRollups(ctx context.Context, in *RollupData, opts ...grpc.CallOption) (*MetricsResponse, error)
	SendMetrics(ctx context.Context, opts ...grpc.CallOption) (CedarPerformanceMetrics_SendMetricsClient, error)
	CloseMetrics(ctx context.Context, in *MetricsSeriesEnd, opts ...grpc.CallOption) (*MetricsResponse, error)
}

CedarPerformanceMetricsClient is the client API for CedarPerformanceMetrics service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCedarPerformanceMetricsClient 

func NewCedarPerformanceMetricsClient(cc *grpc.ClientConn) CedarPerformanceMetricsClient

type CedarPerformanceMetricsServer 

type CedarPerformanceMetricsServer interface {
	CreateMetricSeries(context.Context, *ResultData) (*MetricsResponse, error)
	AttachResultData(context.Context, *ResultData) (*MetricsResponse, error)
	AttachArtifacts(context.Context, *ArtifactData) (*MetricsResponse, error)
	AttachRollups(context.Context, *RollupData) (*MetricsResponse, error)
	SendMetrics(CedarPerformanceMetrics_SendMetricsServer) error
	CloseMetrics(context.Context, *MetricsSeriesEnd) (*MetricsResponse, error)
}

CedarPerformanceMetricsServer is the server API for CedarPerformanceMetrics service.

type CedarPerformanceMetrics_SendMetricsClient 

type CedarPerformanceMetrics_SendMetricsClient interface {
	Send(*MetricsEvent) error
	CloseAndRecv() (*SendResponse, error)
	grpc.ClientStream
}

type CedarPerformanceMetrics_SendMetricsServer 

type CedarPerformanceMetrics_SendMetricsServer interface {
	SendAndClose(*SendResponse) error
	Recv() (*MetricsEvent, error)
	grpc.ServerStream
}

type CompressionType 

type CompressionType int32
const (
	CompressionType_NONE  CompressionType = 0
	CompressionType_TARGZ CompressionType = 1
	CompressionType_ZIP   CompressionType = 2
	CompressionType_GZ    CompressionType = 3
	CompressionType_XZ    CompressionType = 4
)

func (CompressionType) EnumDescriptor 

func (CompressionType) EnumDescriptor() ([]byte, []int)

func (CompressionType) String 

func (x CompressionType) String() string

type CreateOptions 

type CreateOptions struct {
	Name                 string                            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path                 string                            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ChunkSize            int32                             `protobuf:"varint,3,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	Streaming            bool                              `protobuf:"varint,4,opt,name=streaming,proto3" json:"streaming,omitempty"`
	Dynamic              bool                              `protobuf:"varint,5,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	Recorder             CreateOptions_RecorderType        `protobuf:"varint,6,opt,name=recorder,proto3,enum=poplar.CreateOptions_RecorderType" json:"recorder,omitempty"`
	Events               CreateOptions_EventsCollectorType `protobuf:"varint,7,opt,name=events,proto3,enum=poplar.CreateOptions_EventsCollectorType" json:"events,omitempty"`
	Buffered             bool                              `protobuf:"varint,8,opt,name=buffered,proto3" json:"buffered,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*CreateOptions) Descriptor 

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

func (*CreateOptions) Export 

func (opts *CreateOptions) Export() poplar.CreateOptions

func (*CreateOptions) GetBuffered 

func (m *CreateOptions) GetBuffered() bool

func (*CreateOptions) GetChunkSize 

func (m *CreateOptions) GetChunkSize() int32

func (*CreateOptions) GetDynamic 

func (m *CreateOptions) GetDynamic() bool

func (*CreateOptions) GetEvents 

func (m *CreateOptions) GetEvents() CreateOptions_EventsCollectorType

func (*CreateOptions) GetName 

func (m *CreateOptions) GetName() string

func (*CreateOptions) GetPath 

func (m *CreateOptions) GetPath() string

func (*CreateOptions) GetRecorder 

func (m *CreateOptions) GetRecorder() CreateOptions_RecorderType

func (*CreateOptions) GetStreaming 

func (m *CreateOptions) GetStreaming() bool

func (*CreateOptions) ProtoMessage 

func (*CreateOptions) ProtoMessage()

func (*CreateOptions) Reset 

func (m *CreateOptions) Reset()

func (*CreateOptions) String 

func (m *CreateOptions) String() string

func (*CreateOptions) XXX_DiscardUnknown 

func (m *CreateOptions) XXX_DiscardUnknown()

func (*CreateOptions) XXX_Marshal 

func (m *CreateOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateOptions) XXX_Merge 

func (m *CreateOptions) XXX_Merge(src proto.Message)

func (*CreateOptions) XXX_Size 

func (m *CreateOptions) XXX_Size() int

func (*CreateOptions) XXX_Unmarshal 

func (m *CreateOptions) XXX_Unmarshal(b []byte) error

type CreateOptions_EventsCollectorType 

type CreateOptions_EventsCollectorType int32
const (
	CreateOptions_UNKNOWN_COLLECTOR CreateOptions_EventsCollectorType = 0
	CreateOptions_BASIC             CreateOptions_EventsCollectorType = 1
	CreateOptions_PASSTHROUGH       CreateOptions_EventsCollectorType = 2
	CreateOptions_SAMPLING_100      CreateOptions_EventsCollectorType = 3
	CreateOptions_SAMPLING_1K       CreateOptions_EventsCollectorType = 4
	CreateOptions_SAMPLING_10K      CreateOptions_EventsCollectorType = 5
	CreateOptions_SAMPLING_100K     CreateOptions_EventsCollectorType = 6
	CreateOptions_RAND_SAMPLING_50  CreateOptions_EventsCollectorType = 7
	CreateOptions_RAND_SAMPLING_25  CreateOptions_EventsCollectorType = 8
	CreateOptions_RAND_SAMPLING_10  CreateOptions_EventsCollectorType = 9
	CreateOptions_INTERVAL_100MS    CreateOptions_EventsCollectorType = 10
	CreateOptions_INTERVAL_1S       CreateOptions_EventsCollectorType = 11
)

func (CreateOptions_EventsCollectorType) EnumDescriptor 

func (CreateOptions_EventsCollectorType) EnumDescriptor() ([]byte, []int)

func (CreateOptions_EventsCollectorType) Export 

func (ect CreateOptions_EventsCollectorType) Export() poplar.EventsCollectorType

func (CreateOptions_EventsCollectorType) String 

func (x CreateOptions_EventsCollectorType) String() string

type CreateOptions_RecorderType 

type CreateOptions_RecorderType int32
const (
	CreateOptions_UNKNOWN_RECORDER       CreateOptions_RecorderType = 0
	CreateOptions_PERF                   CreateOptions_RecorderType = 1
	CreateOptions_PERF_SINGLE            CreateOptions_RecorderType = 2
	CreateOptions_PERF_100MS             CreateOptions_RecorderType = 3
	CreateOptions_PERF_1S                CreateOptions_RecorderType = 4
	CreateOptions_HISTOGRAM_SINGLE       CreateOptions_RecorderType = 6
	CreateOptions_HISTOGRAM_100MS        CreateOptions_RecorderType = 7
	CreateOptions_HISTOGRAM_1S           CreateOptions_RecorderType = 8
	CreateOptions_INTERVAL_SUMMARIZATION CreateOptions_RecorderType = 9
)

func (CreateOptions_RecorderType) EnumDescriptor 

func (CreateOptions_RecorderType) EnumDescriptor() ([]byte, []int)

func (CreateOptions_RecorderType) Export 

func (rt CreateOptions_RecorderType) Export() poplar.RecorderType

func (CreateOptions_RecorderType) String 

func (x CreateOptions_RecorderType) String() string

type DataFormat 

type DataFormat int32
const (
	DataFormat_TEXT DataFormat = 0
	DataFormat_FTDC DataFormat = 1
	DataFormat_BSON DataFormat = 2
	DataFormat_JSON DataFormat = 3
	DataFormat_CSV  DataFormat = 4
)

func (DataFormat) EnumDescriptor 

func (DataFormat) EnumDescriptor() ([]byte, []int)

func (DataFormat) String 

func (x DataFormat) String() string

type EventMetrics 

type EventMetrics struct {
	Name                 string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Time                 *timestamp.Timestamp  `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	Id                   int64                 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Counters             *EventMetricsCounters `protobuf:"bytes,4,opt,name=counters,proto3" json:"counters,omitempty"`
	Timers               *EventMetricsTimers   `protobuf:"bytes,5,opt,name=timers,proto3" json:"timers,omitempty"`
	Gauges               *EventMetricsGauges   `protobuf:"bytes,6,opt,name=gauges,proto3" json:"gauges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*EventMetrics) Descriptor 

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

func (*EventMetrics) Export 

func (m *EventMetrics) Export() *events.Performance

func (*EventMetrics) GetCounters 

func (m *EventMetrics) GetCounters() *EventMetricsCounters

func (*EventMetrics) GetGauges 

func (m *EventMetrics) GetGauges() *EventMetricsGauges

func (*EventMetrics) GetId 

func (m *EventMetrics) GetId() int64

func (*EventMetrics) GetName 

func (m *EventMetrics) GetName() string

func (*EventMetrics) GetTime 

func (m *EventMetrics) GetTime() *timestamp.Timestamp

func (*EventMetrics) GetTimers 

func (m *EventMetrics) GetTimers() *EventMetricsTimers

func (*EventMetrics) ProtoMessage 

func (*EventMetrics) ProtoMessage()

func (*EventMetrics) Reset 

func (m *EventMetrics) Reset()

func (*EventMetrics) String 

func (m *EventMetrics) String() string

func (*EventMetrics) XXX_DiscardUnknown 

func (m *EventMetrics) XXX_DiscardUnknown()

func (*EventMetrics) XXX_Marshal 

func (m *EventMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventMetrics) XXX_Merge 

func (m *EventMetrics) XXX_Merge(src proto.Message)

func (*EventMetrics) XXX_Size 

func (m *EventMetrics) XXX_Size() int

func (*EventMetrics) XXX_Unmarshal 

func (m *EventMetrics) XXX_Unmarshal(b []byte) error

type EventMetricsCounters 

type EventMetricsCounters struct {
	Number               int64    `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	Ops                  int64    `protobuf:"varint,2,opt,name=ops,proto3" json:"ops,omitempty"`
	Size                 int64    `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Errors               int64    `protobuf:"varint,4,opt,name=errors,proto3" json:"errors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventMetricsCounters) Descriptor 

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

func (*EventMetricsCounters) GetErrors 

func (m *EventMetricsCounters) GetErrors() int64

func (*EventMetricsCounters) GetNumber 

func (m *EventMetricsCounters) GetNumber() int64

func (*EventMetricsCounters) GetOps 

func (m *EventMetricsCounters) GetOps() int64

func (*EventMetricsCounters) GetSize 

func (m *EventMetricsCounters) GetSize() int64

func (*EventMetricsCounters) ProtoMessage 

func (*EventMetricsCounters) ProtoMessage()

func (*EventMetricsCounters) Reset 

func (m *EventMetricsCounters) Reset()

func (*EventMetricsCounters) String 

func (m *EventMetricsCounters) String() string

func (*EventMetricsCounters) XXX_DiscardUnknown 

func (m *EventMetricsCounters) XXX_DiscardUnknown()

func (*EventMetricsCounters) XXX_Marshal 

func (m *EventMetricsCounters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventMetricsCounters) XXX_Merge 

func (m *EventMetricsCounters) XXX_Merge(src proto.Message)

func (*EventMetricsCounters) XXX_Size 

func (m *EventMetricsCounters) XXX_Size() int

func (*EventMetricsCounters) XXX_Unmarshal 

func (m *EventMetricsCounters) XXX_Unmarshal(b []byte) error

type EventMetricsGauges 

type EventMetricsGauges struct {
	State                int64    `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	Workers              int64    `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	Failed               bool     `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventMetricsGauges) Descriptor 

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

func (*EventMetricsGauges) GetFailed 

func (m *EventMetricsGauges) GetFailed() bool

func (*EventMetricsGauges) GetState 

func (m *EventMetricsGauges) GetState() int64

func (*EventMetricsGauges) GetWorkers 

func (m *EventMetricsGauges) GetWorkers() int64

func (*EventMetricsGauges) ProtoMessage 

func (*EventMetricsGauges) ProtoMessage()

func (*EventMetricsGauges) Reset 

func (m *EventMetricsGauges) Reset()

func (*EventMetricsGauges) String 

func (m *EventMetricsGauges) String() string

func (*EventMetricsGauges) XXX_DiscardUnknown 

func (m *EventMetricsGauges) XXX_DiscardUnknown()

func (*EventMetricsGauges) XXX_Marshal 

func (m *EventMetricsGauges) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventMetricsGauges) XXX_Merge 

func (m *EventMetricsGauges) XXX_Merge(src proto.Message)

func (*EventMetricsGauges) XXX_Size 

func (m *EventMetricsGauges) XXX_Size() int

func (*EventMetricsGauges) XXX_Unmarshal 

func (m *EventMetricsGauges) XXX_Unmarshal(b []byte) error

type EventMetricsTimers 

type EventMetricsTimers struct {
	Total                *duration.Duration `protobuf:"bytes,1,opt,name=total,proto3" json:"total,omitempty"`
	Duration             *duration.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EventMetricsTimers) Descriptor 

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

func (*EventMetricsTimers) GetDuration 

func (m *EventMetricsTimers) GetDuration() *duration.Duration

func (*EventMetricsTimers) GetTotal 

func (m *EventMetricsTimers) GetTotal() *duration.Duration

func (*EventMetricsTimers) ProtoMessage 

func (*EventMetricsTimers) ProtoMessage()

func (*EventMetricsTimers) Reset 

func (m *EventMetricsTimers) Reset()

func (*EventMetricsTimers) String 

func (m *EventMetricsTimers) String() string

func (*EventMetricsTimers) XXX_DiscardUnknown 

func (m *EventMetricsTimers) XXX_DiscardUnknown()

func (*EventMetricsTimers) XXX_Marshal 

func (m *EventMetricsTimers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventMetricsTimers) XXX_Merge 

func (m *EventMetricsTimers) XXX_Merge(src proto.Message)

func (*EventMetricsTimers) XXX_Size 

func (m *EventMetricsTimers) XXX_Size() int

func (*EventMetricsTimers) XXX_Unmarshal 

func (m *EventMetricsTimers) XXX_Unmarshal(b []byte) error

type EventSendBool 

type EventSendBool struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                bool     `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventSendBool) Descriptor 

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

func (*EventSendBool) GetName 

func (m *EventSendBool) GetName() string

func (*EventSendBool) GetValue 

func (m *EventSendBool) GetValue() bool

func (*EventSendBool) ProtoMessage 

func (*EventSendBool) ProtoMessage()

func (*EventSendBool) Reset 

func (m *EventSendBool) Reset()

func (*EventSendBool) String 

func (m *EventSendBool) String() string

func (*EventSendBool) XXX_DiscardUnknown 

func (m *EventSendBool) XXX_DiscardUnknown()

func (*EventSendBool) XXX_Marshal 

func (m *EventSendBool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSendBool) XXX_Merge 

func (m *EventSendBool) XXX_Merge(src proto.Message)

func (*EventSendBool) XXX_Size 

func (m *EventSendBool) XXX_Size() int

func (*EventSendBool) XXX_Unmarshal 

func (m *EventSendBool) XXX_Unmarshal(b []byte) error

type EventSendDuration 

type EventSendDuration struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Duration             *duration.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EventSendDuration) Descriptor 

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

func (*EventSendDuration) GetDuration 

func (m *EventSendDuration) GetDuration() *duration.Duration

func (*EventSendDuration) GetName 

func (m *EventSendDuration) GetName() string

func (*EventSendDuration) ProtoMessage 

func (*EventSendDuration) ProtoMessage()

func (*EventSendDuration) Reset 

func (m *EventSendDuration) Reset()

func (*EventSendDuration) String 

func (m *EventSendDuration) String() string

func (*EventSendDuration) XXX_DiscardUnknown 

func (m *EventSendDuration) XXX_DiscardUnknown()

func (*EventSendDuration) XXX_Marshal 

func (m *EventSendDuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSendDuration) XXX_Merge 

func (m *EventSendDuration) XXX_Merge(src proto.Message)

func (*EventSendDuration) XXX_Size 

func (m *EventSendDuration) XXX_Size() int

func (*EventSendDuration) XXX_Unmarshal 

func (m *EventSendDuration) XXX_Unmarshal(b []byte) error

type EventSendInt 

type EventSendInt struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                int64    `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventSendInt) Descriptor 

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

func (*EventSendInt) GetName 

func (m *EventSendInt) GetName() string

func (*EventSendInt) GetValue 

func (m *EventSendInt) GetValue() int64

func (*EventSendInt) ProtoMessage 

func (*EventSendInt) ProtoMessage()

func (*EventSendInt) Reset 

func (m *EventSendInt) Reset()

func (*EventSendInt) String 

func (m *EventSendInt) String() string

func (*EventSendInt) XXX_DiscardUnknown 

func (m *EventSendInt) XXX_DiscardUnknown()

func (*EventSendInt) XXX_Marshal 

func (m *EventSendInt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSendInt) XXX_Merge 

func (m *EventSendInt) XXX_Merge(src proto.Message)

func (*EventSendInt) XXX_Size 

func (m *EventSendInt) XXX_Size() int

func (*EventSendInt) XXX_Unmarshal 

func (m *EventSendInt) XXX_Unmarshal(b []byte) error

type EventSendTime 

type EventSendTime struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Time                 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*EventSendTime) Descriptor 

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

func (*EventSendTime) GetName 

func (m *EventSendTime) GetName() string

func (*EventSendTime) GetTime 

func (m *EventSendTime) GetTime() *timestamp.Timestamp

func (*EventSendTime) ProtoMessage 

func (*EventSendTime) ProtoMessage()

func (*EventSendTime) Reset 

func (m *EventSendTime) Reset()

func (*EventSendTime) String 

func (m *EventSendTime) String() string

func (*EventSendTime) XXX_DiscardUnknown 

func (m *EventSendTime) XXX_DiscardUnknown()

func (*EventSendTime) XXX_Marshal 

func (m *EventSendTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventSendTime) XXX_Merge 

func (m *EventSendTime) XXX_Merge(src proto.Message)

func (*EventSendTime) XXX_Size 

func (m *EventSendTime) XXX_Size() int

func (*EventSendTime) XXX_Unmarshal 

func (m *EventSendTime) XXX_Unmarshal(b []byte) error

type IntervalSummary 

type IntervalSummary struct {
	Collector string `protobuf:"bytes,1,opt,name=collector,proto3" json:"collector,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*IntervalSummary_Number
	//	*IntervalSummary_NumberValues
	//	*IntervalSummary_Point
	//	*IntervalSummary_PointValues
	Value                isIntervalSummary_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*IntervalSummary) Descriptor 

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

func (*IntervalSummary) GetCollector 

func (m *IntervalSummary) GetCollector() string

func (*IntervalSummary) GetNumber 

func (m *IntervalSummary) GetNumber() *SummaryInteger

func (*IntervalSummary) GetNumberValues 

func (m *IntervalSummary) GetNumberValues() *SummaryIntegerSlice

func (*IntervalSummary) GetPoint 

func (m *IntervalSummary) GetPoint() *SummaryDouble

func (*IntervalSummary) GetPointValues 

func (m *IntervalSummary) GetPointValues() *SummaryDoubleSlice

func (*IntervalSummary) GetValue 

func (m *IntervalSummary) GetValue() isIntervalSummary_Value

func (*IntervalSummary) ProtoMessage 

func (*IntervalSummary) ProtoMessage()

func (*IntervalSummary) Reset 

func (m *IntervalSummary) Reset()

func (*IntervalSummary) String 

func (m *IntervalSummary) String() string

func (*IntervalSummary) XXX_DiscardUnknown 

func (m *IntervalSummary) XXX_DiscardUnknown()

func (*IntervalSummary) XXX_Marshal 

func (m *IntervalSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IntervalSummary) XXX_Merge 

func (m *IntervalSummary) XXX_Merge(src proto.Message)

func (*IntervalSummary) XXX_OneofWrappers 

func (*IntervalSummary) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*IntervalSummary) XXX_Size 

func (m *IntervalSummary) XXX_Size() int

func (*IntervalSummary) XXX_Unmarshal 

func (m *IntervalSummary) XXX_Unmarshal(b []byte) error

type IntervalSummary_Number 

type IntervalSummary_Number struct {
	Number *SummaryInteger `protobuf:"bytes,2,opt,name=number,proto3,oneof"`
}

type IntervalSummary_NumberValues 

type IntervalSummary_NumberValues struct {
	NumberValues *SummaryIntegerSlice `protobuf:"bytes,3,opt,name=number_values,json=numberValues,proto3,oneof"`
}

type IntervalSummary_Point 

type IntervalSummary_Point struct {
	Point *SummaryDouble `protobuf:"bytes,4,opt,name=point,proto3,oneof"`
}

type IntervalSummary_PointValues 

type IntervalSummary_PointValues struct {
	PointValues *SummaryDoubleSlice `protobuf:"bytes,5,opt,name=point_values,json=pointValues,proto3,oneof"`
}

type MetricsCounters 

type MetricsCounters struct {
	Ops                  int64    `protobuf:"varint,1,opt,name=ops,proto3" json:"ops,omitempty"`
	Size                 int64    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Errors               int64    `protobuf:"varint,3,opt,name=errors,proto3" json:"errors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetricsCounters) Descriptor 

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

func (*MetricsCounters) GetErrors 

func (m *MetricsCounters) GetErrors() int64

func (*MetricsCounters) GetOps 

func (m *MetricsCounters) GetOps() int64

func (*MetricsCounters) GetSize 

func (m *MetricsCounters) GetSize() int64

func (*MetricsCounters) ProtoMessage 

func (*MetricsCounters) ProtoMessage()

func (*MetricsCounters) Reset 

func (m *MetricsCounters) Reset()

func (*MetricsCounters) String 

func (m *MetricsCounters) String() string

func (*MetricsCounters) XXX_DiscardUnknown 

func (m *MetricsCounters) XXX_DiscardUnknown()

func (*MetricsCounters) XXX_Marshal 

func (m *MetricsCounters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsCounters) XXX_Merge 

func (m *MetricsCounters) XXX_Merge(src proto.Message)

func (*MetricsCounters) XXX_Size 

func (m *MetricsCounters) XXX_Size() int

func (*MetricsCounters) XXX_Unmarshal 

func (m *MetricsCounters) XXX_Unmarshal(b []byte) error

type MetricsEvent 

type MetricsEvent struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Event                []*MetricsPoint `protobuf:"bytes,3,rep,name=Event,proto3" json:"Event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MetricsEvent) Descriptor 

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

func (*MetricsEvent) GetEvent 

func (m *MetricsEvent) GetEvent() []*MetricsPoint

func (*MetricsEvent) GetId 

func (m *MetricsEvent) GetId() string

func (*MetricsEvent) ProtoMessage 

func (*MetricsEvent) ProtoMessage()

func (*MetricsEvent) Reset 

func (m *MetricsEvent) Reset()

func (*MetricsEvent) String 

func (m *MetricsEvent) String() string

func (*MetricsEvent) XXX_DiscardUnknown 

func (m *MetricsEvent) XXX_DiscardUnknown()

func (*MetricsEvent) XXX_Marshal 

func (m *MetricsEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsEvent) XXX_Merge 

func (m *MetricsEvent) XXX_Merge(src proto.Message)

func (*MetricsEvent) XXX_Size 

func (m *MetricsEvent) XXX_Size() int

func (*MetricsEvent) XXX_Unmarshal 

func (m *MetricsEvent) XXX_Unmarshal(b []byte) error

type MetricsGauges 

type MetricsGauges struct {
	State                int64    `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	Workers              int64    `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	Failed               bool     `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetricsGauges) Descriptor 

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

func (*MetricsGauges) GetFailed 

func (m *MetricsGauges) GetFailed() bool

func (*MetricsGauges) GetState 

func (m *MetricsGauges) GetState() int64

func (*MetricsGauges) GetWorkers 

func (m *MetricsGauges) GetWorkers() int64

func (*MetricsGauges) ProtoMessage 

func (*MetricsGauges) ProtoMessage()

func (*MetricsGauges) Reset 

func (m *MetricsGauges) Reset()

func (*MetricsGauges) String 

func (m *MetricsGauges) String() string

func (*MetricsGauges) XXX_DiscardUnknown 

func (m *MetricsGauges) XXX_DiscardUnknown()

func (*MetricsGauges) XXX_Marshal 

func (m *MetricsGauges) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsGauges) XXX_Merge 

func (m *MetricsGauges) XXX_Merge(src proto.Message)

func (*MetricsGauges) XXX_Size 

func (m *MetricsGauges) XXX_Size() int

func (*MetricsGauges) XXX_Unmarshal 

func (m *MetricsGauges) XXX_Unmarshal(b []byte) error

type MetricsPoint 

type MetricsPoint struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=Time,proto3" json:"Time,omitempty"`
	Counters             *MetricsCounters     `protobuf:"bytes,2,opt,name=counters,proto3" json:"counters,omitempty"`
	Timers               *MetricsTimers       `protobuf:"bytes,3,opt,name=timers,proto3" json:"timers,omitempty"`
	Gauges               *MetricsGauges       `protobuf:"bytes,4,opt,name=gauges,proto3" json:"gauges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*MetricsPoint) Descriptor 

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

func (*MetricsPoint) GetCounters 

func (m *MetricsPoint) GetCounters() *MetricsCounters

func (*MetricsPoint) GetGauges 

func (m *MetricsPoint) GetGauges() *MetricsGauges

func (*MetricsPoint) GetTime 

func (m *MetricsPoint) GetTime() *timestamp.Timestamp

func (*MetricsPoint) GetTimers 

func (m *MetricsPoint) GetTimers() *MetricsTimers

func (*MetricsPoint) ProtoMessage 

func (*MetricsPoint) ProtoMessage()

func (*MetricsPoint) Reset 

func (m *MetricsPoint) Reset()

func (*MetricsPoint) String 

func (m *MetricsPoint) String() string

func (*MetricsPoint) XXX_DiscardUnknown 

func (m *MetricsPoint) XXX_DiscardUnknown()

func (*MetricsPoint) XXX_Marshal 

func (m *MetricsPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsPoint) XXX_Merge 

func (m *MetricsPoint) XXX_Merge(src proto.Message)

func (*MetricsPoint) XXX_Size 

func (m *MetricsPoint) XXX_Size() int

func (*MetricsPoint) XXX_Unmarshal 

func (m *MetricsPoint) XXX_Unmarshal(b []byte) error

type MetricsResponse 

type MetricsResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success              bool     `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetricsResponse) Descriptor 

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

func (*MetricsResponse) GetId 

func (m *MetricsResponse) GetId() string

func (*MetricsResponse) GetSuccess 

func (m *MetricsResponse) GetSuccess() bool

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) Reset 

func (m *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (m *MetricsResponse) String() string

func (*MetricsResponse) XXX_DiscardUnknown 

func (m *MetricsResponse) XXX_DiscardUnknown()

func (*MetricsResponse) XXX_Marshal 

func (m *MetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsResponse) XXX_Merge 

func (m *MetricsResponse) XXX_Merge(src proto.Message)

func (*MetricsResponse) XXX_Size 

func (m *MetricsResponse) XXX_Size() int

func (*MetricsResponse) XXX_Unmarshal 

func (m *MetricsResponse) XXX_Unmarshal(b []byte) error

type MetricsSeriesEnd 

type MetricsSeriesEnd struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IsComplete           bool                 `protobuf:"varint,2,opt,name=is_complete,json=isComplete,proto3" json:"is_complete,omitempty"`
	CompletedAt          *timestamp.Timestamp `protobuf:"bytes,3,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*MetricsSeriesEnd) Descriptor 

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

func (*MetricsSeriesEnd) GetCompletedAt 

func (m *MetricsSeriesEnd) GetCompletedAt() *timestamp.Timestamp

func (*MetricsSeriesEnd) GetId 

func (m *MetricsSeriesEnd) GetId() string

func (*MetricsSeriesEnd) GetIsComplete 

func (m *MetricsSeriesEnd) GetIsComplete() bool

func (*MetricsSeriesEnd) ProtoMessage 

func (*MetricsSeriesEnd) ProtoMessage()

func (*MetricsSeriesEnd) Reset 

func (m *MetricsSeriesEnd) Reset()

func (*MetricsSeriesEnd) String 

func (m *MetricsSeriesEnd) String() string

func (*MetricsSeriesEnd) XXX_DiscardUnknown 

func (m *MetricsSeriesEnd) XXX_DiscardUnknown()

func (*MetricsSeriesEnd) XXX_Marshal 

func (m *MetricsSeriesEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsSeriesEnd) XXX_Merge 

func (m *MetricsSeriesEnd) XXX_Merge(src proto.Message)

func (*MetricsSeriesEnd) XXX_Size 

func (m *MetricsSeriesEnd) XXX_Size() int

func (*MetricsSeriesEnd) XXX_Unmarshal 

func (m *MetricsSeriesEnd) XXX_Unmarshal(b []byte) error

type MetricsTimers 

type MetricsTimers struct {
	Duration             *duration.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Total                *duration.Duration `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*MetricsTimers) Descriptor 

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

func (*MetricsTimers) GetDuration 

func (m *MetricsTimers) GetDuration() *duration.Duration

func (*MetricsTimers) GetTotal 

func (m *MetricsTimers) GetTotal() *duration.Duration

func (*MetricsTimers) ProtoMessage 

func (*MetricsTimers) ProtoMessage()

func (*MetricsTimers) Reset 

func (m *MetricsTimers) Reset()

func (*MetricsTimers) String 

func (m *MetricsTimers) String() string

func (*MetricsTimers) XXX_DiscardUnknown 

func (m *MetricsTimers) XXX_DiscardUnknown()

func (*MetricsTimers) XXX_Marshal 

func (m *MetricsTimers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsTimers) XXX_Merge 

func (m *MetricsTimers) XXX_Merge(src proto.Message)

func (*MetricsTimers) XXX_Size 

func (m *MetricsTimers) XXX_Size() int

func (*MetricsTimers) XXX_Unmarshal 

func (m *MetricsTimers) XXX_Unmarshal(b []byte) error

type PoplarEventCollectorClient 

type PoplarEventCollectorClient interface {
	CreateCollector(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	SendEvent(ctx context.Context, in *EventMetrics, opts ...grpc.CallOption) (*PoplarResponse, error)
	StreamEvents(ctx context.Context, opts ...grpc.CallOption) (PoplarEventCollector_StreamEventsClient, error)
	CloseCollector(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarEventCollectorClient is the client API for PoplarEventCollector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPoplarEventCollectorClient 

func NewPoplarEventCollectorClient(cc *grpc.ClientConn) PoplarEventCollectorClient

type PoplarEventCollectorServer 

type PoplarEventCollectorServer interface {
	CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
	SendEvent(context.Context, *EventMetrics) (*PoplarResponse, error)
	StreamEvents(PoplarEventCollector_StreamEventsServer) error
	CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
}

PoplarEventCollectorServer is the server API for PoplarEventCollector service.

type PoplarEventCollector_StreamEventsClient 

type PoplarEventCollector_StreamEventsClient interface {
	Send(*EventMetrics) error
	CloseAndRecv() (*PoplarResponse, error)
	grpc.ClientStream
}

type PoplarEventCollector_StreamEventsServer 

type PoplarEventCollector_StreamEventsServer interface {
	SendAndClose(*PoplarResponse) error
	Recv() (*EventMetrics, error)
	grpc.ServerStream
}

type PoplarID 

type PoplarID struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PoplarID) Descriptor 

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

func (*PoplarID) GetName 

func (m *PoplarID) GetName() string

func (*PoplarID) ProtoMessage 

func (*PoplarID) ProtoMessage()

func (*PoplarID) Reset 

func (m *PoplarID) Reset()

func (*PoplarID) String 

func (m *PoplarID) String() string

func (*PoplarID) XXX_DiscardUnknown 

func (m *PoplarID) XXX_DiscardUnknown()

func (*PoplarID) XXX_Marshal 

func (m *PoplarID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoplarID) XXX_Merge 

func (m *PoplarID) XXX_Merge(src proto.Message)

func (*PoplarID) XXX_Size 

func (m *PoplarID) XXX_Size() int

func (*PoplarID) XXX_Unmarshal 

func (m *PoplarID) XXX_Unmarshal(b []byte) error

type PoplarMetricsCollectorClient 

type PoplarMetricsCollectorClient interface {
	CreateCollector(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	CloseCollector(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	ResetSample(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	FlushSample(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	Add(ctx context.Context, in *IntervalSummary, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarMetricsCollectorClient is the client API for PoplarMetricsCollector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPoplarMetricsCollectorClient 

func NewPoplarMetricsCollectorClient(cc *grpc.ClientConn) PoplarMetricsCollectorClient

type PoplarMetricsCollectorServer 

type PoplarMetricsCollectorServer interface {
	CreateCollector(context.Context, *CreateOptions) (*PoplarResponse, error)
	CloseCollector(context.Context, *PoplarID) (*PoplarResponse, error)
	ResetSample(context.Context, *PoplarID) (*PoplarResponse, error)
	FlushSample(context.Context, *PoplarID) (*PoplarResponse, error)
	Add(context.Context, *IntervalSummary) (*PoplarResponse, error)
}

PoplarMetricsCollectorServer is the server API for PoplarMetricsCollector service.

type PoplarMetricsRecorderClient 

type PoplarMetricsRecorderClient interface {
	// Create builds a new recorder instance which creates a local file,
	// while the close recorder method flushes the contents of that
	// recorder and closes the file.
	CreateRecorder(ctx context.Context, in *CreateOptions, opts ...grpc.CallOption) (*PoplarResponse, error)
	CloseRecorder(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Event Lifecycle methods
	BeginEvent(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	ResetEvent(ctx context.Context, in *PoplarID, opts ...grpc.CallOption) (*PoplarResponse, error)
	EndEvent(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetID(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Timers
	SetTime(ctx context.Context, in *EventSendTime, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetDuration(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetTotalDuration(ctx context.Context, in *EventSendDuration, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Guages
	SetState(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetWorkers(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	SetFailed(ctx context.Context, in *EventSendBool, opts ...grpc.CallOption) (*PoplarResponse, error)
	// Counters
	IncOps(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncSize(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncError(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
	IncIterations(ctx context.Context, in *EventSendInt, opts ...grpc.CallOption) (*PoplarResponse, error)
}

PoplarMetricsRecorderClient is the client API for PoplarMetricsRecorder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPoplarMetricsRecorderClient 

func NewPoplarMetricsRecorderClient(cc *grpc.ClientConn) PoplarMetricsRecorderClient

type PoplarMetricsRecorderServer 

type PoplarMetricsRecorderServer interface {
	// Create builds a new recorder instance which creates a local file,
	// while the close recorder method flushes the contents of that
	// recorder and closes the file.
	CreateRecorder(context.Context, *CreateOptions) (*PoplarResponse, error)
	CloseRecorder(context.Context, *PoplarID) (*PoplarResponse, error)
	// Event Lifecycle methods
	BeginEvent(context.Context, *PoplarID) (*PoplarResponse, error)
	ResetEvent(context.Context, *PoplarID) (*PoplarResponse, error)
	EndEvent(context.Context, *EventSendDuration) (*PoplarResponse, error)
	SetID(context.Context, *EventSendInt) (*PoplarResponse, error)
	// Timers
	SetTime(context.Context, *EventSendTime) (*PoplarResponse, error)
	SetDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
	SetTotalDuration(context.Context, *EventSendDuration) (*PoplarResponse, error)
	// Guages
	SetState(context.Context, *EventSendInt) (*PoplarResponse, error)
	SetWorkers(context.Context, *EventSendInt) (*PoplarResponse, error)
	SetFailed(context.Context, *EventSendBool) (*PoplarResponse, error)
	// Counters
	IncOps(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncSize(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncError(context.Context, *EventSendInt) (*PoplarResponse, error)
	IncIterations(context.Context, *EventSendInt) (*PoplarResponse, error)
}

PoplarMetricsRecorderServer is the server API for PoplarMetricsRecorder service.

type PoplarResponse 

type PoplarResponse struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status               bool     `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PoplarResponse) Descriptor 

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

func (*PoplarResponse) GetName 

func (m *PoplarResponse) GetName() string

func (*PoplarResponse) GetStatus 

func (m *PoplarResponse) GetStatus() bool

func (*PoplarResponse) ProtoMessage 

func (*PoplarResponse) ProtoMessage()

func (*PoplarResponse) Reset 

func (m *PoplarResponse) Reset()

func (*PoplarResponse) String 

func (m *PoplarResponse) String() string

func (*PoplarResponse) XXX_DiscardUnknown 

func (m *PoplarResponse) XXX_DiscardUnknown()

func (*PoplarResponse) XXX_Marshal 

func (m *PoplarResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoplarResponse) XXX_Merge 

func (m *PoplarResponse) XXX_Merge(src proto.Message)

func (*PoplarResponse) XXX_Size 

func (m *PoplarResponse) XXX_Size() int

func (*PoplarResponse) XXX_Unmarshal 

func (m *PoplarResponse) XXX_Unmarshal(b []byte) error

type ResultData 

type ResultData struct {
	Id                   *ResultID       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Artifacts            []*ArtifactInfo `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	Rollups              []*RollupValue  `protobuf:"bytes,3,rep,name=rollups,proto3" json:"rollups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ResultData) Descriptor 

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

func (*ResultData) GetArtifacts 

func (m *ResultData) GetArtifacts() []*ArtifactInfo

func (*ResultData) GetId 

func (m *ResultData) GetId() *ResultID

func (*ResultData) GetRollups 

func (m *ResultData) GetRollups() []*RollupValue

func (*ResultData) ProtoMessage 

func (*ResultData) ProtoMessage()

func (*ResultData) Reset 

func (m *ResultData) Reset()

func (*ResultData) String 

func (m *ResultData) String() string

func (*ResultData) XXX_DiscardUnknown 

func (m *ResultData) XXX_DiscardUnknown()

func (*ResultData) XXX_Marshal 

func (m *ResultData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultData) XXX_Merge 

func (m *ResultData) XXX_Merge(src proto.Message)

func (*ResultData) XXX_Size 

func (m *ResultData) XXX_Size() int

func (*ResultData) XXX_Unmarshal 

func (m *ResultData) XXX_Unmarshal(b []byte) error

type ResultID 

type ResultID struct {
	Project              string               `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Version              string               `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Variant              string               `protobuf:"bytes,3,opt,name=variant,proto3" json:"variant,omitempty"`
	TaskName             string               `protobuf:"bytes,4,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Execution            int32                `protobuf:"varint,5,opt,name=execution,proto3" json:"execution,omitempty"`
	TaskId               string               `protobuf:"bytes,6,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TestName             string               `protobuf:"bytes,7,opt,name=test_name,json=testName,proto3" json:"test_name,omitempty"`
	Parent               string               `protobuf:"bytes,8,opt,name=parent,proto3" json:"parent,omitempty"`
	Trial                int32                `protobuf:"varint,9,opt,name=trial,proto3" json:"trial,omitempty"`
	Tags                 []string             `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	Arguments            map[string]int32     `` /* 161-byte string literal not displayed */
	Mainline             bool                 `protobuf:"varint,12,opt,name=mainline,proto3" json:"mainline,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Order                int32                `protobuf:"varint,14,opt,name=order,proto3" json:"order,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResultID) Descriptor 

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

func (*ResultID) GetArguments 

func (m *ResultID) GetArguments() map[string]int32

func (*ResultID) GetCreatedAt 

func (m *ResultID) GetCreatedAt() *timestamp.Timestamp

func (*ResultID) GetExecution 

func (m *ResultID) GetExecution() int32

func (*ResultID) GetMainline 

func (m *ResultID) GetMainline() bool

func (*ResultID) GetOrder 

func (m *ResultID) GetOrder() int32

func (*ResultID) GetParent 

func (m *ResultID) GetParent() string

func (*ResultID) GetProject 

func (m *ResultID) GetProject() string

func (*ResultID) GetTags 

func (m *ResultID) GetTags() []string

func (*ResultID) GetTaskId 

func (m *ResultID) GetTaskId() string

func (*ResultID) GetTaskName 

func (m *ResultID) GetTaskName() string

func (*ResultID) GetTestName 

func (m *ResultID) GetTestName() string

func (*ResultID) GetTrial 

func (m *ResultID) GetTrial() int32

func (*ResultID) GetVariant 

func (m *ResultID) GetVariant() string

func (*ResultID) GetVersion 

func (m *ResultID) GetVersion() string

func (*ResultID) ProtoMessage 

func (*ResultID) ProtoMessage()

func (*ResultID) Reset 

func (m *ResultID) Reset()

func (*ResultID) String 

func (m *ResultID) String() string

func (*ResultID) XXX_DiscardUnknown 

func (m *ResultID) XXX_DiscardUnknown()

func (*ResultID) XXX_Marshal 

func (m *ResultID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultID) XXX_Merge 

func (m *ResultID) XXX_Merge(src proto.Message)

func (*ResultID) XXX_Size 

func (m *ResultID) XXX_Size() int

func (*ResultID) XXX_Unmarshal 

func (m *ResultID) XXX_Unmarshal(b []byte) error

type RollupData 

type RollupData struct {
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Rollups              []*RollupValue `protobuf:"bytes,2,rep,name=rollups,proto3" json:"rollups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RollupData) Descriptor 

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

func (*RollupData) GetId 

func (m *RollupData) GetId() string

func (*RollupData) GetRollups 

func (m *RollupData) GetRollups() []*RollupValue

func (*RollupData) ProtoMessage 

func (*RollupData) ProtoMessage()

func (*RollupData) Reset 

func (m *RollupData) Reset()

func (*RollupData) String 

func (m *RollupData) String() string

func (*RollupData) XXX_DiscardUnknown 

func (m *RollupData) XXX_DiscardUnknown()

func (*RollupData) XXX_Marshal 

func (m *RollupData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollupData) XXX_Merge 

func (m *RollupData) XXX_Merge(src proto.Message)

func (*RollupData) XXX_Size 

func (m *RollupData) XXX_Size() int

func (*RollupData) XXX_Unmarshal 

func (m *RollupData) XXX_Unmarshal(b []byte) error

type RollupType 

type RollupType int32
const (
	RollupType_SUM                RollupType = 0
	RollupType_MEAN               RollupType = 1
	RollupType_MEDIAN             RollupType = 2
	RollupType_MAX                RollupType = 3
	RollupType_MIN                RollupType = 4
	RollupType_STANDARD_DEVIATION RollupType = 5
	RollupType_THROUGHPUT         RollupType = 6
	RollupType_LATENCY            RollupType = 7
	RollupType_PERCENTILE_99TH    RollupType = 8
	RollupType_PERCENTILE_95TH    RollupType = 9
	RollupType_PERCENTILE_90TH    RollupType = 10
	RollupType_PERCENTILE_80TH    RollupType = 11
	RollupType_PERCENTILE_50TH    RollupType = 12
)

func (RollupType) EnumDescriptor 

func (RollupType) EnumDescriptor() ([]byte, []int)

func (RollupType) String 

func (x RollupType) String() string

type RollupValue 

type RollupValue struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*RollupValue_Int
	//	*RollupValue_Fl
	Value                isRollupValue_Value `protobuf_oneof:"value"`
	Type                 RollupType          `protobuf:"varint,4,opt,name=type,proto3,enum=cedar.RollupType" json:"type,omitempty"`
	Version              int64               `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	UserSubmitted        bool                `protobuf:"varint,6,opt,name=user_submitted,json=userSubmitted,proto3" json:"user_submitted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func ExportRollup 

func ExportRollup(in *poplar.TestMetrics) *RollupValue

func (*RollupValue) Descriptor 

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

func (*RollupValue) GetFl 

func (m *RollupValue) GetFl() float64

func (*RollupValue) GetInt 

func (m *RollupValue) GetInt() int64

func (*RollupValue) GetName 

func (m *RollupValue) GetName() string

func (*RollupValue) GetType 

func (m *RollupValue) GetType() RollupType

func (*RollupValue) GetUserSubmitted 

func (m *RollupValue) GetUserSubmitted() bool

func (*RollupValue) GetValue 

func (m *RollupValue) GetValue() isRollupValue_Value

func (*RollupValue) GetVersion 

func (m *RollupValue) GetVersion() int64

func (*RollupValue) ProtoMessage 

func (*RollupValue) ProtoMessage()

func (*RollupValue) Reset 

func (m *RollupValue) Reset()

func (*RollupValue) String 

func (m *RollupValue) String() string

func (*RollupValue) XXX_DiscardUnknown 

func (m *RollupValue) XXX_DiscardUnknown()

func (*RollupValue) XXX_Marshal 

func (m *RollupValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollupValue) XXX_Merge 

func (m *RollupValue) XXX_Merge(src proto.Message)

func (*RollupValue) XXX_OneofWrappers 

func (*RollupValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RollupValue) XXX_Size 

func (m *RollupValue) XXX_Size() int

func (*RollupValue) XXX_Unmarshal 

func (m *RollupValue) XXX_Unmarshal(b []byte) error

type RollupValue_Fl 

type RollupValue_Fl struct {
	Fl float64 `protobuf:"fixed64,3,opt,name=fl,proto3,oneof"`
}

type RollupValue_Int 

type RollupValue_Int struct {
	Int int64 `protobuf:"varint,2,opt,name=int,proto3,oneof"`
}

type SchemaType 

type SchemaType int32
const (
	SchemaType_RAW_EVENTS             SchemaType = 0
	SchemaType_COLLAPSED_EVENTS       SchemaType = 1
	SchemaType_INTERVAL_SUMMARIZATION SchemaType = 2
	SchemaType_HISTOGRAM              SchemaType = 3
)

func (SchemaType) EnumDescriptor 

func (SchemaType) EnumDescriptor() ([]byte, []int)

func (SchemaType) String 

func (x SchemaType) String() string

type SendResponse 

type SendResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success              bool     `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Count                int64    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendResponse) Descriptor 

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

func (*SendResponse) GetCount 

func (m *SendResponse) GetCount() int64

func (*SendResponse) GetId 

func (m *SendResponse) GetId() string

func (*SendResponse) GetSuccess 

func (m *SendResponse) GetSuccess() bool

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) Reset 

func (m *SendResponse) Reset()

func (*SendResponse) String 

func (m *SendResponse) String() string

func (*SendResponse) XXX_DiscardUnknown 

func (m *SendResponse) XXX_DiscardUnknown()

func (*SendResponse) XXX_Marshal 

func (m *SendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendResponse) XXX_Merge 

func (m *SendResponse) XXX_Merge(src proto.Message)

func (*SendResponse) XXX_Size 

func (m *SendResponse) XXX_Size() int

func (*SendResponse) XXX_Unmarshal 

func (m *SendResponse) XXX_Unmarshal(b []byte) error

type StorageLocation 

type StorageLocation int32
const (
	StorageLocation_UNKNOWN    StorageLocation = 0
	StorageLocation_CEDAR_S3   StorageLocation = 1
	StorageLocation_PROJECT_S3 StorageLocation = 2
	StorageLocation_GRIDFS     StorageLocation = 3
	StorageLocation_EPHEMERAL  StorageLocation = 4
	StorageLocation_LOCAL      StorageLocation = 5
)

func (StorageLocation) EnumDescriptor 

func (StorageLocation) EnumDescriptor() ([]byte, []int)

func (StorageLocation) String 

func (x StorageLocation) String() string

type SummaryDouble 

type SummaryDouble struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SummaryDouble) Descriptor 

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

func (*SummaryDouble) GetName 

func (m *SummaryDouble) GetName() string

func (*SummaryDouble) GetValue 

func (m *SummaryDouble) GetValue() float64

func (*SummaryDouble) ProtoMessage 

func (*SummaryDouble) ProtoMessage()

func (*SummaryDouble) Reset 

func (m *SummaryDouble) Reset()

func (*SummaryDouble) String 

func (m *SummaryDouble) String() string

func (*SummaryDouble) XXX_DiscardUnknown 

func (m *SummaryDouble) XXX_DiscardUnknown()

func (*SummaryDouble) XXX_Marshal 

func (m *SummaryDouble) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryDouble) XXX_Merge 

func (m *SummaryDouble) XXX_Merge(src proto.Message)

func (*SummaryDouble) XXX_Size 

func (m *SummaryDouble) XXX_Size() int

func (*SummaryDouble) XXX_Unmarshal 

func (m *SummaryDouble) XXX_Unmarshal(b []byte) error

type SummaryDoubleSlice 

type SummaryDoubleSlice struct {
	Name                 string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                []float64 `protobuf:"fixed64,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SummaryDoubleSlice) Descriptor 

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

func (*SummaryDoubleSlice) GetName 

func (m *SummaryDoubleSlice) GetName() string

func (*SummaryDoubleSlice) GetValue 

func (m *SummaryDoubleSlice) GetValue() []float64

func (*SummaryDoubleSlice) ProtoMessage 

func (*SummaryDoubleSlice) ProtoMessage()

func (*SummaryDoubleSlice) Reset 

func (m *SummaryDoubleSlice) Reset()

func (*SummaryDoubleSlice) String 

func (m *SummaryDoubleSlice) String() string

func (*SummaryDoubleSlice) XXX_DiscardUnknown 

func (m *SummaryDoubleSlice) XXX_DiscardUnknown()

func (*SummaryDoubleSlice) XXX_Marshal 

func (m *SummaryDoubleSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryDoubleSlice) XXX_Merge 

func (m *SummaryDoubleSlice) XXX_Merge(src proto.Message)

func (*SummaryDoubleSlice) XXX_Size 

func (m *SummaryDoubleSlice) XXX_Size() int

func (*SummaryDoubleSlice) XXX_Unmarshal 

func (m *SummaryDoubleSlice) XXX_Unmarshal(b []byte) error

type SummaryInteger 

type SummaryInteger struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                int64    `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SummaryInteger) Descriptor 

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

func (*SummaryInteger) GetName 

func (m *SummaryInteger) GetName() string

func (*SummaryInteger) GetValue 

func (m *SummaryInteger) GetValue() int64

func (*SummaryInteger) ProtoMessage 

func (*SummaryInteger) ProtoMessage()

func (*SummaryInteger) Reset 

func (m *SummaryInteger) Reset()

func (*SummaryInteger) String 

func (m *SummaryInteger) String() string

func (*SummaryInteger) XXX_DiscardUnknown 

func (m *SummaryInteger) XXX_DiscardUnknown()

func (*SummaryInteger) XXX_Marshal 

func (m *SummaryInteger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryInteger) XXX_Merge 

func (m *SummaryInteger) XXX_Merge(src proto.Message)

func (*SummaryInteger) XXX_Size 

func (m *SummaryInteger) XXX_Size() int

func (*SummaryInteger) XXX_Unmarshal 

func (m *SummaryInteger) XXX_Unmarshal(b []byte) error

type SummaryIntegerSlice 

type SummaryIntegerSlice struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                []int64  `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SummaryIntegerSlice) Descriptor 

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

func (*SummaryIntegerSlice) GetName 

func (m *SummaryIntegerSlice) GetName() string

func (*SummaryIntegerSlice) GetValue 

func (m *SummaryIntegerSlice) GetValue() []int64

func (*SummaryIntegerSlice) ProtoMessage 

func (*SummaryIntegerSlice) ProtoMessage()

func (*SummaryIntegerSlice) Reset 

func (m *SummaryIntegerSlice) Reset()

func (*SummaryIntegerSlice) String 

func (m *SummaryIntegerSlice) String() string

func (*SummaryIntegerSlice) XXX_DiscardUnknown 

func (m *SummaryIntegerSlice) XXX_DiscardUnknown()

func (*SummaryIntegerSlice) XXX_Marshal 

func (m *SummaryIntegerSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryIntegerSlice) XXX_Merge 

func (m *SummaryIntegerSlice) XXX_Merge(src proto.Message)

func (*SummaryIntegerSlice) XXX_Size 

func (m *SummaryIntegerSlice) XXX_Size() int

func (*SummaryIntegerSlice) XXX_Unmarshal 

func (m *SummaryIntegerSlice) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.