Documentation
¶
Index ¶
- Constants
- type AsyncProfilerService
- type Receiver
- func (r *Receiver) Channel() <-chan *v1.SniffData
- func (r *Receiver) DefaultConfig() string
- func (r *Receiver) Description() string
- func (r *Receiver) Name() string
- func (r *Receiver) RegisterHandler(server interface{})
- func (r *Receiver) RegisterSyncInvoker(invoker module.SyncInvoker)
- func (r *Receiver) ShowName() string
- func (r *Receiver) SupportForwarders() []forwarder.Forwarder
Constants ¶
View Source
const ( Name = "grpc-native-async-profiler-receiver" ShowName = "GRPC Native Async Profiler Receiver" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncProfilerService ¶
type AsyncProfilerService struct {
module.SyncInvoker
asyncprofiler.UnimplementedAsyncProfilerTaskServer
// contains filtered or unexported fields
}
func (*AsyncProfilerService) Collect ¶
func (p *AsyncProfilerService) Collect(clientStream asyncprofiler.AsyncProfilerTask_CollectServer) error
func (*AsyncProfilerService) GetAsyncProfilerTaskCommands ¶
func (p *AsyncProfilerService) GetAsyncProfilerTaskCommands(_ context.Context, query *asyncprofiler.AsyncProfilerTaskCommandQuery) (*common.Commands, error)
type Receiver ¶
type Receiver struct {
config.CommonFields
grpc.CommonGRPCReceiverFields
// contains filtered or unexported fields
}
func (*Receiver) DefaultConfig ¶
func (*Receiver) Description ¶
func (*Receiver) RegisterHandler ¶
func (r *Receiver) RegisterHandler(server interface{})
func (*Receiver) RegisterSyncInvoker ¶
func (r *Receiver) RegisterSyncInvoker(invoker module.SyncInvoker)
func (*Receiver) SupportForwarders ¶
Source Files
Click to show internal directories.
Click to hide internal directories.