agent

package

v0.0.0-...-52b0792 Latest Latest Go to latest Published: Feb 21, 2024 License: Apache-2.0 Imports: 9 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/storj/monkit-jaeger

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Agent
type AgentClient
type AgentEmitBatchArgs
- func NewAgentEmitBatchArgs() *AgentEmitBatchArgs
type AgentProcessor
- func NewAgentProcessor(handler Agent) *AgentProcessor

Constants ¶

This section is empty.

Variables ¶

View Source

var AgentEmitBatchArgs_Batch_DEFAULT *jaeger.Batch

View Source

var GoUnusedProtection__ int

Functions ¶

This section is empty.

Types ¶

type Agent ¶

type Agent interface {
	// Parameters:
	//  - Batch
	EmitBatch(ctx context.Context, batch *jaeger.Batch) (_err error)
}

type AgentClient ¶

type AgentClient struct {
	// contains filtered or unexported fields
}

func NewAgentClient ¶

func NewAgentClient(c thrift.TClient) *AgentClient

func NewAgentClientFactory ¶

func NewAgentClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AgentClient

func NewAgentClientProtocol ¶

func NewAgentClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AgentClient

func (*AgentClient) Client_ ¶

func (p *AgentClient) Client_() thrift.TClient

func (*AgentClient) EmitBatch ¶

func (p *AgentClient) EmitBatch(ctx context.Context, batch *jaeger.Batch) (_err error)

Parameters:

Batch

func (*AgentClient) LastResponseMeta_ ¶

func (p *AgentClient) LastResponseMeta_() thrift.ResponseMeta

func (*AgentClient) SetLastResponseMeta_ ¶

func (p *AgentClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type AgentEmitBatchArgs ¶

type AgentEmitBatchArgs struct {
	Batch *jaeger.Batch `thrift:"batch,1" db:"batch" json:"batch"`
}

Attributes:

Batch

func NewAgentEmitBatchArgs ¶

func NewAgentEmitBatchArgs() *AgentEmitBatchArgs

func (*AgentEmitBatchArgs) GetBatch ¶

func (p *AgentEmitBatchArgs) GetBatch() *jaeger.Batch

func (*AgentEmitBatchArgs) IsSetBatch ¶

func (p *AgentEmitBatchArgs) IsSetBatch() bool

func (*AgentEmitBatchArgs) Read ¶

func (p *AgentEmitBatchArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*AgentEmitBatchArgs) ReadField1 ¶

func (p *AgentEmitBatchArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*AgentEmitBatchArgs) String ¶

func (p *AgentEmitBatchArgs) String() string

func (*AgentEmitBatchArgs) Write ¶

func (p *AgentEmitBatchArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type AgentProcessor ¶

type AgentProcessor struct {
	// contains filtered or unexported fields
}

func NewAgentProcessor ¶

func NewAgentProcessor(handler Agent) *AgentProcessor

func (*AgentProcessor) AddToProcessorMap ¶

func (p *AgentProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*AgentProcessor) GetProcessorFunction ¶

func (p *AgentProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*AgentProcessor) Process ¶

func (p *AgentProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*AgentProcessor) ProcessorMap ¶

func (p *AgentProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
agent-remote

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL