blob: e2b723506749359be14b97399215813b238774ac [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: traceservice.proto
package traceservice
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{0}
}
func (m *Empty) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Empty.Unmarshal(m, b)
}
func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
}
func (m *Empty) XXX_Merge(src proto.Message) {
xxx_messageInfo_Empty.Merge(m, src)
}
func (m *Empty) XXX_Size() int {
return xxx_messageInfo_Empty.Size(m)
}
func (m *Empty) XXX_DiscardUnknown() {
xxx_messageInfo_Empty.DiscardUnknown(m)
}
var xxx_messageInfo_Empty proto.InternalMessageInfo
// CommitID identifies one commit, or trybot try.
type CommitID struct {
// The id of a commit, either a git hash, or a Reitveld patch id.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// The source of the commit, either a git branch name, or a Reitveld issue id.
Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
// The timestamp of the commit or trybot patch.
Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CommitID) Reset() { *m = CommitID{} }
func (m *CommitID) String() string { return proto.CompactTextString(m) }
func (*CommitID) ProtoMessage() {}
func (*CommitID) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{1}
}
func (m *CommitID) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitID.Unmarshal(m, b)
}
func (m *CommitID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitID.Marshal(b, m, deterministic)
}
func (m *CommitID) XXX_Merge(src proto.Message) {
xxx_messageInfo_CommitID.Merge(m, src)
}
func (m *CommitID) XXX_Size() int {
return xxx_messageInfo_CommitID.Size(m)
}
func (m *CommitID) XXX_DiscardUnknown() {
xxx_messageInfo_CommitID.DiscardUnknown(m)
}
var xxx_messageInfo_CommitID proto.InternalMessageInfo
func (m *CommitID) GetId() string {
if m != nil {
return m.Id
}
return ""
}
func (m *CommitID) GetSource() string {
if m != nil {
return m.Source
}
return ""
}
func (m *CommitID) GetTimestamp() int64 {
if m != nil {
return m.Timestamp
}
return 0
}
// Params are the key-value pairs for a single trace.
//
// All of the key-value parameters should be present, the ones used to
// construct the traceid, along with optional parameters.
type Params struct {
Params map[string]string `protobuf:"bytes,1,rep,name=params,proto3" json:"params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Params) Reset() { *m = Params{} }
func (m *Params) String() string { return proto.CompactTextString(m) }
func (*Params) ProtoMessage() {}
func (*Params) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{2}
}
func (m *Params) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Params.Unmarshal(m, b)
}
func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Params.Marshal(b, m, deterministic)
}
func (m *Params) XXX_Merge(src proto.Message) {
xxx_messageInfo_Params.Merge(m, src)
}
func (m *Params) XXX_Size() int {
return xxx_messageInfo_Params.Size(m)
}
func (m *Params) XXX_DiscardUnknown() {
xxx_messageInfo_Params.DiscardUnknown(m)
}
var xxx_messageInfo_Params proto.InternalMessageInfo
func (m *Params) GetParams() map[string]string {
if m != nil {
return m.Params
}
return nil
}
type MissingParamsRequest struct {
Traceids []string `protobuf:"bytes,1,rep,name=traceids,proto3" json:"traceids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MissingParamsRequest) Reset() { *m = MissingParamsRequest{} }
func (m *MissingParamsRequest) String() string { return proto.CompactTextString(m) }
func (*MissingParamsRequest) ProtoMessage() {}
func (*MissingParamsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{3}
}
func (m *MissingParamsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MissingParamsRequest.Unmarshal(m, b)
}
func (m *MissingParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MissingParamsRequest.Marshal(b, m, deterministic)
}
func (m *MissingParamsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_MissingParamsRequest.Merge(m, src)
}
func (m *MissingParamsRequest) XXX_Size() int {
return xxx_messageInfo_MissingParamsRequest.Size(m)
}
func (m *MissingParamsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_MissingParamsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_MissingParamsRequest proto.InternalMessageInfo
func (m *MissingParamsRequest) GetTraceids() []string {
if m != nil {
return m.Traceids
}
return nil
}
type MissingParamsResponse struct {
Traceids []string `protobuf:"bytes,1,rep,name=traceids,proto3" json:"traceids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MissingParamsResponse) Reset() { *m = MissingParamsResponse{} }
func (m *MissingParamsResponse) String() string { return proto.CompactTextString(m) }
func (*MissingParamsResponse) ProtoMessage() {}
func (*MissingParamsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{4}
}
func (m *MissingParamsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MissingParamsResponse.Unmarshal(m, b)
}
func (m *MissingParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MissingParamsResponse.Marshal(b, m, deterministic)
}
func (m *MissingParamsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_MissingParamsResponse.Merge(m, src)
}
func (m *MissingParamsResponse) XXX_Size() int {
return xxx_messageInfo_MissingParamsResponse.Size(m)
}
func (m *MissingParamsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_MissingParamsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_MissingParamsResponse proto.InternalMessageInfo
func (m *MissingParamsResponse) GetTraceids() []string {
if m != nil {
return m.Traceids
}
return nil
}
type ParamsPair struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Params map[string]string `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ParamsPair) Reset() { *m = ParamsPair{} }
func (m *ParamsPair) String() string { return proto.CompactTextString(m) }
func (*ParamsPair) ProtoMessage() {}
func (*ParamsPair) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{5}
}
func (m *ParamsPair) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ParamsPair.Unmarshal(m, b)
}
func (m *ParamsPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ParamsPair.Marshal(b, m, deterministic)
}
func (m *ParamsPair) XXX_Merge(src proto.Message) {
xxx_messageInfo_ParamsPair.Merge(m, src)
}
func (m *ParamsPair) XXX_Size() int {
return xxx_messageInfo_ParamsPair.Size(m)
}
func (m *ParamsPair) XXX_DiscardUnknown() {
xxx_messageInfo_ParamsPair.DiscardUnknown(m)
}
var xxx_messageInfo_ParamsPair proto.InternalMessageInfo
func (m *ParamsPair) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func (m *ParamsPair) GetParams() map[string]string {
if m != nil {
return m.Params
}
return nil
}
type AddParamsRequest struct {
Params []*ParamsPair `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddParamsRequest) Reset() { *m = AddParamsRequest{} }
func (m *AddParamsRequest) String() string { return proto.CompactTextString(m) }
func (*AddParamsRequest) ProtoMessage() {}
func (*AddParamsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{6}
}
func (m *AddParamsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddParamsRequest.Unmarshal(m, b)
}
func (m *AddParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddParamsRequest.Marshal(b, m, deterministic)
}
func (m *AddParamsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddParamsRequest.Merge(m, src)
}
func (m *AddParamsRequest) XXX_Size() int {
return xxx_messageInfo_AddParamsRequest.Size(m)
}
func (m *AddParamsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_AddParamsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_AddParamsRequest proto.InternalMessageInfo
func (m *AddParamsRequest) GetParams() []*ParamsPair {
if m != nil {
return m.Params
}
return nil
}
// StoredEntry is used to serialize the Params to be stored in the BoltBD.
type StoredEntry struct {
Params *Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StoredEntry) Reset() { *m = StoredEntry{} }
func (m *StoredEntry) String() string { return proto.CompactTextString(m) }
func (*StoredEntry) ProtoMessage() {}
func (*StoredEntry) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{7}
}
func (m *StoredEntry) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StoredEntry.Unmarshal(m, b)
}
func (m *StoredEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StoredEntry.Marshal(b, m, deterministic)
}
func (m *StoredEntry) XXX_Merge(src proto.Message) {
xxx_messageInfo_StoredEntry.Merge(m, src)
}
func (m *StoredEntry) XXX_Size() int {
return xxx_messageInfo_StoredEntry.Size(m)
}
func (m *StoredEntry) XXX_DiscardUnknown() {
xxx_messageInfo_StoredEntry.DiscardUnknown(m)
}
var xxx_messageInfo_StoredEntry proto.InternalMessageInfo
func (m *StoredEntry) GetParams() *Params {
if m != nil {
return m.Params
}
return nil
}
type ValuePair struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ValuePair) Reset() { *m = ValuePair{} }
func (m *ValuePair) String() string { return proto.CompactTextString(m) }
func (*ValuePair) ProtoMessage() {}
func (*ValuePair) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{8}
}
func (m *ValuePair) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ValuePair.Unmarshal(m, b)
}
func (m *ValuePair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ValuePair.Marshal(b, m, deterministic)
}
func (m *ValuePair) XXX_Merge(src proto.Message) {
xxx_messageInfo_ValuePair.Merge(m, src)
}
func (m *ValuePair) XXX_Size() int {
return xxx_messageInfo_ValuePair.Size(m)
}
func (m *ValuePair) XXX_DiscardUnknown() {
xxx_messageInfo_ValuePair.DiscardUnknown(m)
}
var xxx_messageInfo_ValuePair proto.InternalMessageInfo
func (m *ValuePair) GetKey() string {
if m != nil {
return m.Key
}
return ""
}
func (m *ValuePair) GetValue() []byte {
if m != nil {
return m.Value
}
return nil
}
type AddRequest struct {
// The id of the commit/trybot we are adding data about.
Commitid *CommitID `protobuf:"bytes,1,opt,name=commitid,proto3" json:"commitid,omitempty"`
Values []*ValuePair `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddRequest) Reset() { *m = AddRequest{} }
func (m *AddRequest) String() string { return proto.CompactTextString(m) }
func (*AddRequest) ProtoMessage() {}
func (*AddRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{9}
}
func (m *AddRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddRequest.Unmarshal(m, b)
}
func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddRequest.Marshal(b, m, deterministic)
}
func (m *AddRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddRequest.Merge(m, src)
}
func (m *AddRequest) XXX_Size() int {
return xxx_messageInfo_AddRequest.Size(m)
}
func (m *AddRequest) XXX_DiscardUnknown() {
xxx_messageInfo_AddRequest.DiscardUnknown(m)
}
var xxx_messageInfo_AddRequest proto.InternalMessageInfo
func (m *AddRequest) GetCommitid() *CommitID {
if m != nil {
return m.Commitid
}
return nil
}
func (m *AddRequest) GetValues() []*ValuePair {
if m != nil {
return m.Values
}
return nil
}
type ListRequest struct {
// begin is the unix timestamp to start searching from.
Begin int64 `protobuf:"varint,1,opt,name=begin,proto3" json:"begin,omitempty"`
// end is the unix timestamp to search to (inclusive).
End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListRequest) Reset() { *m = ListRequest{} }
func (m *ListRequest) String() string { return proto.CompactTextString(m) }
func (*ListRequest) ProtoMessage() {}
func (*ListRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{10}
}
func (m *ListRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListRequest.Unmarshal(m, b)
}
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListRequest.Marshal(b, m, deterministic)
}
func (m *ListRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListRequest.Merge(m, src)
}
func (m *ListRequest) XXX_Size() int {
return xxx_messageInfo_ListRequest.Size(m)
}
func (m *ListRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ListRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ListRequest proto.InternalMessageInfo
func (m *ListRequest) GetBegin() int64 {
if m != nil {
return m.Begin
}
return 0
}
func (m *ListRequest) GetEnd() int64 {
if m != nil {
return m.End
}
return 0
}
type ListResponse struct {
// A list of CommitIDs that fall between the given timestamps in
// ListRequest.
Commitids []*CommitID `protobuf:"bytes,3,rep,name=commitids,proto3" json:"commitids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListResponse) Reset() { *m = ListResponse{} }
func (m *ListResponse) String() string { return proto.CompactTextString(m) }
func (*ListResponse) ProtoMessage() {}
func (*ListResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{11}
}
func (m *ListResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListResponse.Unmarshal(m, b)
}
func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListResponse.Marshal(b, m, deterministic)
}
func (m *ListResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListResponse.Merge(m, src)
}
func (m *ListResponse) XXX_Size() int {
return xxx_messageInfo_ListResponse.Size(m)
}
func (m *ListResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ListResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ListResponse proto.InternalMessageInfo
func (m *ListResponse) GetCommitids() []*CommitID {
if m != nil {
return m.Commitids
}
return nil
}
type GetValuesRequest struct {
Commitid *CommitID `protobuf:"bytes,1,opt,name=commitid,proto3" json:"commitid,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetValuesRequest) Reset() { *m = GetValuesRequest{} }
func (m *GetValuesRequest) String() string { return proto.CompactTextString(m) }
func (*GetValuesRequest) ProtoMessage() {}
func (*GetValuesRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{12}
}
func (m *GetValuesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetValuesRequest.Unmarshal(m, b)
}
func (m *GetValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetValuesRequest.Marshal(b, m, deterministic)
}
func (m *GetValuesRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetValuesRequest.Merge(m, src)
}
func (m *GetValuesRequest) XXX_Size() int {
return xxx_messageInfo_GetValuesRequest.Size(m)
}
func (m *GetValuesRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetValuesRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetValuesRequest proto.InternalMessageInfo
func (m *GetValuesRequest) GetCommitid() *CommitID {
if m != nil {
return m.Commitid
}
return nil
}
type GetValuesResponse struct {
Values []*ValuePair `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
Md5 string `protobuf:"bytes,5,opt,name=md5,proto3" json:"md5,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetValuesResponse) Reset() { *m = GetValuesResponse{} }
func (m *GetValuesResponse) String() string { return proto.CompactTextString(m) }
func (*GetValuesResponse) ProtoMessage() {}
func (*GetValuesResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{13}
}
func (m *GetValuesResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetValuesResponse.Unmarshal(m, b)
}
func (m *GetValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetValuesResponse.Marshal(b, m, deterministic)
}
func (m *GetValuesResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetValuesResponse.Merge(m, src)
}
func (m *GetValuesResponse) XXX_Size() int {
return xxx_messageInfo_GetValuesResponse.Size(m)
}
func (m *GetValuesResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetValuesResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetValuesResponse proto.InternalMessageInfo
func (m *GetValuesResponse) GetValues() []*ValuePair {
if m != nil {
return m.Values
}
return nil
}
func (m *GetValuesResponse) GetMd5() string {
if m != nil {
return m.Md5
}
return ""
}
type GetParamsRequest struct {
// A list of traceids.
Traceids []string `protobuf:"bytes,1,rep,name=traceids,proto3" json:"traceids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetParamsRequest) Reset() { *m = GetParamsRequest{} }
func (m *GetParamsRequest) String() string { return proto.CompactTextString(m) }
func (*GetParamsRequest) ProtoMessage() {}
func (*GetParamsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{14}
}
func (m *GetParamsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetParamsRequest.Unmarshal(m, b)
}
func (m *GetParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetParamsRequest.Marshal(b, m, deterministic)
}
func (m *GetParamsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetParamsRequest.Merge(m, src)
}
func (m *GetParamsRequest) XXX_Size() int {
return xxx_messageInfo_GetParamsRequest.Size(m)
}
func (m *GetParamsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetParamsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetParamsRequest proto.InternalMessageInfo
func (m *GetParamsRequest) GetTraceids() []string {
if m != nil {
return m.Traceids
}
return nil
}
type GetParamsResponse struct {
Params []*ParamsPair `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetParamsResponse) Reset() { *m = GetParamsResponse{} }
func (m *GetParamsResponse) String() string { return proto.CompactTextString(m) }
func (*GetParamsResponse) ProtoMessage() {}
func (*GetParamsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{15}
}
func (m *GetParamsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetParamsResponse.Unmarshal(m, b)
}
func (m *GetParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetParamsResponse.Marshal(b, m, deterministic)
}
func (m *GetParamsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetParamsResponse.Merge(m, src)
}
func (m *GetParamsResponse) XXX_Size() int {
return xxx_messageInfo_GetParamsResponse.Size(m)
}
func (m *GetParamsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetParamsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetParamsResponse proto.InternalMessageInfo
func (m *GetParamsResponse) GetParams() []*ParamsPair {
if m != nil {
return m.Params
}
return nil
}
type GetValuesRawResponse struct {
// Raw byte slice that can be decoded with NewCommitInfo.
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
Md5 string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetValuesRawResponse) Reset() { *m = GetValuesRawResponse{} }
func (m *GetValuesRawResponse) String() string { return proto.CompactTextString(m) }
func (*GetValuesRawResponse) ProtoMessage() {}
func (*GetValuesRawResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{16}
}
func (m *GetValuesRawResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetValuesRawResponse.Unmarshal(m, b)
}
func (m *GetValuesRawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetValuesRawResponse.Marshal(b, m, deterministic)
}
func (m *GetValuesRawResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetValuesRawResponse.Merge(m, src)
}
func (m *GetValuesRawResponse) XXX_Size() int {
return xxx_messageInfo_GetValuesRawResponse.Size(m)
}
func (m *GetValuesRawResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetValuesRawResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetValuesRawResponse proto.InternalMessageInfo
func (m *GetValuesRawResponse) GetValue() []byte {
if m != nil {
return m.Value
}
return nil
}
func (m *GetValuesRawResponse) GetMd5() string {
if m != nil {
return m.Md5
}
return ""
}
type GetTraceIDsRequest struct {
Id []uint64 `protobuf:"varint,1,rep,packed,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetTraceIDsRequest) Reset() { *m = GetTraceIDsRequest{} }
func (m *GetTraceIDsRequest) String() string { return proto.CompactTextString(m) }
func (*GetTraceIDsRequest) ProtoMessage() {}
func (*GetTraceIDsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{17}
}
func (m *GetTraceIDsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetTraceIDsRequest.Unmarshal(m, b)
}
func (m *GetTraceIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetTraceIDsRequest.Marshal(b, m, deterministic)
}
func (m *GetTraceIDsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetTraceIDsRequest.Merge(m, src)
}
func (m *GetTraceIDsRequest) XXX_Size() int {
return xxx_messageInfo_GetTraceIDsRequest.Size(m)
}
func (m *GetTraceIDsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetTraceIDsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetTraceIDsRequest proto.InternalMessageInfo
func (m *GetTraceIDsRequest) GetId() []uint64 {
if m != nil {
return m.Id
}
return nil
}
type TraceIDPair struct {
Id64 uint64 `protobuf:"varint,1,opt,name=id64,proto3" json:"id64,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TraceIDPair) Reset() { *m = TraceIDPair{} }
func (m *TraceIDPair) String() string { return proto.CompactTextString(m) }
func (*TraceIDPair) ProtoMessage() {}
func (*TraceIDPair) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{18}
}
func (m *TraceIDPair) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TraceIDPair.Unmarshal(m, b)
}
func (m *TraceIDPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TraceIDPair.Marshal(b, m, deterministic)
}
func (m *TraceIDPair) XXX_Merge(src proto.Message) {
xxx_messageInfo_TraceIDPair.Merge(m, src)
}
func (m *TraceIDPair) XXX_Size() int {
return xxx_messageInfo_TraceIDPair.Size(m)
}
func (m *TraceIDPair) XXX_DiscardUnknown() {
xxx_messageInfo_TraceIDPair.DiscardUnknown(m)
}
var xxx_messageInfo_TraceIDPair proto.InternalMessageInfo
func (m *TraceIDPair) GetId64() uint64 {
if m != nil {
return m.Id64
}
return 0
}
func (m *TraceIDPair) GetId() string {
if m != nil {
return m.Id
}
return ""
}
type GetTraceIDsResponse struct {
Ids []*TraceIDPair `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetTraceIDsResponse) Reset() { *m = GetTraceIDsResponse{} }
func (m *GetTraceIDsResponse) String() string { return proto.CompactTextString(m) }
func (*GetTraceIDsResponse) ProtoMessage() {}
func (*GetTraceIDsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{19}
}
func (m *GetTraceIDsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetTraceIDsResponse.Unmarshal(m, b)
}
func (m *GetTraceIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetTraceIDsResponse.Marshal(b, m, deterministic)
}
func (m *GetTraceIDsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetTraceIDsResponse.Merge(m, src)
}
func (m *GetTraceIDsResponse) XXX_Size() int {
return xxx_messageInfo_GetTraceIDsResponse.Size(m)
}
func (m *GetTraceIDsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetTraceIDsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetTraceIDsResponse proto.InternalMessageInfo
func (m *GetTraceIDsResponse) GetIds() []*TraceIDPair {
if m != nil {
return m.Ids
}
return nil
}
type CommitMD5 struct {
Commitid *CommitID `protobuf:"bytes,1,opt,name=commitid,proto3" json:"commitid,omitempty"`
Md5 string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CommitMD5) Reset() { *m = CommitMD5{} }
func (m *CommitMD5) String() string { return proto.CompactTextString(m) }
func (*CommitMD5) ProtoMessage() {}
func (*CommitMD5) Descriptor() ([]byte, []int) {
return fileDescriptor_6a33e1f1de7a389e, []int{20}
}
func (m *CommitMD5) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitMD5.Unmarshal(m, b)
}
func (m *CommitMD5) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitMD5.Marshal(b, m, deterministic)
}
func (m *CommitMD5) XXX_Merge(src proto.Message) {
xxx_messageInfo_CommitMD5.Merge(m, src)
}
func (m *CommitMD5) XXX_Size() int {
return xxx_messageInfo_CommitMD5.Size(m)
}
func (m *CommitMD5) XXX_DiscardUnknown() {
xxx_messageInfo_CommitMD5.DiscardUnknown(m)
}
var xxx_messageInfo_CommitMD5 proto.InternalMessageInfo
func (m *CommitMD5) GetCommitid() *CommitID {
if m != nil {
return m.Commitid
}
return nil
}
func (m *CommitMD5) GetMd5() string {
if m != nil {
return m.Md5
}
return ""
}
func init() {
proto.RegisterType((*Empty)(nil), "traceservice.Empty")
proto.RegisterType((*CommitID)(nil), "traceservice.CommitID")
proto.RegisterType((*Params)(nil), "traceservice.Params")
proto.RegisterMapType((map[string]string)(nil), "traceservice.Params.ParamsEntry")
proto.RegisterType((*MissingParamsRequest)(nil), "traceservice.MissingParamsRequest")
proto.RegisterType((*MissingParamsResponse)(nil), "traceservice.MissingParamsResponse")
proto.RegisterType((*ParamsPair)(nil), "traceservice.ParamsPair")
proto.RegisterMapType((map[string]string)(nil), "traceservice.ParamsPair.ParamsEntry")
proto.RegisterType((*AddParamsRequest)(nil), "traceservice.AddParamsRequest")
proto.RegisterType((*StoredEntry)(nil), "traceservice.StoredEntry")
proto.RegisterType((*ValuePair)(nil), "traceservice.ValuePair")
proto.RegisterType((*AddRequest)(nil), "traceservice.AddRequest")
proto.RegisterType((*ListRequest)(nil), "traceservice.ListRequest")
proto.RegisterType((*ListResponse)(nil), "traceservice.ListResponse")
proto.RegisterType((*GetValuesRequest)(nil), "traceservice.GetValuesRequest")
proto.RegisterType((*GetValuesResponse)(nil), "traceservice.GetValuesResponse")
proto.RegisterType((*GetParamsRequest)(nil), "traceservice.GetParamsRequest")
proto.RegisterType((*GetParamsResponse)(nil), "traceservice.GetParamsResponse")
proto.RegisterType((*GetValuesRawResponse)(nil), "traceservice.GetValuesRawResponse")
proto.RegisterType((*GetTraceIDsRequest)(nil), "traceservice.GetTraceIDsRequest")
proto.RegisterType((*TraceIDPair)(nil), "traceservice.TraceIDPair")
proto.RegisterType((*GetTraceIDsResponse)(nil), "traceservice.GetTraceIDsResponse")
proto.RegisterType((*CommitMD5)(nil), "traceservice.CommitMD5")
}
func init() { proto.RegisterFile("traceservice.proto", fileDescriptor_6a33e1f1de7a389e) }
var fileDescriptor_6a33e1f1de7a389e = []byte{
// 705 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0x4b, 0x6f, 0xd3, 0x40,
0x10, 0x80, 0xeb, 0x47, 0x42, 0x3d, 0x0e, 0xa8, 0x6c, 0x43, 0x31, 0x16, 0x82, 0xb0, 0xf4, 0x10,
0x09, 0x54, 0xc0, 0x6d, 0xaa, 0xf2, 0x10, 0xa8, 0x25, 0xa5, 0xaa, 0x44, 0x51, 0x70, 0xab, 0x1e,
0xb8, 0xb9, 0xd9, 0x55, 0xb5, 0x02, 0x27, 0xa9, 0xed, 0x16, 0xf5, 0xc0, 0xef, 0xe0, 0x27, 0xf0,
0x37, 0x91, 0x77, 0xd7, 0x1b, 0xdb, 0xb1, 0xd3, 0xf2, 0x38, 0x65, 0x1f, 0xf3, 0xf8, 0x66, 0x76,
0x66, 0x62, 0x40, 0x49, 0x14, 0x0c, 0x69, 0x4c, 0xa3, 0x0b, 0x36, 0xa4, 0x6b, 0x93, 0x68, 0x9c,
0x8c, 0x51, 0x2b, 0x7f, 0x86, 0x6f, 0x40, 0x63, 0x37, 0x9c, 0x24, 0x97, 0x78, 0x00, 0x8b, 0xef,
0xc7, 0x61, 0xc8, 0x92, 0xfd, 0x3e, 0xba, 0x05, 0x3a, 0x23, 0x8e, 0xd6, 0xd1, 0xba, 0x96, 0xaf,
0x33, 0x82, 0x56, 0xa0, 0x19, 0x8f, 0xcf, 0xa3, 0x21, 0x75, 0x74, 0x7e, 0x26, 0x77, 0xe8, 0x3e,
0x58, 0x09, 0x0b, 0x69, 0x9c, 0x04, 0xe1, 0xc4, 0x31, 0x3a, 0x5a, 0xd7, 0xf0, 0xa7, 0x07, 0xf8,
0x07, 0x34, 0x07, 0x41, 0x14, 0x84, 0x31, 0xda, 0x82, 0xe6, 0x84, 0xaf, 0x1c, 0xad, 0x63, 0x74,
0x6d, 0xaf, 0xb3, 0x56, 0xe0, 0x12, 0x52, 0xf2, 0x67, 0x77, 0x94, 0x44, 0x97, 0xbe, 0x94, 0x77,
0x5f, 0x82, 0x9d, 0x3b, 0x46, 0x4b, 0x60, 0x7c, 0xa5, 0x97, 0x92, 0x2c, 0x5d, 0xa2, 0x36, 0x34,
0x2e, 0x82, 0x6f, 0xe7, 0x19, 0x99, 0xd8, 0xbc, 0xd2, 0xb7, 0x34, 0xec, 0x41, 0xfb, 0x80, 0xc5,
0x31, 0x1b, 0x9d, 0x0a, 0x0b, 0x3e, 0x3d, 0x3b, 0xa7, 0x71, 0x82, 0x5c, 0x58, 0xe4, 0xde, 0x19,
0x11, 0x38, 0x96, 0xaf, 0xf6, 0x78, 0x1d, 0xee, 0x94, 0x74, 0xe2, 0xc9, 0x78, 0x14, 0xd3, 0xb9,
0x4a, 0x3f, 0x35, 0x00, 0x21, 0x3e, 0x08, 0x58, 0x54, 0xc1, 0xf8, 0x46, 0x85, 0xaf, 0xf3, 0xf0,
0x57, 0xab, 0xc2, 0x4f, 0x75, 0xff, 0x77, 0x0a, 0xfa, 0xb0, 0xb4, 0x4d, 0x48, 0x31, 0xfc, 0xe7,
0x0a, 0xc6, 0xe4, 0x30, 0x4e, 0x1d, 0x4c, 0x06, 0x80, 0x5f, 0x83, 0x7d, 0x98, 0x8c, 0x23, 0x4a,
0x04, 0xc0, 0xd3, 0x5c, 0x34, 0x5a, 0xd7, 0xf6, 0xda, 0x55, 0x06, 0x94, 0xf2, 0x3a, 0x58, 0xc7,
0x29, 0x4f, 0x4d, 0x6a, 0x0a, 0xec, 0x2d, 0xc9, 0x8e, 0xcf, 0x00, 0xb6, 0x09, 0xc9, 0x88, 0x3d,
0x58, 0x1c, 0xf2, 0xca, 0x94, 0x35, 0x69, 0x7b, 0x2b, 0x45, 0x97, 0x59, 0xdd, 0xfa, 0x4a, 0x0e,
0x3d, 0x83, 0x26, 0x37, 0x15, 0x3b, 0x06, 0x8f, 0xf2, 0x6e, 0x51, 0x43, 0x21, 0xf9, 0x52, 0x0c,
0xf7, 0xc0, 0xfe, 0xc8, 0xe2, 0x24, 0xf3, 0xd9, 0x86, 0xc6, 0x09, 0x3d, 0x65, 0x23, 0xee, 0xd0,
0xf0, 0xc5, 0x26, 0xe5, 0xa7, 0x23, 0xc2, 0x59, 0x0d, 0x3f, 0x5d, 0xe2, 0x3e, 0xb4, 0x84, 0x9a,
0xac, 0x93, 0x0d, 0xb0, 0x32, 0x86, 0xcc, 0x75, 0x1d, 0xec, 0x54, 0x10, 0x7f, 0x80, 0xa5, 0x3d,
0x9a, 0x70, 0xa8, 0xf8, 0x1f, 0xa2, 0xc6, 0xc7, 0x70, 0x3b, 0x67, 0x47, 0x22, 0x4d, 0x53, 0x61,
0x5e, 0x2b, 0x15, 0x69, 0x94, 0x21, 0xe9, 0x39, 0x0d, 0xf1, 0x4a, 0x21, 0xe9, 0xe1, 0x35, 0xce,
0x77, 0xfd, 0x36, 0xda, 0xe5, 0x1c, 0xa5, 0x16, 0xfa, 0xf3, 0xc2, 0x7b, 0x0b, 0xed, 0x69, 0x38,
0xc1, 0x77, 0x65, 0x49, 0x15, 0x8d, 0x96, 0x2b, 0x9a, 0x0c, 0x5b, 0x9f, 0x62, 0xaf, 0x02, 0xda,
0xa3, 0xc9, 0x51, 0xea, 0x65, 0xbf, 0xaf, 0xc0, 0xb3, 0xe1, 0x66, 0x74, 0xcd, 0x74, 0xb8, 0xe1,
0x17, 0x60, 0x4b, 0x11, 0x5e, 0xa3, 0x08, 0x4c, 0x46, 0x36, 0x37, 0xb8, 0x6d, 0xd3, 0xe7, 0x6b,
0xa9, 0xa2, 0x67, 0xf3, 0x10, 0xef, 0xc0, 0x72, 0xc1, 0xb0, 0xe4, 0x7a, 0x02, 0x46, 0x96, 0x0d,
0xdb, 0xbb, 0x57, 0x0c, 0x2f, 0xe7, 0xc2, 0x4f, 0xa5, 0xf0, 0x67, 0xb0, 0xc4, 0x0b, 0x1e, 0xf4,
0x7b, 0x7f, 0x55, 0xe2, 0x33, 0xf1, 0x7a, 0xbf, 0x1a, 0xd0, 0xe2, 0x7e, 0x0e, 0x85, 0x16, 0xfa,
0x02, 0x37, 0x0b, 0xe3, 0x0c, 0xe1, 0xa2, 0xd5, 0xaa, 0xf9, 0xe8, 0x3e, 0x9e, 0x2b, 0x23, 0x42,
0xc5, 0x0b, 0x68, 0x07, 0x2c, 0x35, 0x5b, 0xd0, 0x83, 0xa2, 0x4e, 0x79, 0xe8, 0xb8, 0xcb, 0xc5,
0x7b, 0xf1, 0x8f, 0xb3, 0x80, 0x36, 0xc1, 0xd8, 0x26, 0x04, 0x39, 0x33, 0xda, 0x57, 0xe8, 0xbd,
0x03, 0x33, 0xed, 0x3a, 0x54, 0xca, 0x71, 0xae, 0x81, 0x5d, 0xb7, 0xea, 0x4a, 0xc1, 0x7f, 0x02,
0x4b, 0x55, 0x56, 0x19, 0xbe, 0xdc, 0x89, 0xee, 0xc3, 0xda, 0xfb, 0x92, 0xbd, 0xea, 0x64, 0x94,
0x3b, 0xa7, 0xc2, 0xde, 0x4c, 0x72, 0x8f, 0xa0, 0x95, 0xaf, 0xfc, 0x2b, 0x11, 0x71, 0xdd, 0xfd,
0xb4, 0x6b, 0xb8, 0x55, 0x3b, 0x57, 0xb6, 0xa8, 0x33, 0xa3, 0x54, 0x6a, 0x15, 0xf7, 0xd1, 0x1c,
0x09, 0x65, 0xd5, 0x03, 0x73, 0xc0, 0x46, 0xa7, 0xa8, 0xea, 0xad, 0x6a, 0x1e, 0xf0, 0xa4, 0xc9,
0x3f, 0x45, 0xd6, 0x7f, 0x07, 0x00, 0x00, 0xff, 0xff, 0xf4, 0x6b, 0xd8, 0x4e, 0xa0, 0x08, 0x00,
0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// TraceServiceClient is the client API for TraceService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type TraceServiceClient interface {
// Returns a list of traceids that don't have Params stored in the datastore.
MissingParams(ctx context.Context, in *MissingParamsRequest, opts ...grpc.CallOption) (*MissingParamsResponse, error)
// Adds Params for a set of traceids.
AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*Empty, error)
// Adds data for a set of traces for a particular commitid.
Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empty, error)
// List returns all the CommitIDs that exist in the given time range.
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
// GetValues returns all the trace values stored for the given CommitID.
GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesResponse, error)
// GetParams returns the Params for all of the given traces.
GetParams(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*GetParamsResponse, error)
// GetValuesRaw returns all the trace values stored for the given CommitID in
// the raw format stored in BoltDB. The decoding can be done by calling
// NewCommitInfo() on the returned byte slice.
GetValuesRaw(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesRawResponse, error)
// GetTraceIDs returns the traceids for the given trace64ids. These are used
// in decoding the bytes returned from GetValuesRaw.
GetTraceIDs(ctx context.Context, in *GetTraceIDsRequest, opts ...grpc.CallOption) (*GetTraceIDsResponse, error)
// Ping should always succeed. Used to test if the service is up and
// running.
Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}
type traceServiceClient struct {
cc *grpc.ClientConn
}
func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient {
return &traceServiceClient{cc}
}
func (c *traceServiceClient) MissingParams(ctx context.Context, in *MissingParamsRequest, opts ...grpc.CallOption) (*MissingParamsResponse, error) {
out := new(MissingParamsResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/MissingParams", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) AddParams(ctx context.Context, in *AddParamsRequest, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/AddParams", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/Add", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
out := new(ListResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/List", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesResponse, error) {
out := new(GetValuesResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/GetValues", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) GetParams(ctx context.Context, in *GetParamsRequest, opts ...grpc.CallOption) (*GetParamsResponse, error) {
out := new(GetParamsResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/GetParams", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) GetValuesRaw(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesRawResponse, error) {
out := new(GetValuesRawResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/GetValuesRaw", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) GetTraceIDs(ctx context.Context, in *GetTraceIDsRequest, opts ...grpc.CallOption) (*GetTraceIDsResponse, error) {
out := new(GetTraceIDsResponse)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/GetTraceIDs", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *traceServiceClient) Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/traceservice.TraceService/Ping", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// TraceServiceServer is the server API for TraceService service.
type TraceServiceServer interface {
// Returns a list of traceids that don't have Params stored in the datastore.
MissingParams(context.Context, *MissingParamsRequest) (*MissingParamsResponse, error)
// Adds Params for a set of traceids.
AddParams(context.Context, *AddParamsRequest) (*Empty, error)
// Adds data for a set of traces for a particular commitid.
Add(context.Context, *AddRequest) (*Empty, error)
// List returns all the CommitIDs that exist in the given time range.
List(context.Context, *ListRequest) (*ListResponse, error)
// GetValues returns all the trace values stored for the given CommitID.
GetValues(context.Context, *GetValuesRequest) (*GetValuesResponse, error)
// GetParams returns the Params for all of the given traces.
GetParams(context.Context, *GetParamsRequest) (*GetParamsResponse, error)
// GetValuesRaw returns all the trace values stored for the given CommitID in
// the raw format stored in BoltDB. The decoding can be done by calling
// NewCommitInfo() on the returned byte slice.
GetValuesRaw(context.Context, *GetValuesRequest) (*GetValuesRawResponse, error)
// GetTraceIDs returns the traceids for the given trace64ids. These are used
// in decoding the bytes returned from GetValuesRaw.
GetTraceIDs(context.Context, *GetTraceIDsRequest) (*GetTraceIDsResponse, error)
// Ping should always succeed. Used to test if the service is up and
// running.
Ping(context.Context, *Empty) (*Empty, error)
}
// UnimplementedTraceServiceServer can be embedded to have forward compatible implementations.
type UnimplementedTraceServiceServer struct {
}
func (*UnimplementedTraceServiceServer) MissingParams(ctx context.Context, req *MissingParamsRequest) (*MissingParamsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method MissingParams not implemented")
}
func (*UnimplementedTraceServiceServer) AddParams(ctx context.Context, req *AddParamsRequest) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddParams not implemented")
}
func (*UnimplementedTraceServiceServer) Add(ctx context.Context, req *AddRequest) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Add not implemented")
}
func (*UnimplementedTraceServiceServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (*UnimplementedTraceServiceServer) GetValues(ctx context.Context, req *GetValuesRequest) (*GetValuesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetValues not implemented")
}
func (*UnimplementedTraceServiceServer) GetParams(ctx context.Context, req *GetParamsRequest) (*GetParamsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetParams not implemented")
}
func (*UnimplementedTraceServiceServer) GetValuesRaw(ctx context.Context, req *GetValuesRequest) (*GetValuesRawResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetValuesRaw not implemented")
}
func (*UnimplementedTraceServiceServer) GetTraceIDs(ctx context.Context, req *GetTraceIDsRequest) (*GetTraceIDsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetTraceIDs not implemented")
}
func (*UnimplementedTraceServiceServer) Ping(ctx context.Context, req *Empty) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
}
func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
s.RegisterService(&_TraceService_serviceDesc, srv)
}
func _TraceService_MissingParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(MissingParamsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).MissingParams(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/MissingParams",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).MissingParams(ctx, req.(*MissingParamsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_AddParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddParamsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).AddParams(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/AddParams",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).AddParams(ctx, req.(*AddParamsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_Add_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).Add(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/Add",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).Add(ctx, req.(*AddRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).List(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/List",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).List(ctx, req.(*ListRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_GetValues_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetValuesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).GetValues(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/GetValues",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).GetValues(ctx, req.(*GetValuesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_GetParams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetParamsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).GetParams(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/GetParams",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).GetParams(ctx, req.(*GetParamsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_GetValuesRaw_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetValuesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).GetValuesRaw(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/GetValuesRaw",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).GetValuesRaw(ctx, req.(*GetValuesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_GetTraceIDs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetTraceIDsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).GetTraceIDs(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/GetTraceIDs",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).GetTraceIDs(ctx, req.(*GetTraceIDsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _TraceService_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Empty)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(TraceServiceServer).Ping(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/traceservice.TraceService/Ping",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TraceServiceServer).Ping(ctx, req.(*Empty))
}
return interceptor(ctx, in, info, handler)
}
var _TraceService_serviceDesc = grpc.ServiceDesc{
ServiceName: "traceservice.TraceService",
HandlerType: (*TraceServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "MissingParams",
Handler: _TraceService_MissingParams_Handler,
},
{
MethodName: "AddParams",
Handler: _TraceService_AddParams_Handler,
},
{
MethodName: "Add",
Handler: _TraceService_Add_Handler,
},
{
MethodName: "List",
Handler: _TraceService_List_Handler,
},
{
MethodName: "GetValues",
Handler: _TraceService_GetValues_Handler,
},
{
MethodName: "GetParams",
Handler: _TraceService_GetParams_Handler,
},
{
MethodName: "GetValuesRaw",
Handler: _TraceService_GetValuesRaw_Handler,
},
{
MethodName: "GetTraceIDs",
Handler: _TraceService_GetTraceIDs_Handler,
},
{
MethodName: "Ping",
Handler: _TraceService_Ping_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "traceservice.proto",
}