collector

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EncodingType_name = map[int32]string{
	0: "BSON",
	1: "PROTOBUF",
}
View Source 
var EncodingType_value = map[string]int32{
	"BSON":     0,
	"PROTOBUF": 1,
}
View Source 
var HostType_name = map[int32]string{
	0: "PERSISTENT",
	1: "AWS_LAMBDA",
}
View Source 
var HostType_value = map[string]int32{
	"PERSISTENT": 0,
	"AWS_LAMBDA": 1,
}
View Source 
var OboeSettingType_name = map[int32]string{
	0: "DEFAULT_SAMPLE_RATE",
	1: "LAYER_SAMPLE_RATE",
	2: "LAYER_APP_SAMPLE_RATE",
	3: "LAYER_HTTPHOST_SAMPLE_RATE",
	4: "CONFIG_STRING",
	5: "CONFIG_INT",
}
View Source 
var OboeSettingType_value = map[string]int32{
	"DEFAULT_SAMPLE_RATE":        0,
	"LAYER_SAMPLE_RATE":          1,
	"LAYER_APP_SAMPLE_RATE":      2,
	"LAYER_HTTPHOST_SAMPLE_RATE": 3,
	"CONFIG_STRING":              4,
	"CONFIG_INT":                 5,
}
View Source 
var ResultCode_name = map[int32]string{
	0: "OK",
	1: "TRY_LATER",
	2: "INVALID_API_KEY",
	3: "LIMIT_EXCEEDED",
	4: "REDIRECT",
}
View Source 
var ResultCode_value = map[string]int32{
	"OK":              0,
	"TRY_LATER":       1,
	"INVALID_API_KEY": 2,
	"LIMIT_EXCEEDED":  3,
	"REDIRECT":        4,
}

Functions

func RegisterTraceCollectorServer 

func RegisterTraceCollectorServer(s *grpc.Server, srv TraceCollectorServer)

Types

type EncodingType 

type EncodingType int32
const (
	EncodingType_BSON     EncodingType = 0
	EncodingType_PROTOBUF EncodingType = 1
)

func (EncodingType) EnumDescriptor 

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

func (EncodingType) String 

func (x EncodingType) String() string

type HostID 

type HostID struct {
	Hostname               string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	IpAddresses            []string `protobuf:"bytes,2,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
	Uuid                   string   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Pid                    int32    `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	Ec2InstanceID          string   `protobuf:"bytes,5,opt,name=ec2InstanceID,proto3" json:"ec2InstanceID,omitempty"`
	Ec2AvailabilityZone    string   `protobuf:"bytes,6,opt,name=ec2AvailabilityZone,proto3" json:"ec2AvailabilityZone,omitempty"`
	DockerContainerID      string   `protobuf:"bytes,7,opt,name=dockerContainerID,proto3" json:"dockerContainerID,omitempty"`
	MacAddresses           []string `protobuf:"bytes,8,rep,name=macAddresses,proto3" json:"macAddresses,omitempty"`
	HerokuDynoID           string   `protobuf:"bytes,9,opt,name=herokuDynoID,proto3" json:"herokuDynoID,omitempty"`
	AzAppServiceInstanceID string   `protobuf:"bytes,10,opt,name=azAppServiceInstanceID,proto3" json:"azAppServiceInstanceID,omitempty"`
	HostType               HostType `protobuf:"varint,11,opt,name=hostType,proto3,enum=collectorpb.HostType" json:"hostType,omitempty"`
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*HostID) Descriptor 

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

func (*HostID) GetAzAppServiceInstanceID 

func (m *HostID) GetAzAppServiceInstanceID() string

func (*HostID) GetDockerContainerID 

func (m *HostID) GetDockerContainerID() string

func (*HostID) GetEc2AvailabilityZone 

func (m *HostID) GetEc2AvailabilityZone() string

func (*HostID) GetEc2InstanceID 

func (m *HostID) GetEc2InstanceID() string

func (*HostID) GetHerokuDynoID 

func (m *HostID) GetHerokuDynoID() string

func (*HostID) GetHostType 

func (m *HostID) GetHostType() HostType

