Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + var Product_name = map[int32]string + var Product_value = map[string]int32 + var TagCardinality_name = map[int32]string + var TagCardinality_value = map[string]int32 + func RegisterAgentHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterAgentHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentClient) error + func RegisterAgentHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterAgentHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentServer) error + func RegisterAgentSecureHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterAgentSecureHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentSecureClient) error + func RegisterAgentSecureHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterAgentSecureHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentSecureServer) error + func RegisterAgentSecureServer(s *grpc.Server, srv AgentSecureServer) + func RegisterAgentServer(s *grpc.Server, srv AgentServer) + type AgentClient interface + GetHostname func(ctx context.Context, in *HostnameRequest, opts ...grpc.CallOption) (*HostnameReply, error) + func NewAgentClient(cc *grpc.ClientConn) AgentClient + type AgentSecureClient interface + DogstatsdCaptureTrigger func(ctx context.Context, in *CaptureTriggerRequest, opts ...grpc.CallOption) (*CaptureTriggerResponse, error) + DogstatsdSetTaggerState func(ctx context.Context, in *TaggerState, opts ...grpc.CallOption) (*TaggerStateResponse, error) + GetConfigUpdates func(ctx context.Context, in *SubscribeConfigRequest, opts ...grpc.CallOption) (AgentSecure_GetConfigUpdatesClient, error) + GetConfigs func(ctx context.Context, in *GetConfigsRequest, opts ...grpc.CallOption) (*GetConfigsResponse, error) + TaggerFetchEntity func(ctx context.Context, in *FetchEntityRequest, opts ...grpc.CallOption) (*FetchEntityResponse, error) + TaggerStreamEntities func(ctx context.Context, in *StreamTagsRequest, opts ...grpc.CallOption) (AgentSecure_TaggerStreamEntitiesClient, error) + func NewAgentSecureClient(cc *grpc.ClientConn) AgentSecureClient + type AgentSecureServer interface + DogstatsdCaptureTrigger func(context.Context, *CaptureTriggerRequest) (*CaptureTriggerResponse, error) + DogstatsdSetTaggerState func(context.Context, *TaggerState) (*TaggerStateResponse, error) + GetConfigUpdates func(*SubscribeConfigRequest, AgentSecure_GetConfigUpdatesServer) error + GetConfigs func(context.Context, *GetConfigsRequest) (*GetConfigsResponse, error) + TaggerFetchEntity func(context.Context, *FetchEntityRequest) (*FetchEntityResponse, error) + TaggerStreamEntities func(*StreamTagsRequest, AgentSecure_TaggerStreamEntitiesServer) error + type AgentSecure_GetConfigUpdatesClient interface + Recv func() (*ConfigResponse, error) + type AgentSecure_GetConfigUpdatesServer interface + Send func(*ConfigResponse) error + type AgentSecure_TaggerStreamEntitiesClient interface + Recv func() (*StreamTagsResponse, error) + type AgentSecure_TaggerStreamEntitiesServer interface + Send func(*StreamTagsResponse) error + type AgentServer interface + GetHostname func(context.Context, *HostnameRequest) (*HostnameReply, error) + type CaptureTriggerRequest struct + Compressed bool + Duration string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CaptureTriggerRequest) Descriptor() ([]byte, []int) + func (*CaptureTriggerRequest) ProtoMessage() + func (m *CaptureTriggerRequest) GetCompressed() bool + func (m *CaptureTriggerRequest) GetDuration() string + func (m *CaptureTriggerRequest) GetPath() string + func (m *CaptureTriggerRequest) Reset() + func (m *CaptureTriggerRequest) String() string + func (m *CaptureTriggerRequest) XXX_DiscardUnknown() + func (m *CaptureTriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CaptureTriggerRequest) XXX_Merge(src proto.Message) + func (m *CaptureTriggerRequest) XXX_Size() int + func (m *CaptureTriggerRequest) XXX_Unmarshal(b []byte) error + type CaptureTriggerResponse struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CaptureTriggerResponse) Descriptor() ([]byte, []int) + func (*CaptureTriggerResponse) ProtoMessage() + func (m *CaptureTriggerResponse) GetPath() string + func (m *CaptureTriggerResponse) Reset() + func (m *CaptureTriggerResponse) String() string + func (m *CaptureTriggerResponse) XXX_DiscardUnknown() + func (m *CaptureTriggerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CaptureTriggerResponse) XXX_Merge(src proto.Message) + func (m *CaptureTriggerResponse) XXX_Size() int + func (m *CaptureTriggerResponse) XXX_Unmarshal(b []byte) error + type ClientLatestConfigsRequest struct + AgentVersion string + CurrentConfigRootVersion uint64 + CurrentConfigSnapshotVersion uint64 + CurrentDirectorRootVersion uint64 + Hostname string + NewProducts []Product + Products []Product + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientLatestConfigsRequest) Descriptor() ([]byte, []int) + func (*ClientLatestConfigsRequest) ProtoMessage() + func (m *ClientLatestConfigsRequest) GetAgentVersion() string + func (m *ClientLatestConfigsRequest) GetCurrentConfigRootVersion() uint64 + func (m *ClientLatestConfigsRequest) GetCurrentConfigSnapshotVersion() uint64 + func (m *ClientLatestConfigsRequest) GetCurrentDirectorRootVersion() uint64 + func (m *ClientLatestConfigsRequest) GetHostname() string + func (m *ClientLatestConfigsRequest) GetNewProducts() []Product + func (m *ClientLatestConfigsRequest) GetProducts() []Product + func (m *ClientLatestConfigsRequest) Reset() + func (m *ClientLatestConfigsRequest) String() string + func (m *ClientLatestConfigsRequest) XXX_DiscardUnknown() + func (m *ClientLatestConfigsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientLatestConfigsRequest) XXX_Merge(src proto.Message) + func (m *ClientLatestConfigsRequest) XXX_Size() int + func (m *ClientLatestConfigsRequest) XXX_Unmarshal(b []byte) error + func (z *ClientLatestConfigsRequest) DecodeMsg(dc *msgp.Reader) (err error) + func (z *ClientLatestConfigsRequest) EncodeMsg(en *msgp.Writer) (err error) + func (z *ClientLatestConfigsRequest) MarshalMsg(b []byte) (o []byte, err error) + func (z *ClientLatestConfigsRequest) Msgsize() (s int) + func (z *ClientLatestConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error) + type ConfigMetas struct + DelegatedTargets []*DelegatedMeta + Roots []*TopMeta + Snapshot *TopMeta + Timestamp *TopMeta + TopTargets *TopMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfigMetas) Descriptor() ([]byte, []int) + func (*ConfigMetas) ProtoMessage() + func (m *ConfigMetas) GetDelegatedTargets() []*DelegatedMeta + func (m *ConfigMetas) GetRoots() []*TopMeta + func (m *ConfigMetas) GetSnapshot() *TopMeta + func (m *ConfigMetas) GetTimestamp() *TopMeta + func (m *ConfigMetas) GetTopTargets() *TopMeta + func (m *ConfigMetas) Reset() + func (m *ConfigMetas) String() string + func (m *ConfigMetas) XXX_DiscardUnknown() + func (m *ConfigMetas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfigMetas) XXX_Merge(src proto.Message) + func (m *ConfigMetas) XXX_Size() int + func (m *ConfigMetas) XXX_Unmarshal(b []byte) error + func (z *ConfigMetas) DecodeMsg(dc *msgp.Reader) (err error) + func (z *ConfigMetas) EncodeMsg(en *msgp.Writer) (err error) + func (z *ConfigMetas) MarshalMsg(b []byte) (o []byte, err error) + func (z *ConfigMetas) Msgsize() (s int) + func (z *ConfigMetas) UnmarshalMsg(bts []byte) (o []byte, err error) + type ConfigResponse struct + ConfigDelegatedTargetVersion uint64 + ConfigSnapshotVersion uint64 + DirectoryRoots []*TopMeta + DirectoryTargets *TopMeta + TargetFiles []*File + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfigResponse) Descriptor() ([]byte, []int) + func (*ConfigResponse) ProtoMessage() + func (m *ConfigResponse) GetConfigDelegatedTargetVersion() uint64 + func (m *ConfigResponse) GetConfigSnapshotVersion() uint64 + func (m *ConfigResponse) GetDirectoryRoots() []*TopMeta + func (m *ConfigResponse) GetDirectoryTargets() *TopMeta + func (m *ConfigResponse) GetTargetFiles() []*File + func (m *ConfigResponse) Reset() + func (m *ConfigResponse) String() string + func (m *ConfigResponse) XXX_DiscardUnknown() + func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfigResponse) XXX_Merge(src proto.Message) + func (m *ConfigResponse) XXX_Size() int + func (m *ConfigResponse) XXX_Unmarshal(b []byte) error + func (z *ConfigResponse) DecodeMsg(dc *msgp.Reader) (err error) + func (z *ConfigResponse) EncodeMsg(en *msgp.Writer) (err error) + func (z *ConfigResponse) MarshalMsg(b []byte) (o []byte, err error) + func (z *ConfigResponse) Msgsize() (s int) + func (z *ConfigResponse) UnmarshalMsg(bts []byte) (o []byte, err error) + type DelegatedMeta struct + Raw []byte + Role string + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DelegatedMeta) Descriptor() ([]byte, []int) + func (*DelegatedMeta) ProtoMessage() + func (m *DelegatedMeta) GetRaw() []byte + func (m *DelegatedMeta) GetRole() string + func (m *DelegatedMeta) GetVersion() uint64 + func (m *DelegatedMeta) Reset() + func (m *DelegatedMeta) String() string + func (m *DelegatedMeta) XXX_DiscardUnknown() + func (m *DelegatedMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DelegatedMeta) XXX_Merge(src proto.Message) + func (m *DelegatedMeta) XXX_Size() int + func (m *DelegatedMeta) XXX_Unmarshal(b []byte) error + func (z *DelegatedMeta) DecodeMsg(dc *msgp.Reader) (err error) + func (z *DelegatedMeta) EncodeMsg(en *msgp.Writer) (err error) + func (z *DelegatedMeta) MarshalMsg(b []byte) (o []byte, err error) + func (z *DelegatedMeta) Msgsize() (s int) + func (z *DelegatedMeta) UnmarshalMsg(bts []byte) (o []byte, err error) + type DirectorMetas struct + Roots []*TopMeta + Snapshot *TopMeta + Targets *TopMeta + Timestamp *TopMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DirectorMetas) Descriptor() ([]byte, []int) + func (*DirectorMetas) ProtoMessage() + func (m *DirectorMetas) GetRoots() []*TopMeta + func (m *DirectorMetas) GetSnapshot() *TopMeta + func (m *DirectorMetas) GetTargets() *TopMeta + func (m *DirectorMetas) GetTimestamp() *TopMeta + func (m *DirectorMetas) Reset() + func (m *DirectorMetas) String() string + func (m *DirectorMetas) XXX_DiscardUnknown() + func (m *DirectorMetas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DirectorMetas) XXX_Merge(src proto.Message) + func (m *DirectorMetas) XXX_Size() int + func (m *DirectorMetas) XXX_Unmarshal(b []byte) error + func (z *DirectorMetas) DecodeMsg(dc *msgp.Reader) (err error) + func (z *DirectorMetas) EncodeMsg(en *msgp.Writer) (err error) + func (z *DirectorMetas) MarshalMsg(b []byte) (o []byte, err error) + func (z *DirectorMetas) Msgsize() (s int) + func (z *DirectorMetas) UnmarshalMsg(bts []byte) (o []byte, err error) + type Entity struct + Hash string + HighCardinalityTags []string + Id *EntityId + LowCardinalityTags []string + OrchestratorCardinalityTags []string + StandardTags []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Entity) Descriptor() ([]byte, []int) + func (*Entity) ProtoMessage() + func (m *Entity) GetHash() string + func (m *Entity) GetHighCardinalityTags() []string + func (m *Entity) GetId() *EntityId + func (m *Entity) GetLowCardinalityTags() []string + func (m *Entity) GetOrchestratorCardinalityTags() []string + func (m *Entity) GetStandardTags() []string + func (m *Entity) Reset() + func (m *Entity) String() string + func (m *Entity) XXX_DiscardUnknown() + func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Entity) XXX_Merge(src proto.Message) + func (m *Entity) XXX_Size() int + func (m *Entity) XXX_Unmarshal(b []byte) error + type EntityId struct + Prefix string + Uid string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EntityId) Descriptor() ([]byte, []int) + func (*EntityId) ProtoMessage() + func (m *EntityId) GetPrefix() string + func (m *EntityId) GetUid() string + func (m *EntityId) Reset() + func (m *EntityId) String() string + func (m *EntityId) XXX_DiscardUnknown() + func (m *EntityId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EntityId) XXX_Merge(src proto.Message) + func (m *EntityId) XXX_Size() int + func (m *EntityId) XXX_Unmarshal(b []byte) error + type EventType int32 + const EventType_ADDED + const EventType_DELETED + const EventType_MODIFIED + func (EventType) EnumDescriptor() ([]byte, []int) + func (x EventType) String() string + type FetchEntityRequest struct + Cardinality TagCardinality + Id *EntityId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchEntityRequest) Descriptor() ([]byte, []int) + func (*FetchEntityRequest) ProtoMessage() + func (m *FetchEntityRequest) GetCardinality() TagCardinality + func (m *FetchEntityRequest) GetId() *EntityId + func (m *FetchEntityRequest) Reset() + func (m *FetchEntityRequest) String() string + func (m *FetchEntityRequest) XXX_DiscardUnknown() + func (m *FetchEntityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchEntityRequest) XXX_Merge(src proto.Message) + func (m *FetchEntityRequest) XXX_Size() int + func (m *FetchEntityRequest) XXX_Unmarshal(b []byte) error + type FetchEntityResponse struct + Cardinality TagCardinality + Id *EntityId + Tags []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchEntityResponse) Descriptor() ([]byte, []int) + func (*FetchEntityResponse) ProtoMessage() + func (m *FetchEntityResponse) GetCardinality() TagCardinality + func (m *FetchEntityResponse) GetId() *EntityId + func (m *FetchEntityResponse) GetTags() []string + func (m *FetchEntityResponse) Reset() + func (m *FetchEntityResponse) String() string + func (m *FetchEntityResponse) XXX_DiscardUnknown() + func (m *FetchEntityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchEntityResponse) XXX_Merge(src proto.Message) + func (m *FetchEntityResponse) XXX_Size() int + func (m *FetchEntityResponse) XXX_Unmarshal(b []byte) error + type File struct + Path string + Raw []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*File) Descriptor() ([]byte, []int) + func (*File) ProtoMessage() + func (m *File) GetPath() string + func (m *File) GetRaw() []byte + func (m *File) Reset() + func (m *File) String() string + func (m *File) XXX_DiscardUnknown() + func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *File) XXX_Merge(src proto.Message) + func (m *File) XXX_Size() int + func (m *File) XXX_Unmarshal(b []byte) error + func (z *File) DecodeMsg(dc *msgp.Reader) (err error) + func (z *File) EncodeMsg(en *msgp.Writer) (err error) + func (z *File) MarshalMsg(b []byte) (o []byte, err error) + func (z *File) Msgsize() (s int) + func (z *File) UnmarshalMsg(bts []byte) (o []byte, err error) + type Filter struct + ContainerName string + Image string + KubeNamespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (m *Filter) GetContainerName() string + func (m *Filter) GetImage() string + func (m *Filter) GetKubeNamespace() string + func (m *Filter) Reset() + func (m *Filter) String() string + func (m *Filter) XXX_DiscardUnknown() + func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Filter) XXX_Merge(src proto.Message) + func (m *Filter) XXX_Size() int + func (m *Filter) XXX_Unmarshal(b []byte) error + type GetConfigsRequest struct + CurrentConfigProductVersion uint64 + CurrentDirectorRootVersion uint64 + Product Product + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetConfigsRequest) Descriptor() ([]byte, []int) + func (*GetConfigsRequest) ProtoMessage() + func (m *GetConfigsRequest) GetCurrentConfigProductVersion() uint64 + func (m *GetConfigsRequest) GetCurrentDirectorRootVersion() uint64 + func (m *GetConfigsRequest) GetProduct() Product + func (m *GetConfigsRequest) Reset() + func (m *GetConfigsRequest) String() string + func (m *GetConfigsRequest) XXX_DiscardUnknown() + func (m *GetConfigsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetConfigsRequest) XXX_Merge(src proto.Message) + func (m *GetConfigsRequest) XXX_Size() int + func (m *GetConfigsRequest) XXX_Unmarshal(b []byte) error + func (z *GetConfigsRequest) DecodeMsg(dc *msgp.Reader) (err error) + func (z *GetConfigsRequest) EncodeMsg(en *msgp.Writer) (err error) + func (z *GetConfigsRequest) MarshalMsg(b []byte) (o []byte, err error) + func (z *GetConfigsRequest) Msgsize() (s int) + func (z *GetConfigsRequest) UnmarshalMsg(bts []byte) (o []byte, err error) + type GetConfigsResponse struct + ConfigResponses []*ConfigResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetConfigsResponse) Descriptor() ([]byte, []int) + func (*GetConfigsResponse) ProtoMessage() + func (m *GetConfigsResponse) GetConfigResponses() []*ConfigResponse + func (m *GetConfigsResponse) Reset() + func (m *GetConfigsResponse) String() string + func (m *GetConfigsResponse) XXX_DiscardUnknown() + func (m *GetConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetConfigsResponse) XXX_Merge(src proto.Message) + func (m *GetConfigsResponse) XXX_Size() int + func (m *GetConfigsResponse) XXX_Unmarshal(b []byte) error + func (z *GetConfigsResponse) DecodeMsg(dc *msgp.Reader) (err error) + func (z *GetConfigsResponse) EncodeMsg(en *msgp.Writer) (err error) + func (z *GetConfigsResponse) MarshalMsg(b []byte) (o []byte, err error) + func (z *GetConfigsResponse) Msgsize() (s int) + func (z *GetConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error) + type HostnameReply struct + Hostname string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HostnameReply) Descriptor() ([]byte, []int) + func (*HostnameReply) ProtoMessage() + func (m *HostnameReply) GetHostname() string + func (m *HostnameReply) Reset() + func (m *HostnameReply) String() string + func (m *HostnameReply) XXX_DiscardUnknown() + func (m *HostnameReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HostnameReply) XXX_Merge(src proto.Message) + func (m *HostnameReply) XXX_Size() int + func (m *HostnameReply) XXX_Unmarshal(b []byte) error + type HostnameRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HostnameRequest) Descriptor() ([]byte, []int) + func (*HostnameRequest) ProtoMessage() + func (m *HostnameRequest) Reset() + func (m *HostnameRequest) String() string + func (m *HostnameRequest) XXX_DiscardUnknown() + func (m *HostnameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HostnameRequest) XXX_Merge(src proto.Message) + func (m *HostnameRequest) XXX_Size() int + func (m *HostnameRequest) XXX_Unmarshal(b []byte) error + type LatestConfigsResponse struct + ConfigMetas *ConfigMetas + DirectorMetas *DirectorMetas + TargetFiles []*File + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LatestConfigsResponse) Descriptor() ([]byte, []int) + func (*LatestConfigsResponse) ProtoMessage() + func (m *LatestConfigsResponse) GetConfigMetas() *ConfigMetas + func (m *LatestConfigsResponse) GetDirectorMetas() *DirectorMetas + func (m *LatestConfigsResponse) GetTargetFiles() []*File + func (m *LatestConfigsResponse) Reset() + func (m *LatestConfigsResponse) String() string + func (m *LatestConfigsResponse) XXX_DiscardUnknown() + func (m *LatestConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LatestConfigsResponse) XXX_Merge(src proto.Message) + func (m *LatestConfigsResponse) XXX_Size() int + func (m *LatestConfigsResponse) XXX_Unmarshal(b []byte) error + func (z *LatestConfigsResponse) DecodeMsg(dc *msgp.Reader) (err error) + func (z *LatestConfigsResponse) EncodeMsg(en *msgp.Writer) (err error) + func (z *LatestConfigsResponse) MarshalMsg(b []byte) (o []byte, err error) + func (z *LatestConfigsResponse) Msgsize() (s int) + func (z *LatestConfigsResponse) UnmarshalMsg(bts []byte) (o []byte, err error) + type ProcessStatRequest struct + Pids []int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ProcessStatRequest) Descriptor() ([]byte, []int) + func (*ProcessStatRequest) ProtoMessage() + func (m *ProcessStatRequest) GetPids() []int32 + func (m *ProcessStatRequest) Reset() + func (m *ProcessStatRequest) String() string + func (m *ProcessStatRequest) XXX_DiscardUnknown() + func (m *ProcessStatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProcessStatRequest) XXX_Merge(src proto.Message) + func (m *ProcessStatRequest) XXX_Size() int + func (m *ProcessStatRequest) XXX_Unmarshal(b []byte) error + type Product int32 + const Product_APM_SAMPLING + const Product_APPSEC + const Product_LIVE_DEBUGGING + const Product_NO_PRODUCT + const Product_RUNTIME_SECURITY + const Product_TESTING1 + const Product_TESTING2 + func (Product) EnumDescriptor() ([]byte, []int) + func (x Product) String() string + func (z *Product) DecodeMsg(dc *msgp.Reader) (err error) + func (z *Product) UnmarshalMsg(bts []byte) (o []byte, err error) + func (z Product) EncodeMsg(en *msgp.Writer) (err error) + func (z Product) MarshalMsg(b []byte) (o []byte, err error) + func (z Product) Msgsize() (s int) + type StreamTagsEvent struct + Entity *Entity + Type EventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTagsEvent) Descriptor() ([]byte, []int) + func (*StreamTagsEvent) ProtoMessage() + func (m *StreamTagsEvent) GetEntity() *Entity + func (m *StreamTagsEvent) GetType() EventType + func (m *StreamTagsEvent) Reset() + func (m *StreamTagsEvent) String() string + func (m *StreamTagsEvent) XXX_DiscardUnknown() + func (m *StreamTagsEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTagsEvent) XXX_Merge(src proto.Message) + func (m *StreamTagsEvent) XXX_Size() int + func (m *StreamTagsEvent) XXX_Unmarshal(b []byte) error + type StreamTagsRequest struct + Cardinality TagCardinality + ExcludeFilter *Filter + IncludeFilter *Filter + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTagsRequest) Descriptor() ([]byte, []int) + func (*StreamTagsRequest) ProtoMessage() + func (m *StreamTagsRequest) GetCardinality() TagCardinality + func (m *StreamTagsRequest) GetExcludeFilter() *Filter + func (m *StreamTagsRequest) GetIncludeFilter() *Filter + func (m *StreamTagsRequest) Reset() + func (m *StreamTagsRequest) String() string + func (m *StreamTagsRequest) XXX_DiscardUnknown() + func (m *StreamTagsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTagsRequest) XXX_Merge(src proto.Message) + func (m *StreamTagsRequest) XXX_Size() int + func (m *StreamTagsRequest) XXX_Unmarshal(b []byte) error + type StreamTagsResponse struct + Events []*StreamTagsEvent + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTagsResponse) Descriptor() ([]byte, []int) + func (*StreamTagsResponse) ProtoMessage() + func (m *StreamTagsResponse) GetEvents() []*StreamTagsEvent + func (m *StreamTagsResponse) Reset() + func (m *StreamTagsResponse) String() string + func (m *StreamTagsResponse) XXX_DiscardUnknown() + func (m *StreamTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTagsResponse) XXX_Merge(src proto.Message) + func (m *StreamTagsResponse) XXX_Size() int + func (m *StreamTagsResponse) XXX_Unmarshal(b []byte) error + type SubscribeConfigRequest struct + CurrentConfigSnapshotVersion uint64 + Product Product + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeConfigRequest) Descriptor() ([]byte, []int) + func (*SubscribeConfigRequest) ProtoMessage() + func (m *SubscribeConfigRequest) GetCurrentConfigSnapshotVersion() uint64 + func (m *SubscribeConfigRequest) GetProduct() Product + func (m *SubscribeConfigRequest) Reset() + func (m *SubscribeConfigRequest) String() string + func (m *SubscribeConfigRequest) XXX_DiscardUnknown() + func (m *SubscribeConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeConfigRequest) XXX_Merge(src proto.Message) + func (m *SubscribeConfigRequest) XXX_Size() int + func (m *SubscribeConfigRequest) XXX_Unmarshal(b []byte) error + func (z *SubscribeConfigRequest) DecodeMsg(dc *msgp.Reader) (err error) + func (z *SubscribeConfigRequest) EncodeMsg(en *msgp.Writer) (err error) + func (z *SubscribeConfigRequest) MarshalMsg(b []byte) (o []byte, err error) + func (z *SubscribeConfigRequest) Msgsize() (s int) + func (z *SubscribeConfigRequest) UnmarshalMsg(bts []byte) (o []byte, err error) + type TagCardinality int32 + const TagCardinality_HIGH + const TagCardinality_LOW + const TagCardinality_ORCHESTRATOR + func (TagCardinality) EnumDescriptor() ([]byte, []int) + func (x TagCardinality) String() string + type TaggerState struct + PidMap map[int32]string + State map[string]*Entity + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaggerState) Descriptor() ([]byte, []int) + func (*TaggerState) ProtoMessage() + func (m *TaggerState) GetPidMap() map[int32]string + func (m *TaggerState) GetState() map[string]*Entity + func (m *TaggerState) Reset() + func (m *TaggerState) String() string + func (m *TaggerState) XXX_DiscardUnknown() + func (m *TaggerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaggerState) XXX_Merge(src proto.Message) + func (m *TaggerState) XXX_Size() int + func (m *TaggerState) XXX_Unmarshal(b []byte) error + type TaggerStateResponse struct + Loaded bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaggerStateResponse) Descriptor() ([]byte, []int) + func (*TaggerStateResponse) ProtoMessage() + func (m *TaggerStateResponse) GetLoaded() bool + func (m *TaggerStateResponse) Reset() + func (m *TaggerStateResponse) String() string + func (m *TaggerStateResponse) XXX_DiscardUnknown() + func (m *TaggerStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaggerStateResponse) XXX_Merge(src proto.Message) + func (m *TaggerStateResponse) XXX_Size() int + func (m *TaggerStateResponse) XXX_Unmarshal(b []byte) error + type TopMeta struct + Raw []byte + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TopMeta) Descriptor() ([]byte, []int) + func (*TopMeta) ProtoMessage() + func (m *TopMeta) GetRaw() []byte + func (m *TopMeta) GetVersion() uint64 + func (m *TopMeta) Reset() + func (m *TopMeta) String() string + func (m *TopMeta) XXX_DiscardUnknown() + func (m *TopMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TopMeta) XXX_Merge(src proto.Message) + func (m *TopMeta) XXX_Size() int + func (m *TopMeta) XXX_Unmarshal(b []byte) error + func (z *TopMeta) DecodeMsg(dc *msgp.Reader) (err error) + func (z *TopMeta) EncodeMsg(en *msgp.Writer) (err error) + func (z *TopMeta) MarshalMsg(b []byte) (o []byte, err error) + func (z *TopMeta) Msgsize() (s int) + func (z *TopMeta) UnmarshalMsg(bts []byte) (o []byte, err error) + type UnimplementedAgentSecureServer struct + func (*UnimplementedAgentSecureServer) DogstatsdCaptureTrigger(ctx context.Context, req *CaptureTriggerRequest) (*CaptureTriggerResponse, error) + func (*UnimplementedAgentSecureServer) DogstatsdSetTaggerState(ctx context.Context, req *TaggerState) (*TaggerStateResponse, error) + func (*UnimplementedAgentSecureServer) GetConfigUpdates(req *SubscribeConfigRequest, srv AgentSecure_GetConfigUpdatesServer) error + func (*UnimplementedAgentSecureServer) GetConfigs(ctx context.Context, req *GetConfigsRequest) (*GetConfigsResponse, error) + func (*UnimplementedAgentSecureServer) TaggerFetchEntity(ctx context.Context, req *FetchEntityRequest) (*FetchEntityResponse, error) + func (*UnimplementedAgentSecureServer) TaggerStreamEntities(req *StreamTagsRequest, srv AgentSecure_TaggerStreamEntitiesServer) error + type UnimplementedAgentServer struct + func (*UnimplementedAgentServer) GetHostname(ctx context.Context, req *HostnameRequest) (*HostnameReply, error) + type UnixDogstatsdMsg struct + Ancillary []byte + AncillarySize int32 + Payload []byte + PayloadSize int32 + Pid int32 + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnixDogstatsdMsg) Descriptor() ([]byte, []int) + func (*UnixDogstatsdMsg) ProtoMessage() + func (m *UnixDogstatsdMsg) GetAncillary() []byte + func (m *UnixDogstatsdMsg) GetAncillarySize() int32 + func (m *UnixDogstatsdMsg) GetPayload() []byte + func (m *UnixDogstatsdMsg) GetPayloadSize() int32 + func (m *UnixDogstatsdMsg) GetPid() int32 + func (m *UnixDogstatsdMsg) GetTimestamp() int64 + func (m *UnixDogstatsdMsg) Reset() + func (m *UnixDogstatsdMsg) String() string + func (m *UnixDogstatsdMsg) XXX_DiscardUnknown() + func (m *UnixDogstatsdMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UnixDogstatsdMsg) XXX_Merge(src proto.Message) + func (m *UnixDogstatsdMsg) XXX_Size() int + func (m *UnixDogstatsdMsg) XXX_Unmarshal(b []byte) error Other modules containing this package github.com/DataDog/datadog-agent/pkg/proto
Go to main page