v1

package
v0.0.0-...-5b17d3f Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GCPhraseV1_name = map[int32]string{
	0: "NEW",
	1: "OLD",
}
View Source 
var GCPhraseV1_value = map[string]int32{
	"NEW": 0,
	"OLD": 1,
}
View Source 
var PoolTypeV1_name = map[int32]string{
	0: "CODE_CACHE_USAGE",
	1: "NEWGEN_USAGE",
	2: "OLDGEN_USAGE",
	3: "SURVIVOR_USAGE",
	4: "PERMGEN_USAGE",
	5: "METASPACE_USAGE",
}
View Source 
var PoolTypeV1_value = map[string]int32{
	"CODE_CACHE_USAGE": 0,
	"NEWGEN_USAGE":     1,
	"OLDGEN_USAGE":     2,
	"SURVIVOR_USAGE":   3,
	"PERMGEN_USAGE":    4,
	"METASPACE_USAGE":  5,
}
View Source 
var RefTypeV1_name = map[int32]string{
	0: "CrossProcess",
	1: "CrossThread",
}
View Source 
var RefTypeV1_value = map[string]int32{
	"CrossProcess": 0,
	"CrossThread":  1,
}
View Source 
var SpanLayerV1_name = map[int32]string{
	0: "Unknown",
	1: "Database",
	2: "RPCFramework",
	3: "Http",
	4: "MQ",
	5: "Cache",
}
View Source 
var SpanLayerV1_value = map[string]int32{
	"Unknown":      0,
	"Database":     1,
	"RPCFramework": 2,
	"Http":         3,
	"MQ":           4,
	"Cache":        5,
}
View Source 
var SpanTypeV1_name = map[int32]string{
	0: "Entry",
	1: "Exit",
	2: "Local",
}
View Source 
var SpanTypeV1_value = map[string]int32{
	"Entry": 0,
	"Exit":  1,
	"Local": 2,
}

Functions

func RegisterApplicationRegisterServiceServer 

func RegisterApplicationRegisterServiceServer(s *grpc.Server, srv ApplicationRegisterServiceServer)

func RegisterInstanceDiscoveryServiceServer 

func RegisterInstanceDiscoveryServiceServer(s *grpc.Server, srv InstanceDiscoveryServiceServer)

func RegisterJVMMetricsServiceServer 

func RegisterJVMMetricsServiceServer(s *grpc.Server, srv JVMMetricsServiceServer)

func RegisterNetworkAddressRegisterServiceServer 

func RegisterNetworkAddressRegisterServiceServer(s *grpc.Server, srv NetworkAddressRegisterServiceServer)

func RegisterServiceNameDiscoveryServiceServer 

func RegisterServiceNameDiscoveryServiceServer(s *grpc.Server, srv ServiceNameDiscoveryServiceServer)

func RegisterTraceSegmentServiceServer 

func RegisterTraceSegmentServiceServer(s *grpc.Server, srv TraceSegmentServiceServer)

Types

type Application 

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

func (*Application) Descriptor 

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

func (*Application) GetApplicationCode 

func (m *Application) GetApplicationCode() string

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) Reset 

func (m *Application) Reset()

func (*Application) String 

func (m *Application) String() string

func (*Application) XXX_DiscardUnknown 

func (m *Application) XXX_DiscardUnknown()

func (*Application) XXX_Marshal 

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

func (*Application) XXX_Merge 

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

func (*Application) XXX_Size 

func (m *Application) XXX_Size() int

func (*Application) XXX_Unmarshal 

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

type ApplicationInstance 