func (*HostID) GetHostname 

func (m *HostID) GetHostname() string

func (*HostID) GetIpAddresses 

func (m *HostID) GetIpAddresses() []string

func (*HostID) GetMacAddresses 

func (m *HostID) GetMacAddresses() []string

func (*HostID) GetPid 

func (m *HostID) GetPid() int32

func (*HostID) GetUuid 

func (m *HostID) GetUuid() string

func (*HostID) ProtoMessage 

func (*HostID) ProtoMessage()

func (*HostID) Reset 

func (m *HostID) Reset()

func (*HostID) String 

func (m *HostID) String() string

func (*HostID) XXX_DiscardUnknown 

func (m *HostID) XXX_DiscardUnknown()

func (*HostID) XXX_Marshal 

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

func (*HostID) XXX_Merge 

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

func (*HostID) XXX_Size 

func (m *HostID) XXX_Size() int

func (*HostID) XXX_Unmarshal 

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

type HostType 

type HostType int32
const (
	HostType_PERSISTENT HostType = 0
	HostType_AWS_LAMBDA HostType = 1
)

func (HostType) EnumDescriptor 

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

func (HostType) String 

func (x HostType) String() string

type MessageRequest 

type MessageRequest struct {
	ApiKey               string       `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	Messages             [][]byte     `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	Encoding             EncodingType `protobuf:"varint,3,opt,name=encoding,proto3,enum=collectorpb.EncodingType" json:"encoding,omitempty"`
	Identity             *HostID      `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MessageRequest) Descriptor 

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

func (*MessageRequest) GetApiKey 

func (m *MessageRequest) GetApiKey() string

func (*MessageRequest) GetEncoding 

func (m *MessageRequest) GetEncoding() EncodingType

func (*MessageRequest) GetIdentity 

func (m *MessageRequest) GetIdentity() *HostID

func (*MessageRequest) GetMessages 

func (m *MessageRequest) GetMessages() [][]byte

func (*MessageRequest) ProtoMessage 

func (*MessageRequest) ProtoMessage()

func (*MessageRequest) Reset 

func (m *MessageRequest) Reset()

func (*MessageRequest) String 

func (m *MessageRequest) String() string

func (*MessageRequest) XXX_DiscardUnknown 

func (m *MessageRequest) XXX_DiscardUnknown()

func (*MessageRequest) XXX_Marshal 

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

func (*MessageRequest) XXX_Merge 

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

func (*MessageRequest) XXX_Size 

func (m *MessageRequest) XXX_Size() int

func (*MessageRequest) XXX_Unmarshal 

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

type MessageResult 

type MessageResult struct {
	Result ResultCode `protobuf:"varint,1,opt,name=result,proto3,enum=collectorpb.ResultCode" json:"result,omitempty"`
	Arg    string     `protobuf:"bytes,2,opt,name=arg,proto3" json:"arg,omitempty"`
	// warning specifies a user-facing warning message; agents attempt to squelch repeated warnings,
	// so care should be taken to ensure that warning messages are consistent across all RPCs.
	Warning              string   `protobuf:"bytes,4,opt,name=warning,proto3" json:"warning,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageResult) Descriptor 

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

func (*MessageResult) GetArg 

func (m *MessageResult) GetArg() string

func (*MessageResult) GetResult 

func (m *MessageResult) GetResult() ResultCode

func (*MessageResult) GetWarning 

func (m *MessageResult) GetWarning() string

func (*MessageResult) ProtoMessage 

func (*MessageResult) ProtoMessage()

func (*MessageResult) Reset 

func (m *MessageResult) Reset()

func (*MessageResult) String 

func (m *MessageResult) String() string

func (*MessageResult) XXX_DiscardUnknown 

func (m *MessageResult) XXX_DiscardUnknown()

func (*MessageResult) XXX_Marshal 

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

func (*MessageResult) XXX_Merge 

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

func (*MessageResult) XXX_Size 

func (m *MessageResult) XXX_Size() int

func (*MessageResult) XXX_Unmarshal 

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

type OboeSetting 

type OboeSetting struct {
	Type                 OboeSettingType   `protobuf:"varint,1,opt,name=type,proto3,enum=collectorpb.OboeSettingType" json:"type,omitempty"`
	Flags                []byte            `protobuf:"bytes,2,opt,name=flags,proto3" json:"flags,omitempty"`
	Timestamp            int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                int64             `protobuf:"varint,4,opt,name=value,proto3" json:"value,omitempty"`
	Layer                []byte            `protobuf:"bytes,5,opt,name=layer,proto3" json:"layer,omitempty"`
	Arguments            map[string][]byte `` /* 159-byte string literal not displayed */
	Ttl                  int64             `protobuf:"varint,8,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*OboeSetting) Descriptor 

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

func (*OboeSetting) GetArguments 

func (m *OboeSetting) GetArguments() map[string][]byte

func (*OboeSetting) GetFlags 

func (m *OboeSetting) GetFlags() []byte

func (*OboeSetting) GetLayer 

func (m *OboeSetting) GetLayer() []byte

func (*OboeSetting) GetTimestamp 

func (m *OboeSetting) GetTimestamp() int64

func (*OboeSetting) GetTtl 

func (m *OboeSetting) GetTtl() int64

func (*OboeSetting) GetType 

func (m *OboeSetting) GetType() OboeSettingType

func (*OboeSetting) GetValue 

func (m *OboeSetting) GetValue() int64

func (*OboeSetting) ProtoMessage 

func (*OboeSetting) ProtoMessage()

func (*OboeSetting) Reset 

func (m *OboeSetting) Reset()

func (*OboeSetting) String 

func (m *OboeSetting) String() string

func (*OboeSetting) XXX_DiscardUnknown 

func (m *OboeSetting) XXX_DiscardUnknown()

func (*OboeSetting) XXX_Marshal 

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

func (*OboeSetting) XXX_Merge 

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

func (*OboeSetting) XXX_Size 

func (m *OboeSetting) XXX_Size() int

func (*OboeSetting) XXX_Unmarshal 

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

type OboeSettingType 

type OboeSettingType int32
const (
	OboeSettingType_DEFAULT_SAMPLE_RATE        OboeSettingType = 0
	OboeSettingType_LAYER_SAMPLE_RATE          OboeSettingType = 1
	OboeSettingType_LAYER_APP_SAMPLE_RATE      OboeSettingType = 2
	OboeSettingType_LAYER_HTTPHOST_SAMPLE_RATE OboeSettingType = 3
	OboeSettingType_CONFIG_STRING              OboeSettingType = 4
	OboeSettingType_CONFIG_INT                 OboeSettingType = 5
)

func (OboeSettingType) EnumDescriptor 

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

func (OboeSettingType) String 

func (x OboeSettingType) String() string

type PingRequest 

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

func (*PingRequest) Descriptor 

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

func (*PingRequest) GetApiKey 

func (m *PingRequest) GetApiKey() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type ResultCode 

type ResultCode int32
const (
	ResultCode_OK              ResultCode = 0
	ResultCode_TRY_LATER       ResultCode = 1
	ResultCode_INVALID_API_KEY ResultCode = 2
	ResultCode_LIMIT_EXCEEDED  ResultCode = 3
	ResultCode_REDIRECT        ResultCode = 4
)

func (ResultCode) EnumDescriptor 

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

func (ResultCode) String 

func (x ResultCode) String() string

type SettingsRequest 

type SettingsRequest struct {
	ApiKey               string   `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	Identity             *HostID  `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	ClientVersion        string   `protobuf:"bytes,3,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SettingsRequest) Descriptor 

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

func (*SettingsRequest) GetApiKey 

func (m *SettingsRequest) GetApiKey() string

func (*SettingsRequest) GetClientVersion 

func (m *SettingsRequest) GetClientVersion() string

func (*SettingsRequest) GetIdentity 

func (m *SettingsRequest) GetIdentity() *HostID

func (*SettingsRequest) ProtoMessage 

func (*SettingsRequest) ProtoMessage()

func (*SettingsRequest) Reset 

func (m *SettingsRequest) Reset()

func (*SettingsRequest) String 

func (m *SettingsRequest) String() string

func (*SettingsRequest) XXX_DiscardUnknown 

func (m *SettingsRequest) XXX_DiscardUnknown()

func (*SettingsRequest) XXX_Marshal 

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

func (*SettingsRequest) XXX_Merge 

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

func (*SettingsRequest) XXX_Size 

func (m *SettingsRequest) XXX_Size() int

func (*SettingsRequest) XXX_Unmarshal 

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

type SettingsResult 

type SettingsResult struct {
	Result   ResultCode     `protobuf:"varint,1,opt,name=result,proto3,enum=collectorpb.ResultCode" json:"result,omitempty"`
	Arg      string         `protobuf:"bytes,2,opt,name=arg,proto3" json:"arg,omitempty"`
	Settings []*OboeSetting `protobuf:"bytes,3,rep,name=settings,proto3" json:"settings,omitempty"`
	// warning specifies a user-facing warning message; see note on MessageResult.warning for details.
	Warning              string   `protobuf:"bytes,4,opt,name=warning,proto3" json:"warning,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SettingsResult) Descriptor 

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

func (*SettingsResult) GetArg 

func (m *SettingsResult) GetArg() string

func (*SettingsResult) GetResult 

func (m *SettingsResult) GetResult() ResultCode

func (*SettingsResult) GetSettings 

func (m *SettingsResult) GetSettings() []*OboeSetting

func (*SettingsResult) GetWarning 

func (m *SettingsResult) GetWarning() string

func (*SettingsResult) ProtoMessage 

func (*SettingsResult) ProtoMessage()

func (*SettingsResult) Reset 

func (m *SettingsResult) Reset()

func (*SettingsResult) String 

func (m *SettingsResult) String() string

func (*SettingsResult) XXX_DiscardUnknown 

func (m *SettingsResult) XXX_DiscardUnknown()

func (*SettingsResult) XXX_Marshal 

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

func (*SettingsResult) XXX_Merge 

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

func (*SettingsResult) XXX_Size 

func (m *SettingsResult) XXX_Size() int

func (*SettingsResult) XXX_Unmarshal 

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

type TraceCollectorClient 

type TraceCollectorClient interface {
	PostEvents(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResult, error)
	PostMetrics(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResult, error)
	PostStatus(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResult, error)
	GetSettings(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResult, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*MessageResult, error)
}

TraceCollectorClient is the client API for TraceCollector service.

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

func NewTraceCollectorClient 

func NewTraceCollectorClient(cc *grpc.ClientConn) TraceCollectorClient

type TraceCollectorServer 

type TraceCollectorServer interface {
	PostEvents(context.Context, *MessageRequest) (*MessageResult, error)
	PostMetrics(context.Context, *MessageRequest) (*MessageResult, error)
	PostStatus(context.Context, *MessageRequest) (*MessageResult, error)
	GetSettings(context.Context, *SettingsRequest) (*SettingsResult, error)
	Ping(context.Context, *PingRequest) (*MessageResult, error)
}

TraceCollectorServer is the server API for TraceCollector service.

type UnimplementedTraceCollectorServer 

type UnimplementedTraceCollectorServer struct {
}

UnimplementedTraceCollectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedTraceCollectorServer) GetSettings 

func (*UnimplementedTraceCollectorServer) GetSettings(ctx context.Context, req *SettingsRequest) (*SettingsResult, error)

func (*UnimplementedTraceCollectorServer) Ping 

func (*UnimplementedTraceCollectorServer) Ping(ctx context.Context, req *PingRequest) (*MessageResult, error)

func (*UnimplementedTraceCollectorServer) PostEvents 

func (*UnimplementedTraceCollectorServer) PostEvents(ctx context.Context, req *MessageRequest) (*MessageResult, error)

func (*UnimplementedTraceCollectorServer) PostMetrics 

func (*UnimplementedTraceCollectorServer) PostMetrics(ctx context.Context, req *MessageRequest) (*MessageResult, error)

func (*UnimplementedTraceCollectorServer) PostStatus 

func (*UnimplementedTraceCollectorServer) PostStatus(ctx context.Context, req *MessageRequest) (*MessageResult, 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.