type ApplicationInstance struct {
	ApplicationId        int32    `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	AgentUUID            string   `protobuf:"bytes,2,opt,name=agentUUID,proto3" json:"agentUUID,omitempty"`
	RegisterTime         int64    `protobuf:"varint,3,opt,name=registerTime,proto3" json:"registerTime,omitempty"`
	Osinfo               *OSInfo  `protobuf:"bytes,4,opt,name=osinfo,proto3" json:"osinfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplicationInstance) Descriptor 

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

func (*ApplicationInstance) GetAgentUUID 

func (m *ApplicationInstance) GetAgentUUID() string

func (*ApplicationInstance) GetApplicationId 

func (m *ApplicationInstance) GetApplicationId() int32

func (*ApplicationInstance) GetOsinfo 

func (m *ApplicationInstance) GetOsinfo() *OSInfo

func (*ApplicationInstance) GetRegisterTime 

func (m *ApplicationInstance) GetRegisterTime() int64

func (*ApplicationInstance) ProtoMessage 

func (*ApplicationInstance) ProtoMessage()

func (*ApplicationInstance) Reset 

func (m *ApplicationInstance) Reset()

func (*ApplicationInstance) String 

func (m *ApplicationInstance) String() string

func (*ApplicationInstance) XXX_DiscardUnknown 

func (m *ApplicationInstance) XXX_DiscardUnknown()

func (*ApplicationInstance) XXX_Marshal 

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

func (*ApplicationInstance) XXX_Merge 

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

func (*ApplicationInstance) XXX_Size 

func (m *ApplicationInstance) XXX_Size() int

func (*ApplicationInstance) XXX_Unmarshal 

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

type ApplicationInstanceHeartbeat 

type ApplicationInstanceHeartbeat struct {
	ApplicationInstanceId int32    `protobuf:"varint,1,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	HeartbeatTime         int64    `protobuf:"varint,2,opt,name=heartbeatTime,proto3" json:"heartbeatTime,omitempty"`
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*ApplicationInstanceHeartbeat) Descriptor 

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

func (*ApplicationInstanceHeartbeat) GetApplicationInstanceId 

func (m *ApplicationInstanceHeartbeat) GetApplicationInstanceId() int32

func (*ApplicationInstanceHeartbeat) GetHeartbeatTime 

func (m *ApplicationInstanceHeartbeat) GetHeartbeatTime() int64

func (*ApplicationInstanceHeartbeat) ProtoMessage 

func (*ApplicationInstanceHeartbeat) ProtoMessage()

func (*ApplicationInstanceHeartbeat) Reset 

func (m *ApplicationInstanceHeartbeat) Reset()

func (*ApplicationInstanceHeartbeat) String 

func (m *ApplicationInstanceHeartbeat) String() string

func (*ApplicationInstanceHeartbeat) XXX_DiscardUnknown 

func (m *ApplicationInstanceHeartbeat) XXX_DiscardUnknown()

func (*ApplicationInstanceHeartbeat) XXX_Marshal 

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

func (*ApplicationInstanceHeartbeat) XXX_Merge 

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

func (*ApplicationInstanceHeartbeat) XXX_Size 

func (m *ApplicationInstanceHeartbeat) XXX_Size() int

func (*ApplicationInstanceHeartbeat) XXX_Unmarshal 

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

type ApplicationInstanceMapping 

type ApplicationInstanceMapping struct {
	ApplicationId         int32    `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32    `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*ApplicationInstanceMapping) Descriptor 

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

func (*ApplicationInstanceMapping) GetApplicationId 

func (m *ApplicationInstanceMapping) GetApplicationId() int32

func (*ApplicationInstanceMapping) GetApplicationInstanceId 

func (m *ApplicationInstanceMapping) GetApplicationInstanceId() int32

func (*ApplicationInstanceMapping) ProtoMessage 

func (*ApplicationInstanceMapping) ProtoMessage()

func (*ApplicationInstanceMapping) Reset 

func (m *ApplicationInstanceMapping) Reset()

func (*ApplicationInstanceMapping) String 

func (m *ApplicationInstanceMapping) String() string

func (*ApplicationInstanceMapping) XXX_DiscardUnknown 

func (m *ApplicationInstanceMapping) XXX_DiscardUnknown()

func (*ApplicationInstanceMapping) XXX_Marshal 

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

func (*ApplicationInstanceMapping) XXX_Merge 

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

func (*ApplicationInstanceMapping) XXX_Size 

func (m *ApplicationInstanceMapping) XXX_Size() int

func (*ApplicationInstanceMapping) XXX_Unmarshal 

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

type ApplicationInstanceRecover 

type ApplicationInstanceRecover struct {
	ApplicationId         int32    `protobuf:"varint,1,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32    `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	RegisterTime          int64    `protobuf:"varint,3,opt,name=registerTime,proto3" json:"registerTime,omitempty"`
	Osinfo                *OSInfo  `protobuf:"bytes,4,opt,name=osinfo,proto3" json:"osinfo,omitempty"`
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*ApplicationInstanceRecover) Descriptor 

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

func (*ApplicationInstanceRecover) GetApplicationId 

func (m *ApplicationInstanceRecover) GetApplicationId() int32

func (*ApplicationInstanceRecover) GetApplicationInstanceId 

func (m *ApplicationInstanceRecover) GetApplicationInstanceId() int32

func (*ApplicationInstanceRecover) GetOsinfo 

func (m *ApplicationInstanceRecover) GetOsinfo() *OSInfo

func (*ApplicationInstanceRecover) GetRegisterTime 

func (m *ApplicationInstanceRecover) GetRegisterTime() int64

func (*ApplicationInstanceRecover) ProtoMessage 

func (*ApplicationInstanceRecover) ProtoMessage()

func (*ApplicationInstanceRecover) Reset 

func (m *ApplicationInstanceRecover) Reset()

func (*ApplicationInstanceRecover) String 

func (m *ApplicationInstanceRecover) String() string

func (*ApplicationInstanceRecover) XXX_DiscardUnknown 

func (m *ApplicationInstanceRecover) XXX_DiscardUnknown()

func (*ApplicationInstanceRecover) XXX_Marshal 

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

func (*ApplicationInstanceRecover) XXX_Merge 

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

func (*ApplicationInstanceRecover) XXX_Size 

func (m *ApplicationInstanceRecover) XXX_Size() int

func (*ApplicationInstanceRecover) XXX_Unmarshal 

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

type ApplicationMapping 

type ApplicationMapping struct {
	Application          *KeyWithIntegerValue `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ApplicationMapping) Descriptor 

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

func (*ApplicationMapping) GetApplication 

func (m *ApplicationMapping) GetApplication() *KeyWithIntegerValue

func (*ApplicationMapping) ProtoMessage 

func (*ApplicationMapping) ProtoMessage()

func (*ApplicationMapping) Reset 

func (m *ApplicationMapping) Reset()

func (*ApplicationMapping) String 

func (m *ApplicationMapping) String() string

func (*ApplicationMapping) XXX_DiscardUnknown 

func (m *ApplicationMapping) XXX_DiscardUnknown()

func (*ApplicationMapping) XXX_Marshal 

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

func (*ApplicationMapping) XXX_Merge 

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

func (*ApplicationMapping) XXX_Size 

func (m *ApplicationMapping) XXX_Size() int

func (*ApplicationMapping) XXX_Unmarshal 

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

type ApplicationRegisterServiceClient 

type ApplicationRegisterServiceClient interface {
	ApplicationCodeRegister(ctx context.Context, in *Application, opts ...grpc.CallOption) (*ApplicationMapping, error)
}

ApplicationRegisterServiceClient is the client API for ApplicationRegisterService service.

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

func NewApplicationRegisterServiceClient 

func NewApplicationRegisterServiceClient(cc *grpc.ClientConn) ApplicationRegisterServiceClient

type ApplicationRegisterServiceServer 

type ApplicationRegisterServiceServer interface {
	ApplicationCodeRegister(context.Context, *Application) (*ApplicationMapping, error)
}

ApplicationRegisterServiceServer is the server API for ApplicationRegisterService service.

type CLRMetricV1 

type CLRMetricV1 struct {
	Time                 int64        `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu                  *v1.CPUV1    `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Gc                   *ClrGCV1     `protobuf:"bytes,3,opt,name=gc,proto3" json:"gc,omitempty"`
	Thread               *ClrThreadV1 `protobuf:"bytes,4,opt,name=thread,proto3" json:"thread,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CLRMetricV1) Descriptor 

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

func (*CLRMetricV1) GetCpu 

func (m *CLRMetricV1) GetCpu() *v1.CPUV1

func (*CLRMetricV1) GetGc 

func (m *CLRMetricV1) GetGc() *ClrGCV1

func (*CLRMetricV1) GetThread 

func (m *CLRMetricV1) GetThread() *ClrThreadV1

func (*CLRMetricV1) GetTime 

func (m *CLRMetricV1) GetTime() int64

func (*CLRMetricV1) ProtoMessage 

func (*CLRMetricV1) ProtoMessage()

func (*CLRMetricV1) Reset 

func (m *CLRMetricV1) Reset()

func (*CLRMetricV1) String 

func (m *CLRMetricV1) String() string

func (*CLRMetricV1) XXX_DiscardUnknown 

func (m *CLRMetricV1) XXX_DiscardUnknown()

func (*CLRMetricV1) XXX_Marshal 

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

func (*CLRMetricV1) XXX_Merge 

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

func (*CLRMetricV1) XXX_Size 

func (m *CLRMetricV1) XXX_Size() int

func (*CLRMetricV1) XXX_Unmarshal 

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

type ClrGCV1 

type ClrGCV1 struct {
	Gen0CollectCount     int64    `protobuf:"varint,1,opt,name=Gen0CollectCount,proto3" json:"Gen0CollectCount,omitempty"`
	Gen1CollectCount     int64    `protobuf:"varint,2,opt,name=Gen1CollectCount,proto3" json:"Gen1CollectCount,omitempty"`
	Gen2CollectCount     int64    `protobuf:"varint,3,opt,name=Gen2CollectCount,proto3" json:"Gen2CollectCount,omitempty"`
	HeapMemory           int64    `protobuf:"varint,4,opt,name=HeapMemory,proto3" json:"HeapMemory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClrGCV1) Descriptor 

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

func (*ClrGCV1) GetGen0CollectCount 

func (m *ClrGCV1) GetGen0CollectCount() int64

func (*ClrGCV1) GetGen1CollectCount 

func (m *ClrGCV1) GetGen1CollectCount() int64

func (*ClrGCV1) GetGen2CollectCount 

func (m *ClrGCV1) GetGen2CollectCount() int64

func (*ClrGCV1) GetHeapMemory 

func (m *ClrGCV1) GetHeapMemory() int64

func (*ClrGCV1) ProtoMessage 

func (*ClrGCV1) ProtoMessage()

func (*ClrGCV1) Reset 

func (m *ClrGCV1) Reset()

func (*ClrGCV1) String 

func (m *ClrGCV1) String() string

func (*ClrGCV1) XXX_DiscardUnknown 

func (m *ClrGCV1) XXX_DiscardUnknown()

func (*ClrGCV1) XXX_Marshal 

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

func (*ClrGCV1) XXX_Merge 

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

func (*ClrGCV1) XXX_Size 

func (m *ClrGCV1) XXX_Size() int

func (*ClrGCV1) XXX_Unmarshal 

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

type ClrThreadV1 

type ClrThreadV1 struct {
	AvailableCompletionPortThreads int32    `protobuf:"varint,1,opt,name=AvailableCompletionPortThreads,proto3" json:"AvailableCompletionPortThreads,omitempty"`
	AvailableWorkerThreads         int32    `protobuf:"varint,2,opt,name=AvailableWorkerThreads,proto3" json:"AvailableWorkerThreads,omitempty"`
	MaxCompletionPortThreads       int32    `protobuf:"varint,3,opt,name=MaxCompletionPortThreads,proto3" json:"MaxCompletionPortThreads,omitempty"`
	MaxWorkerThreads               int32    `protobuf:"varint,4,opt,name=MaxWorkerThreads,proto3" json:"MaxWorkerThreads,omitempty"`
	XXX_NoUnkeyedLiteral           struct{} `json:"-"`
	XXX_unrecognized               []byte   `json:"-"`
	XXX_sizecache                  int32    `json:"-"`
}

func (*ClrThreadV1) Descriptor 

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

func (*ClrThreadV1) GetAvailableCompletionPortThreads 

func (m *ClrThreadV1) GetAvailableCompletionPortThreads() int32

func (*ClrThreadV1) GetAvailableWorkerThreads 

func (m *ClrThreadV1) GetAvailableWorkerThreads() int32

func (*ClrThreadV1) GetMaxCompletionPortThreads 

func (m *ClrThreadV1) GetMaxCompletionPortThreads() int32

func (*ClrThreadV1) GetMaxWorkerThreads 

func (m *ClrThreadV1) GetMaxWorkerThreads() int32

func (*ClrThreadV1) ProtoMessage 

func (*ClrThreadV1) ProtoMessage()

func (*ClrThreadV1) Reset 

func (m *ClrThreadV1) Reset()

func (*ClrThreadV1) String 

func (m *ClrThreadV1) String() string

func (*ClrThreadV1) XXX_DiscardUnknown 

func (m *ClrThreadV1) XXX_DiscardUnknown()

func (*ClrThreadV1) XXX_Marshal 

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

func (*ClrThreadV1) XXX_Merge 

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

func (*ClrThreadV1) XXX_Size 

func (m *ClrThreadV1) XXX_Size() int

func (*ClrThreadV1) XXX_Unmarshal 

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

type Downstream 

type Downstream struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

nothing down stream from collector yet.

func (*Downstream) Descriptor 

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

func (*Downstream) ProtoMessage 

func (*Downstream) ProtoMessage()

func (*Downstream) Reset 

func (m *Downstream) Reset()

func (*Downstream) String 

func (m *Downstream) String() string

func (*Downstream) XXX_DiscardUnknown 

func (m *Downstream) XXX_DiscardUnknown()

func (*Downstream) XXX_Marshal 

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

func (*Downstream) XXX_Merge 

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

func (*Downstream) XXX_Size 

func (m *Downstream) XXX_Size() int

func (*Downstream) XXX_Unmarshal 

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

type GCPhraseV1 

type GCPhraseV1 int32
const (
	GCPhraseV1_NEW GCPhraseV1 = 0
	GCPhraseV1_OLD GCPhraseV1 = 1
)

func (GCPhraseV1) EnumDescriptor 

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

func (GCPhraseV1) String 

func (x GCPhraseV1) String() string

type GCV1 

type GCV1 struct {
	Phrase               GCPhraseV1 `protobuf:"varint,1,opt,name=phrase,proto3,enum=GCPhraseV1" json:"phrase,omitempty"`
	Count                int64      `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Time                 int64      `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GCV1) Descriptor 

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

func (*GCV1) GetCount 

func (m *GCV1) GetCount() int64

func (*GCV1) GetPhrase 

func (m *GCV1) GetPhrase() GCPhraseV1

func (*GCV1) GetTime 

func (m *GCV1) GetTime() int64

func (*GCV1) ProtoMessage 

func (*GCV1) ProtoMessage()

func (*GCV1) Reset 

func (m *GCV1) Reset()

func (*GCV1) String 

func (m *GCV1) String() string

func (*GCV1) XXX_DiscardUnknown 

func (m *GCV1) XXX_DiscardUnknown()

func (*GCV1) XXX_Marshal 

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

func (*GCV1) XXX_Merge 

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

func (*GCV1) XXX_Size 

func (m *GCV1) XXX_Size() int

func (*GCV1) XXX_Unmarshal 

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

type InstanceDiscoveryServiceClient 

type InstanceDiscoveryServiceClient interface {
	RegisterInstance(ctx context.Context, in *ApplicationInstance, opts ...grpc.CallOption) (*ApplicationInstanceMapping, error)
	Heartbeat(ctx context.Context, in *ApplicationInstanceHeartbeat, opts ...grpc.CallOption) (*Downstream, error)
}

InstanceDiscoveryServiceClient is the client API for InstanceDiscoveryService service.

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

func NewInstanceDiscoveryServiceClient 

func NewInstanceDiscoveryServiceClient(cc *grpc.ClientConn) InstanceDiscoveryServiceClient

type InstanceDiscoveryServiceServer 

type InstanceDiscoveryServiceServer interface {
	RegisterInstance(context.Context, *ApplicationInstance) (*ApplicationInstanceMapping, error)
	Heartbeat(context.Context, *ApplicationInstanceHeartbeat) (*Downstream, error)
}

InstanceDiscoveryServiceServer is the server API for InstanceDiscoveryService service.

type JVMMetricV1 

type JVMMetricV1 struct {
	Time                 int64           `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Cpu                  *v1.CPUV1       `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory               []*MemoryV1     `protobuf:"bytes,3,rep,name=memory,proto3" json:"memory,omitempty"`
	MemoryPool           []*MemoryPoolV1 `protobuf:"bytes,4,rep,name=memoryPool,proto3" json:"memoryPool,omitempty"`
	Gc                   []*GCV1         `protobuf:"bytes,5,rep,name=gc,proto3" json:"gc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*JVMMetricV1) Descriptor 

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

func (*JVMMetricV1) GetCpu 

func (m *JVMMetricV1) GetCpu() *v1.CPUV1

func (*JVMMetricV1) GetGc 

func (m *JVMMetricV1) GetGc() []*GCV1

func (*JVMMetricV1) GetMemory 

func (m *JVMMetricV1) GetMemory() []*MemoryV1

func (*JVMMetricV1) GetMemoryPool 

func (m *JVMMetricV1) GetMemoryPool() []*MemoryPoolV1

func (*JVMMetricV1) GetTime 

func (m *JVMMetricV1) GetTime() int64

func (*JVMMetricV1) ProtoMessage 

func (*JVMMetricV1) ProtoMessage()

func (*JVMMetricV1) Reset 

func (m *JVMMetricV1) Reset()

func (*JVMMetricV1) String 

func (m *JVMMetricV1) String() string

func (*JVMMetricV1) XXX_DiscardUnknown 

func (m *JVMMetricV1) XXX_DiscardUnknown()

func (*JVMMetricV1) XXX_Marshal 

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

func (*JVMMetricV1) XXX_Merge 

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

func (*JVMMetricV1) XXX_Size 

func (m *JVMMetricV1) XXX_Size() int

func (*JVMMetricV1) XXX_Unmarshal 

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

type JVMMetrics 

type JVMMetrics struct {
	Metrics               []*JVMMetricV1 `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	ApplicationInstanceId int32          `protobuf:"varint,2,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}       `json:"-"`
	XXX_unrecognized      []byte         `json:"-"`
	XXX_sizecache         int32          `json:"-"`
}

func (*JVMMetrics) Descriptor 

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

func (*JVMMetrics) GetApplicationInstanceId 

func (m *JVMMetrics) GetApplicationInstanceId() int32

func (*JVMMetrics) GetMetrics 

func (m *JVMMetrics) GetMetrics() []*JVMMetricV1

func (*JVMMetrics) ProtoMessage 

func (*JVMMetrics) ProtoMessage()

func (*JVMMetrics) Reset 

func (m *JVMMetrics) Reset()

func (*JVMMetrics) String 

func (m *JVMMetrics) String() string

func (*JVMMetrics) XXX_DiscardUnknown 

func (m *JVMMetrics) XXX_DiscardUnknown()

func (*JVMMetrics) XXX_Marshal 

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

func (*JVMMetrics) XXX_Merge 

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

func (*JVMMetrics) XXX_Size 

func (m *JVMMetrics) XXX_Size() int

func (*JVMMetrics) XXX_Unmarshal 

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

type JVMMetricsServiceClient 

type JVMMetricsServiceClient interface {
	Collect(ctx context.Context, in *JVMMetrics, opts ...grpc.CallOption) (*Downstream, error)
}

JVMMetricsServiceClient is the client API for JVMMetricsService service.

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

func NewJVMMetricsServiceClient 

func NewJVMMetricsServiceClient(cc *grpc.ClientConn) JVMMetricsServiceClient

type JVMMetricsServiceServer 

type JVMMetricsServiceServer interface {
	Collect(context.Context, *JVMMetrics) (*Downstream, error)
}

JVMMetricsServiceServer is the server API for JVMMetricsService service.

type KeyWithIntegerValue 

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

func (*KeyWithIntegerValue) Descriptor 

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

func (*KeyWithIntegerValue) GetKey 

func (m *KeyWithIntegerValue) GetKey() string

func (*KeyWithIntegerValue) GetValue 

func (m *KeyWithIntegerValue) GetValue() int32

func (*KeyWithIntegerValue) ProtoMessage 

func (*KeyWithIntegerValue) ProtoMessage()

func (*KeyWithIntegerValue) Reset 

func (m *KeyWithIntegerValue) Reset()

func (*KeyWithIntegerValue) String 

func (m *KeyWithIntegerValue) String() string

func (*KeyWithIntegerValue) XXX_DiscardUnknown 

func (m *KeyWithIntegerValue) XXX_DiscardUnknown()

func (*KeyWithIntegerValue) XXX_Marshal 

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

func (*KeyWithIntegerValue) XXX_Merge 

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

func (*KeyWithIntegerValue) XXX_Size 

func (m *KeyWithIntegerValue) XXX_Size() int

func (*KeyWithIntegerValue) XXX_Unmarshal 

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

type KeyWithStringValue 

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

func (*KeyWithStringValue) Descriptor 

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

func (*KeyWithStringValue) GetKey 

func (m *KeyWithStringValue) GetKey() string

func (*KeyWithStringValue) GetValue 

func (m *KeyWithStringValue) GetValue() string

func (*KeyWithStringValue) ProtoMessage 

func (*KeyWithStringValue) ProtoMessage()

func (*KeyWithStringValue) Reset 

func (m *KeyWithStringValue) Reset()

func (*KeyWithStringValue) String 

func (m *KeyWithStringValue) String() string

func (*KeyWithStringValue) XXX_DiscardUnknown 

func (m *KeyWithStringValue) XXX_DiscardUnknown()

func (*KeyWithStringValue) XXX_Marshal 

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

func (*KeyWithStringValue) XXX_Merge 

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

func (*KeyWithStringValue) XXX_Size 

func (m *KeyWithStringValue) XXX_Size() int

func (*KeyWithStringValue) XXX_Unmarshal 

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

type LogMessage 

type LogMessage struct {
	Time                 int64                 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Data                 []*KeyWithStringValue `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*LogMessage) Descriptor 

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

func (*LogMessage) GetData 

func (m *LogMessage) GetData() []*KeyWithStringValue

func (*LogMessage) GetTime 

func (m *LogMessage) GetTime() int64

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset 

func (m *LogMessage) Reset()

func (*LogMessage) String 

func (m *LogMessage) String() string

func (*LogMessage) XXX_DiscardUnknown 

func (m *LogMessage) XXX_DiscardUnknown()

func (*LogMessage) XXX_Marshal 

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

func (*LogMessage) XXX_Merge 

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

func (*LogMessage) XXX_Size 

func (m *LogMessage) XXX_Size() int

func (*LogMessage) XXX_Unmarshal 

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

type MemoryPoolV1 

type MemoryPoolV1 struct {
	Type                 PoolTypeV1 `protobuf:"varint,1,opt,name=type,proto3,enum=PoolTypeV1" json:"type,omitempty"`
	Init                 int64      `protobuf:"varint,2,opt,name=init,proto3" json:"init,omitempty"`
	Max                  int64      `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Used                 int64      `protobuf:"varint,4,opt,name=used,proto3" json:"used,omitempty"`
	Commited             int64      `protobuf:"varint,5,opt,name=commited,proto3" json:"commited,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MemoryPoolV1) Descriptor 

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

func (*MemoryPoolV1) GetCommited 

func (m *MemoryPoolV1) GetCommited() int64

func (*MemoryPoolV1) GetInit 

func (m *MemoryPoolV1) GetInit() int64

func (*MemoryPoolV1) GetMax 

func (m *MemoryPoolV1) GetMax() int64

func (*MemoryPoolV1) GetType 

func (m *MemoryPoolV1) GetType() PoolTypeV1

func (*MemoryPoolV1) GetUsed 

func (m *MemoryPoolV1) GetUsed() int64

func (*MemoryPoolV1) ProtoMessage 

func (*MemoryPoolV1) ProtoMessage()

func (*MemoryPoolV1) Reset 

func (m *MemoryPoolV1) Reset()

func (*MemoryPoolV1) String 

func (m *MemoryPoolV1) String() string

func (*MemoryPoolV1) XXX_DiscardUnknown 

func (m *MemoryPoolV1) XXX_DiscardUnknown()

func (*MemoryPoolV1) XXX_Marshal 

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

func (*MemoryPoolV1) XXX_Merge 

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

func (*MemoryPoolV1) XXX_Size 

func (m *MemoryPoolV1) XXX_Size() int

func (*MemoryPoolV1) XXX_Unmarshal 

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

type MemoryV1 

type MemoryV1 struct {
	IsHeap               bool     `protobuf:"varint,1,opt,name=isHeap,proto3" json:"isHeap,omitempty"`
	Init                 int64    `protobuf:"varint,2,opt,name=init,proto3" json:"init,omitempty"`
	Max                  int64    `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Used                 int64    `protobuf:"varint,4,opt,name=used,proto3" json:"used,omitempty"`
	Committed            int64    `protobuf:"varint,5,opt,name=committed,proto3" json:"committed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MemoryV1) Descriptor 

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

func (*MemoryV1) GetCommitted 

func (m *MemoryV1) GetCommitted() int64

func (*MemoryV1) GetInit 

func (m *MemoryV1) GetInit() int64

func (*MemoryV1) GetIsHeap 

func (m *MemoryV1) GetIsHeap() bool

func (*MemoryV1) GetMax 

func (m *MemoryV1) GetMax() int64

func (*MemoryV1) GetUsed 

func (m *MemoryV1) GetUsed() int64

func (*MemoryV1) ProtoMessage 

func (*MemoryV1) ProtoMessage()

func (*MemoryV1) Reset 

func (m *MemoryV1) Reset()

func (*MemoryV1) String 

func (m *MemoryV1) String() string

func (*MemoryV1) XXX_DiscardUnknown 

func (m *MemoryV1) XXX_DiscardUnknown()

func (*MemoryV1) XXX_Marshal 

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

func (*MemoryV1) XXX_Merge 

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

func (*MemoryV1) XXX_Size 

func (m *MemoryV1) XXX_Size() int

func (*MemoryV1) XXX_Unmarshal 

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

type NetworkAddressMappings 

type NetworkAddressMappings struct {
	AddressIds           []*KeyWithIntegerValue `protobuf:"bytes,1,rep,name=addressIds,proto3" json:"addressIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*NetworkAddressMappings) Descriptor 

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

func (*NetworkAddressMappings) GetAddressIds 

func (m *NetworkAddressMappings) GetAddressIds() []*KeyWithIntegerValue

func (*NetworkAddressMappings) ProtoMessage 

func (*NetworkAddressMappings) ProtoMessage()

func (*NetworkAddressMappings) Reset 

func (m *NetworkAddressMappings) Reset()

func (*NetworkAddressMappings) String 

func (m *NetworkAddressMappings) String() string

func (*NetworkAddressMappings) XXX_DiscardUnknown 

func (m *NetworkAddressMappings) XXX_DiscardUnknown()

func (*NetworkAddressMappings) XXX_Marshal 

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

func (*NetworkAddressMappings) XXX_Merge 

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

func (*NetworkAddressMappings) XXX_Size 

func (m *NetworkAddressMappings) XXX_Size() int

func (*NetworkAddressMappings) XXX_Unmarshal 

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

type NetworkAddressRegisterServiceClient 

type NetworkAddressRegisterServiceClient interface {
	BatchRegister(ctx context.Context, in *NetworkAddresses, opts ...grpc.CallOption) (*NetworkAddressMappings, error)
}

NetworkAddressRegisterServiceClient is the client API for NetworkAddressRegisterService service.

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

func NewNetworkAddressRegisterServiceClient 

func NewNetworkAddressRegisterServiceClient(cc *grpc.ClientConn) NetworkAddressRegisterServiceClient

type NetworkAddressRegisterServiceServer 

type NetworkAddressRegisterServiceServer interface {
	BatchRegister(context.Context, *NetworkAddresses) (*NetworkAddressMappings, error)
}

NetworkAddressRegisterServiceServer is the server API for NetworkAddressRegisterService service.

type NetworkAddresses 

type NetworkAddresses struct {
	Addresses            []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkAddresses) Descriptor 

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

func (*NetworkAddresses) GetAddresses 

func (m *NetworkAddresses) GetAddresses() []string

func (*NetworkAddresses) ProtoMessage 

func (*NetworkAddresses) ProtoMessage()

func (*NetworkAddresses) Reset 

func (m *NetworkAddresses) Reset()

func (*NetworkAddresses) String 

func (m *NetworkAddresses) String() string

func (*NetworkAddresses) XXX_DiscardUnknown 

func (m *NetworkAddresses) XXX_DiscardUnknown()

func (*NetworkAddresses) XXX_Marshal 

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

func (*NetworkAddresses) XXX_Merge 

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

func (*NetworkAddresses) XXX_Size 

func (m *NetworkAddresses) XXX_Size() int

func (*NetworkAddresses) XXX_Unmarshal 

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

type OSInfo 

type OSInfo struct {
	OsName               string   `protobuf:"bytes,1,opt,name=osName,proto3" json:"osName,omitempty"`
	Hostname             string   `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ProcessNo            int32    `protobuf:"varint,3,opt,name=processNo,proto3" json:"processNo,omitempty"`
	Ipv4S                []string `protobuf:"bytes,4,rep,name=ipv4s,proto3" json:"ipv4s,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OSInfo) Descriptor 

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

func (*OSInfo) GetHostname 

func (m *OSInfo) GetHostname() string

func (*OSInfo) GetIpv4S 

func (m *OSInfo) GetIpv4S() []string

func (*OSInfo) GetOsName 

func (m *OSInfo) GetOsName() string

func (*OSInfo) GetProcessNo 

func (m *OSInfo) GetProcessNo() int32

func (*OSInfo) ProtoMessage 

func (*OSInfo) ProtoMessage()

func (*OSInfo) Reset 

func (m *OSInfo) Reset()

func (*OSInfo) String 

func (m *OSInfo) String() string

func (*OSInfo) XXX_DiscardUnknown 

func (m *OSInfo) XXX_DiscardUnknown()

func (*OSInfo) XXX_Marshal 

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

func (*OSInfo) XXX_Merge 

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

func (*OSInfo) XXX_Size 

func (m *OSInfo) XXX_Size() int

func (*OSInfo) XXX_Unmarshal 

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

type PoolTypeV1 

type PoolTypeV1 int32
const (
	PoolTypeV1_CODE_CACHE_USAGE PoolTypeV1 = 0
	PoolTypeV1_NEWGEN_USAGE     PoolTypeV1 = 1
	PoolTypeV1_OLDGEN_USAGE     PoolTypeV1 = 2
	PoolTypeV1_SURVIVOR_USAGE   PoolTypeV1 = 3
	PoolTypeV1_PERMGEN_USAGE    PoolTypeV1 = 4
	PoolTypeV1_METASPACE_USAGE  PoolTypeV1 = 5
)

func (PoolTypeV1) EnumDescriptor 

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

func (PoolTypeV1) String 

func (x PoolTypeV1) String() string

type RefTypeV1 

type RefTypeV1 int32
const (
	RefTypeV1_CrossProcess RefTypeV1 = 0
	RefTypeV1_CrossThread  RefTypeV1 = 1
)

func (RefTypeV1) EnumDescriptor 

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

func (RefTypeV1) String 

func (x RefTypeV1) String() string

type ServiceNameCollection 

type ServiceNameCollection struct {
	Elements             []*ServiceNameElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ServiceNameCollection) Descriptor 

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

func (*ServiceNameCollection) GetElements 

func (m *ServiceNameCollection) GetElements() []*ServiceNameElement

func (*ServiceNameCollection) ProtoMessage 

func (*ServiceNameCollection) ProtoMessage()

func (*ServiceNameCollection) Reset 

func (m *ServiceNameCollection) Reset()

func (*ServiceNameCollection) String 

func (m *ServiceNameCollection) String() string

func (*ServiceNameCollection) XXX_DiscardUnknown 

func (m *ServiceNameCollection) XXX_DiscardUnknown()

func (*ServiceNameCollection) XXX_Marshal 

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

func (*ServiceNameCollection) XXX_Merge 

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

func (*ServiceNameCollection) XXX_Size 

func (m *ServiceNameCollection) XXX_Size() int

func (*ServiceNameCollection) XXX_Unmarshal 

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

type ServiceNameDiscoveryServiceClient 

type ServiceNameDiscoveryServiceClient interface {
	Discovery(ctx context.Context, in *ServiceNameCollection, opts ...grpc.CallOption) (*ServiceNameMappingCollection, error)
}

ServiceNameDiscoveryServiceClient is the client API for ServiceNameDiscoveryService service.

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

func NewServiceNameDiscoveryServiceClient 

func NewServiceNameDiscoveryServiceClient(cc *grpc.ClientConn) ServiceNameDiscoveryServiceClient

type ServiceNameDiscoveryServiceServer 

type ServiceNameDiscoveryServiceServer interface {
	Discovery(context.Context, *ServiceNameCollection) (*ServiceNameMappingCollection, error)
}

ServiceNameDiscoveryServiceServer is the server API for ServiceNameDiscoveryService service.

type ServiceNameElement 

type ServiceNameElement struct {
	ServiceName          string     `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	ApplicationId        int32      `protobuf:"varint,2,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	SrcSpanType          SpanTypeV1 `protobuf:"varint,3,opt,name=srcSpanType,proto3,enum=SpanTypeV1" json:"srcSpanType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ServiceNameElement) Descriptor 

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

func (*ServiceNameElement) GetApplicationId 

func (m *ServiceNameElement) GetApplicationId() int32

func (*ServiceNameElement) GetServiceName 

func (m *ServiceNameElement) GetServiceName() string

func (*ServiceNameElement) GetSrcSpanType 

func (m *ServiceNameElement) GetSrcSpanType() SpanTypeV1

func (*ServiceNameElement) ProtoMessage 

func (*ServiceNameElement) ProtoMessage()

func (*ServiceNameElement) Reset 

func (m *ServiceNameElement) Reset()

func (*ServiceNameElement) String 

func (m *ServiceNameElement) String() string

func (*ServiceNameElement) XXX_DiscardUnknown 

func (m *ServiceNameElement) XXX_DiscardUnknown()

func (*ServiceNameElement) XXX_Marshal 

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

func (*ServiceNameElement) XXX_Merge 

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

func (*ServiceNameElement) XXX_Size 

func (m *ServiceNameElement) XXX_Size() int

func (*ServiceNameElement) XXX_Unmarshal 

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

type ServiceNameMappingCollection 

type ServiceNameMappingCollection struct {
	Elements             []*ServiceNameMappingElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ServiceNameMappingCollection) Descriptor 

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

func (*ServiceNameMappingCollection) GetElements 

func (m *ServiceNameMappingCollection) GetElements() []*ServiceNameMappingElement

func (*ServiceNameMappingCollection) ProtoMessage 

func (*ServiceNameMappingCollection) ProtoMessage()

func (*ServiceNameMappingCollection) Reset 

func (m *ServiceNameMappingCollection) Reset()

func (*ServiceNameMappingCollection) String 

func (m *ServiceNameMappingCollection) String() string

func (*ServiceNameMappingCollection) XXX_DiscardUnknown 

func (m *ServiceNameMappingCollection) XXX_DiscardUnknown()

func (*ServiceNameMappingCollection) XXX_Marshal 

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

func (*ServiceNameMappingCollection) XXX_Merge 

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

func (*ServiceNameMappingCollection) XXX_Size 

func (m *ServiceNameMappingCollection) XXX_Size() int

func (*ServiceNameMappingCollection) XXX_Unmarshal 

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

type ServiceNameMappingElement 

type ServiceNameMappingElement struct {
	ServiceId            int32               `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	Element              *ServiceNameElement `protobuf:"bytes,2,opt,name=element,proto3" json:"element,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ServiceNameMappingElement) Descriptor 

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

func (*ServiceNameMappingElement) GetElement 

func (m *ServiceNameMappingElement) GetElement() *ServiceNameElement

func (*ServiceNameMappingElement) GetServiceId 

func (m *ServiceNameMappingElement) GetServiceId() int32

func (*ServiceNameMappingElement) ProtoMessage 

func (*ServiceNameMappingElement) ProtoMessage()

func (*ServiceNameMappingElement) Reset 

func (m *ServiceNameMappingElement) Reset()

func (*ServiceNameMappingElement) String 

func (m *ServiceNameMappingElement) String() string

func (*ServiceNameMappingElement) XXX_DiscardUnknown 

func (m *ServiceNameMappingElement) XXX_DiscardUnknown()

func (*ServiceNameMappingElement) XXX_Marshal 

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

func (*ServiceNameMappingElement) XXX_Merge 

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

func (*ServiceNameMappingElement) XXX_Size 

func (m *ServiceNameMappingElement) XXX_Size() int

func (*ServiceNameMappingElement) XXX_Unmarshal 

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

type SpanLayerV1 

type SpanLayerV1 int32
const (
	SpanLayerV1_Unknown      SpanLayerV1 = 0
	SpanLayerV1_Database     SpanLayerV1 = 1
	SpanLayerV1_RPCFramework SpanLayerV1 = 2
	SpanLayerV1_Http         SpanLayerV1 = 3
	SpanLayerV1_MQ           SpanLayerV1 = 4
	SpanLayerV1_Cache        SpanLayerV1 = 5
)

func (SpanLayerV1) EnumDescriptor 

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

func (SpanLayerV1) String 

func (x SpanLayerV1) String() string

type SpanObjectV1 

type SpanObjectV1 struct {
	SpanId               int32                    `protobuf:"varint,1,opt,name=spanId,proto3" json:"spanId,omitempty"`
	ParentSpanId         int32                    `protobuf:"varint,2,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	StartTime            int64                    `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64                    `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Refs                 []*TraceSegmentReference `protobuf:"bytes,5,rep,name=refs,proto3" json:"refs,omitempty"`
	OperationNameId      int32                    `protobuf:"varint,6,opt,name=operationNameId,proto3" json:"operationNameId,omitempty"`
	OperationName        string                   `protobuf:"bytes,7,opt,name=operationName,proto3" json:"operationName,omitempty"`
	PeerId               int32                    `protobuf:"varint,8,opt,name=peerId,proto3" json:"peerId,omitempty"`
	Peer                 string                   `protobuf:"bytes,9,opt,name=peer,proto3" json:"peer,omitempty"`
	SpanType             SpanTypeV1               `protobuf:"varint,10,opt,name=spanType,proto3,enum=SpanTypeV1" json:"spanType,omitempty"`
	SpanLayer            SpanLayerV1              `protobuf:"varint,11,opt,name=spanLayer,proto3,enum=SpanLayerV1" json:"spanLayer,omitempty"`
	ComponentId          int32                    `protobuf:"varint,12,opt,name=componentId,proto3" json:"componentId,omitempty"`
	Component            string                   `protobuf:"bytes,13,opt,name=component,proto3" json:"component,omitempty"`
	IsError              bool                     `protobuf:"varint,14,opt,name=isError,proto3" json:"isError,omitempty"`
	Tags                 []*KeyWithStringValue    `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	Logs                 []*LogMessage            `protobuf:"bytes,16,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*SpanObjectV1) Descriptor 

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

func (*SpanObjectV1) GetComponent 

func (m *SpanObjectV1) GetComponent() string

func (*SpanObjectV1) GetComponentId 

func (m *SpanObjectV1) GetComponentId() int32

func (*SpanObjectV1) GetEndTime 

func (m *SpanObjectV1) GetEndTime() int64

func (*SpanObjectV1) GetIsError 

func (m *SpanObjectV1) GetIsError() bool

func (*SpanObjectV1) GetLogs 

func (m *SpanObjectV1) GetLogs() []*LogMessage

func (*SpanObjectV1) GetOperationName 

func (m *SpanObjectV1) GetOperationName() string

func (*SpanObjectV1) GetOperationNameId 

func (m *SpanObjectV1) GetOperationNameId() int32

func (*SpanObjectV1) GetParentSpanId 

func (m *SpanObjectV1) GetParentSpanId() int32

func (*SpanObjectV1) GetPeer 

func (m *SpanObjectV1) GetPeer() string

func (*SpanObjectV1) GetPeerId 

func (m *SpanObjectV1) GetPeerId() int32

func (*SpanObjectV1) GetRefs 

func (m *SpanObjectV1) GetRefs() []*TraceSegmentReference

func (*SpanObjectV1) GetSpanId 

func (m *SpanObjectV1) GetSpanId() int32

func (*SpanObjectV1) GetSpanLayer 

func (m *SpanObjectV1) GetSpanLayer() SpanLayerV1

func (*SpanObjectV1) GetSpanType 

func (m *SpanObjectV1) GetSpanType() SpanTypeV1

func (*SpanObjectV1) GetStartTime 

func (m *SpanObjectV1) GetStartTime() int64

func (*SpanObjectV1) GetTags 

func (m *SpanObjectV1) GetTags() []*KeyWithStringValue

func (*SpanObjectV1) ProtoMessage 

func (*SpanObjectV1) ProtoMessage()

func (*SpanObjectV1) Reset 

func (m *SpanObjectV1) Reset()

func (*SpanObjectV1) String 

func (m *SpanObjectV1) String() string

func (*SpanObjectV1) XXX_DiscardUnknown 

func (m *SpanObjectV1) XXX_DiscardUnknown()

func (*SpanObjectV1) XXX_Marshal 

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

func (*SpanObjectV1) XXX_Merge 

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

func (*SpanObjectV1) XXX_Size 

func (m *SpanObjectV1) XXX_Size() int

func (*SpanObjectV1) XXX_Unmarshal 

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

type SpanTypeV1 

type SpanTypeV1 int32
const (
	SpanTypeV1_Entry SpanTypeV1 = 0
	SpanTypeV1_Exit  SpanTypeV1 = 1
	SpanTypeV1_Local SpanTypeV1 = 2
)

func (SpanTypeV1) EnumDescriptor 

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

func (SpanTypeV1) String 

func (x SpanTypeV1) String() string

type TraceSegmentObject 

type TraceSegmentObject struct {
	TraceSegmentId        *UniqueId       `protobuf:"bytes,1,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	Spans                 []*SpanObjectV1 `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	ApplicationId         int32           `protobuf:"varint,3,opt,name=applicationId,proto3" json:"applicationId,omitempty"`
	ApplicationInstanceId int32           `protobuf:"varint,4,opt,name=applicationInstanceId,proto3" json:"applicationInstanceId,omitempty"`
	IsSizeLimited         bool            `protobuf:"varint,5,opt,name=isSizeLimited,proto3" json:"isSizeLimited,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}        `json:"-"`
	XXX_unrecognized      []byte          `json:"-"`
	XXX_sizecache         int32           `json:"-"`
}

func (*TraceSegmentObject) Descriptor 

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

func (*TraceSegmentObject) GetApplicationId 

func (m *TraceSegmentObject) GetApplicationId() int32

func (*TraceSegmentObject) GetApplicationInstanceId 

func (m *TraceSegmentObject) GetApplicationInstanceId() int32

func (*TraceSegmentObject) GetIsSizeLimited 

func (m *TraceSegmentObject) GetIsSizeLimited() bool

func (*TraceSegmentObject) GetSpans 

func (m *TraceSegmentObject) GetSpans() []*SpanObjectV1

func (*TraceSegmentObject) GetTraceSegmentId 

func (m *TraceSegmentObject) GetTraceSegmentId() *UniqueId

func (*TraceSegmentObject) ProtoMessage 

func (*TraceSegmentObject) ProtoMessage()

func (*TraceSegmentObject) Reset 

func (m *TraceSegmentObject) Reset()

func (*TraceSegmentObject) String 

func (m *TraceSegmentObject) String() string

func (*TraceSegmentObject) XXX_DiscardUnknown 

func (m *TraceSegmentObject) XXX_DiscardUnknown()

func (*TraceSegmentObject) XXX_Marshal 

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

func (*TraceSegmentObject) XXX_Merge 

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

func (*TraceSegmentObject) XXX_Size 

func (m *TraceSegmentObject) XXX_Size() int

func (*TraceSegmentObject) XXX_Unmarshal 

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

type TraceSegmentReference 

type TraceSegmentReference struct {
	RefType                     RefTypeV1 `protobuf:"varint,1,opt,name=refType,proto3,enum=RefTypeV1" json:"refType,omitempty"`
	ParentTraceSegmentId        *UniqueId `protobuf:"bytes,2,opt,name=parentTraceSegmentId,proto3" json:"parentTraceSegmentId,omitempty"`
	ParentSpanId                int32     `protobuf:"varint,3,opt,name=parentSpanId,proto3" json:"parentSpanId,omitempty"`
	ParentApplicationInstanceId int32     `protobuf:"varint,4,opt,name=parentApplicationInstanceId,proto3" json:"parentApplicationInstanceId,omitempty"`
	NetworkAddress              string    `protobuf:"bytes,5,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
	NetworkAddressId            int32     `protobuf:"varint,6,opt,name=networkAddressId,proto3" json:"networkAddressId,omitempty"`
	EntryApplicationInstanceId  int32     `protobuf:"varint,7,opt,name=entryApplicationInstanceId,proto3" json:"entryApplicationInstanceId,omitempty"`
	EntryServiceName            string    `protobuf:"bytes,8,opt,name=entryServiceName,proto3" json:"entryServiceName,omitempty"`
	EntryServiceId              int32     `protobuf:"varint,9,opt,name=entryServiceId,proto3" json:"entryServiceId,omitempty"`
	ParentServiceName           string    `protobuf:"bytes,10,opt,name=parentServiceName,proto3" json:"parentServiceName,omitempty"`
	ParentServiceId             int32     `protobuf:"varint,11,opt,name=parentServiceId,proto3" json:"parentServiceId,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}  `json:"-"`
	XXX_unrecognized            []byte    `json:"-"`
	XXX_sizecache               int32     `json:"-"`
}

func (*TraceSegmentReference) Descriptor 

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

func (*TraceSegmentReference) GetEntryApplicationInstanceId 

func (m *TraceSegmentReference) GetEntryApplicationInstanceId() int32

func (*TraceSegmentReference) GetEntryServiceId 

func (m *TraceSegmentReference) GetEntryServiceId() int32

func (*TraceSegmentReference) GetEntryServiceName 

func (m *TraceSegmentReference) GetEntryServiceName() string

func (*TraceSegmentReference) GetNetworkAddress 

func (m *TraceSegmentReference) GetNetworkAddress() string

func (*TraceSegmentReference) GetNetworkAddressId 

func (m *TraceSegmentReference) GetNetworkAddressId() int32

func (*TraceSegmentReference) GetParentApplicationInstanceId 

func (m *TraceSegmentReference) GetParentApplicationInstanceId() int32

func (*TraceSegmentReference) GetParentServiceId 

func (m *TraceSegmentReference) GetParentServiceId() int32

func (*TraceSegmentReference) GetParentServiceName 

func (m *TraceSegmentReference) GetParentServiceName() string

func (*TraceSegmentReference) GetParentSpanId 

func (m *TraceSegmentReference) GetParentSpanId() int32

func (*TraceSegmentReference) GetParentTraceSegmentId 

func (m *TraceSegmentReference) GetParentTraceSegmentId() *UniqueId

func (*TraceSegmentReference) GetRefType 

func (m *TraceSegmentReference) GetRefType() RefTypeV1

func (*TraceSegmentReference) ProtoMessage 

func (*TraceSegmentReference) ProtoMessage()

func (*TraceSegmentReference) Reset 

func (m *TraceSegmentReference) Reset()

func (*TraceSegmentReference) String 

func (m *TraceSegmentReference) String() string

func (*TraceSegmentReference) XXX_DiscardUnknown 

func (m *TraceSegmentReference) XXX_DiscardUnknown()

func (*TraceSegmentReference) XXX_Marshal 

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

func (*TraceSegmentReference) XXX_Merge 

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

func (*TraceSegmentReference) XXX_Size 

func (m *TraceSegmentReference) XXX_Size() int

func (*TraceSegmentReference) XXX_Unmarshal 

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

type TraceSegmentServiceClient 

type TraceSegmentServiceClient interface {
	Collect(ctx context.Context, opts ...grpc.CallOption) (TraceSegmentService_CollectClient, error)
}

TraceSegmentServiceClient is the client API for TraceSegmentService service.

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

func NewTraceSegmentServiceClient 

func NewTraceSegmentServiceClient(cc *grpc.ClientConn) TraceSegmentServiceClient

type TraceSegmentServiceServer 

type TraceSegmentServiceServer interface {
	Collect(TraceSegmentService_CollectServer) error
}

TraceSegmentServiceServer is the server API for TraceSegmentService service.

type TraceSegmentService_CollectClient 

type TraceSegmentService_CollectClient interface {
	Send(*UpstreamSegment) error
	CloseAndRecv() (*Downstream, error)
	grpc.ClientStream
}

type TraceSegmentService_CollectServer 

type TraceSegmentService_CollectServer interface {
	SendAndClose(*Downstream) error
	Recv() (*UpstreamSegment, error)
	grpc.ServerStream
}

type UnimplementedApplicationRegisterServiceServer 

type UnimplementedApplicationRegisterServiceServer struct {
}

UnimplementedApplicationRegisterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationRegisterServiceServer) ApplicationCodeRegister 

func (*UnimplementedApplicationRegisterServiceServer) ApplicationCodeRegister(ctx context.Context, req *Application) (*ApplicationMapping, error)

type UnimplementedInstanceDiscoveryServiceServer 

type UnimplementedInstanceDiscoveryServiceServer struct {
}

UnimplementedInstanceDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInstanceDiscoveryServiceServer) Heartbeat 

func (*UnimplementedInstanceDiscoveryServiceServer) Heartbeat(ctx context.Context, req *ApplicationInstanceHeartbeat) (*Downstream, error)

func (*UnimplementedInstanceDiscoveryServiceServer) RegisterInstance 

func (*UnimplementedInstanceDiscoveryServiceServer) RegisterInstance(ctx context.Context, req *ApplicationInstance) (*ApplicationInstanceMapping, error)

type UnimplementedJVMMetricsServiceServer 

type UnimplementedJVMMetricsServiceServer struct {
}

UnimplementedJVMMetricsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJVMMetricsServiceServer) Collect 

func (*UnimplementedJVMMetricsServiceServer) Collect(ctx context.Context, req *JVMMetrics) (*Downstream, error)

type UnimplementedNetworkAddressRegisterServiceServer 

type UnimplementedNetworkAddressRegisterServiceServer struct {
}

UnimplementedNetworkAddressRegisterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkAddressRegisterServiceServer) BatchRegister 

func (*UnimplementedNetworkAddressRegisterServiceServer) BatchRegister(ctx context.Context, req *NetworkAddresses) (*NetworkAddressMappings, error)

type UnimplementedServiceNameDiscoveryServiceServer 

type UnimplementedServiceNameDiscoveryServiceServer struct {
}

UnimplementedServiceNameDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceNameDiscoveryServiceServer) Discovery 

func (*UnimplementedServiceNameDiscoveryServiceServer) Discovery(ctx context.Context, req *ServiceNameCollection) (*ServiceNameMappingCollection, error)

type UnimplementedTraceSegmentServiceServer 

type UnimplementedTraceSegmentServiceServer struct {
}

UnimplementedTraceSegmentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTraceSegmentServiceServer) Collect 

func (*UnimplementedTraceSegmentServiceServer) Collect(srv TraceSegmentService_CollectServer) error

type UniqueId 

type UniqueId struct {
	IdParts              []int64  `protobuf:"varint,1,rep,packed,name=idParts,proto3" json:"idParts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UniqueId) Descriptor 

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

func (*UniqueId) GetIdParts 

func (m *UniqueId) GetIdParts() []int64

func (*UniqueId) ProtoMessage 

func (*UniqueId) ProtoMessage()

func (*UniqueId) Reset 

func (m *UniqueId) Reset()

func (*UniqueId) String 

func (m *UniqueId) String() string

func (*UniqueId) XXX_DiscardUnknown 

func (m *UniqueId) XXX_DiscardUnknown()

func (*UniqueId) XXX_Marshal 

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

func (*UniqueId) XXX_Merge 

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

func (*UniqueId) XXX_Size 

func (m *UniqueId) XXX_Size() int

func (*UniqueId) XXX_Unmarshal 

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

type UpstreamSegment 

type UpstreamSegment struct {
	GlobalTraceIds       []*UniqueId `protobuf:"bytes,1,rep,name=globalTraceIds,proto3" json:"globalTraceIds,omitempty"`
	Segment              []byte      `protobuf:"bytes,2,opt,name=segment,proto3" json:"segment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*UpstreamSegment) Descriptor 

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

func (*UpstreamSegment) GetGlobalTraceIds 

func (m *UpstreamSegment) GetGlobalTraceIds() []*UniqueId

func (*UpstreamSegment) GetSegment 

func (m *UpstreamSegment) GetSegment() []byte

func (*UpstreamSegment) ProtoMessage 

func (*UpstreamSegment) ProtoMessage()

func (*UpstreamSegment) Reset 

func (m *UpstreamSegment) Reset()

func (*UpstreamSegment) String 

func (m *UpstreamSegment) String() string

func (*UpstreamSegment) XXX_DiscardUnknown 

func (m *UpstreamSegment) XXX_DiscardUnknown()

func (*UpstreamSegment) XXX_Marshal 

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

func (*UpstreamSegment) XXX_Merge 

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

func (*UpstreamSegment) XXX_Size 

func (m *UpstreamSegment) XXX_Size() int

func (*UpstreamSegment) XXX_Unmarshal 

func (m *UpstreamSegment) 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.