zipkincollector

package
v0.0.0-...-1bace3b Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2015 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var StoreDependenciesArgs_Dependencies_DEFAULT *zipkindependencies.Dependencies

Functions

This section is empty.

Types

type AdjustableRateException 

type AdjustableRateException struct {
	Msg string `thrift:"msg,1" json:"msg"`
}

func NewAdjustableRateException 

func NewAdjustableRateException() *AdjustableRateException

func (*AdjustableRateException) Error 

func (p *AdjustableRateException) Error() string

func (*AdjustableRateException) GetMsg 

func (p *AdjustableRateException) GetMsg() string

func (*AdjustableRateException) Read 

func (p *AdjustableRateException) Read(iprot thrift.TProtocol) error

func (*AdjustableRateException) ReadField1 

func (p *AdjustableRateException) ReadField1(iprot thrift.TProtocol) error

func (*AdjustableRateException) String 

func (p *AdjustableRateException) String() string

func (*AdjustableRateException) Write 

func (p *AdjustableRateException) Write(oprot thrift.TProtocol) error

type StoreAggregatesException 

type StoreAggregatesException struct {
	Msg string `thrift:"msg,1" json:"msg"`
}
var StoreDependenciesResult_E_DEFAULT *StoreAggregatesException
var StoreTopAnnotationsResult_E_DEFAULT *StoreAggregatesException
var StoreTopKeyValueAnnotationsResult_E_DEFAULT *StoreAggregatesException

func NewStoreAggregatesException 

func NewStoreAggregatesException() *StoreAggregatesException

func (*StoreAggregatesException) Error 

func (p *StoreAggregatesException) Error() string

func (*StoreAggregatesException) GetMsg 

func (p *StoreAggregatesException) GetMsg() string

func (*StoreAggregatesException) Read 

func (p *StoreAggregatesException) Read(iprot thrift.TProtocol) error

func (*StoreAggregatesException) ReadField1 

func (p *StoreAggregatesException) ReadField1(iprot thrift.TProtocol) error

func (*StoreAggregatesException) String 

func (p *StoreAggregatesException) String() string

func (*StoreAggregatesException) Write 

func (p *StoreAggregatesException) Write(oprot thrift.TProtocol) error

type StoreDependenciesArgs 

type StoreDependenciesArgs struct {
	Dependencies *zipkindependencies.Dependencies `thrift:"dependencies,1" json:"dependencies"`
}

func NewStoreDependenciesArgs 

func NewStoreDependenciesArgs() *StoreDependenciesArgs

func (*StoreDependenciesArgs) GetDependencies 

func (p *StoreDependenciesArgs) GetDependencies() *zipkindependencies.Dependencies

func (*StoreDependenciesArgs) IsSetDependencies 

func (p *StoreDependenciesArgs) IsSetDependencies() bool

func (*StoreDependenciesArgs) Read 

func (p *StoreDependenciesArgs) Read(iprot thrift.TProtocol) error

func (*StoreDependenciesArgs) ReadField1 

func (p *StoreDependenciesArgs) ReadField1(iprot thrift.TProtocol) error

func (*StoreDependenciesArgs) String 

func (p *StoreDependenciesArgs) String() string

func (*StoreDependenciesArgs) Write 

func (p *StoreDependenciesArgs) Write(oprot thrift.TProtocol) error

type StoreDependenciesResult 

type StoreDependenciesResult struct {
	E *StoreAggregatesException `thrift:"e,1" json:"e"`
}

func NewStoreDependenciesResult 

func NewStoreDependenciesResult() *StoreDependenciesResult

func (*StoreDependenciesResult) GetE 

func (p *StoreDependenciesResult) GetE() *StoreAggregatesException

func (*StoreDependenciesResult) IsSetE 

func (p *StoreDependenciesResult) IsSetE() bool

func (*StoreDependenciesResult) Read 

func (p *StoreDependenciesResult) Read(iprot thrift.TProtocol) error

func (*StoreDependenciesResult) ReadField1 

func (p *StoreDependenciesResult) ReadField1(iprot thrift.TProtocol) error

func (*StoreDependenciesResult) String 

func (p *StoreDependenciesResult) String() string

func (*StoreDependenciesResult) Write 

func (p *StoreDependenciesResult) Write(oprot thrift.TProtocol) error

type StoreTopAnnotationsArgs 

type StoreTopAnnotationsArgs struct {
	ServiceName string   `thrift:"service_name,1" json:"service_name"`
	Annotations []string `thrift:"annotations,2" json:"annotations"`
}

func NewStoreTopAnnotationsArgs 

func NewStoreTopAnnotationsArgs() *StoreTopAnnotationsArgs

func (*StoreTopAnnotationsArgs) GetAnnotations 

func (p *StoreTopAnnotationsArgs) GetAnnotations() []string

func (*StoreTopAnnotationsArgs) GetServiceName 

func (p *StoreTopAnnotationsArgs) GetServiceName() string

func (*StoreTopAnnotationsArgs) Read 

func (p *StoreTopAnnotationsArgs) Read(iprot thrift.TProtocol) error

func (*StoreTopAnnotationsArgs) ReadField1 

func (p *StoreTopAnnotationsArgs) ReadField1(iprot thrift.TProtocol) error

func (*StoreTopAnnotationsArgs) ReadField2 

func (p *StoreTopAnnotationsArgs) ReadField2(iprot thrift.TProtocol) error

func (*StoreTopAnnotationsArgs) String 

func (p *StoreTopAnnotationsArgs) String() string

func (*StoreTopAnnotationsArgs) Write 

func (p *StoreTopAnnotationsArgs) Write(oprot thrift.TProtocol) error

type StoreTopAnnotationsResult 

type StoreTopAnnotationsResult struct {
	E *StoreAggregatesException `thrift:"e,1" json:"e"`
}

func NewStoreTopAnnotationsResult 

func NewStoreTopAnnotationsResult() *StoreTopAnnotationsResult

func (*StoreTopAnnotationsResult) GetE 

func (p *StoreTopAnnotationsResult) GetE() *StoreAggregatesException

func (*StoreTopAnnotationsResult) IsSetE 

func (p *StoreTopAnnotationsResult) IsSetE() bool

func (*StoreTopAnnotationsResult) Read 

func (p *StoreTopAnnotationsResult) Read(iprot thrift.TProtocol) error

func (*StoreTopAnnotationsResult) ReadField1 

func (p *StoreTopAnnotationsResult) ReadField1(iprot thrift.TProtocol) error

func (*StoreTopAnnotationsResult) String 

func (p *StoreTopAnnotationsResult) String() string

func (*StoreTopAnnotationsResult) Write 

func (p *StoreTopAnnotationsResult) Write(oprot thrift.TProtocol) error

type StoreTopKeyValueAnnotationsArgs 

type StoreTopKeyValueAnnotationsArgs struct {
	ServiceName string   `thrift:"service_name,1" json:"service_name"`
	Annotations []string `thrift:"annotations,2" json:"annotations"`
}

func NewStoreTopKeyValueAnnotationsArgs 

func NewStoreTopKeyValueAnnotationsArgs() *StoreTopKeyValueAnnotationsArgs

func (*StoreTopKeyValueAnnotationsArgs) GetAnnotations 

func (p *StoreTopKeyValueAnnotationsArgs) GetAnnotations() []string

func (*StoreTopKeyValueAnnotationsArgs) GetServiceName 

func (p *StoreTopKeyValueAnnotationsArgs) GetServiceName() string

func (*StoreTopKeyValueAnnotationsArgs) Read 

func (p *StoreTopKeyValueAnnotationsArgs) Read(iprot thrift.TProtocol) error

func (*StoreTopKeyValueAnnotationsArgs) ReadField1 

func (p *StoreTopKeyValueAnnotationsArgs) ReadField1(iprot thrift.TProtocol) error

func (*StoreTopKeyValueAnnotationsArgs) ReadField2 

func (p *StoreTopKeyValueAnnotationsArgs) ReadField2(iprot thrift.TProtocol) error

func (*StoreTopKeyValueAnnotationsArgs) String 

func (p *StoreTopKeyValueAnnotationsArgs) String() string

func (*StoreTopKeyValueAnnotationsArgs) Write 

func (p *StoreTopKeyValueAnnotationsArgs) Write(oprot thrift.TProtocol) error

type StoreTopKeyValueAnnotationsResult 

type StoreTopKeyValueAnnotationsResult struct {
	E *StoreAggregatesException `thrift:"e,1" json:"e"`
}

func NewStoreTopKeyValueAnnotationsResult 

func NewStoreTopKeyValueAnnotationsResult() *StoreTopKeyValueAnnotationsResult

func (*StoreTopKeyValueAnnotationsResult) GetE 

func (p *StoreTopKeyValueAnnotationsResult) GetE() *StoreAggregatesException

func (*StoreTopKeyValueAnnotationsResult) IsSetE 

func (p *StoreTopKeyValueAnnotationsResult) IsSetE() bool

func (*StoreTopKeyValueAnnotationsResult) Read 

func (p *StoreTopKeyValueAnnotationsResult) Read(iprot thrift.TProtocol) error

func (*StoreTopKeyValueAnnotationsResult) ReadField1 

func (p *StoreTopKeyValueAnnotationsResult) ReadField1(iprot thrift.TProtocol) error

func (*StoreTopKeyValueAnnotationsResult) String 

func (p *StoreTopKeyValueAnnotationsResult) String() string

func (*StoreTopKeyValueAnnotationsResult) Write 

func (p *StoreTopKeyValueAnnotationsResult) Write(oprot thrift.TProtocol) error

type ZipkinCollector 

type ZipkinCollector interface {
	scribe.Scribe

	// Aggregates methods
	//
	// Parameters:
	//  - ServiceName
	//  - Annotations
	StoreTopAnnotations(service_name string, annotations []string) (err error)
	// Parameters:
	//  - ServiceName
	//  - Annotations
	StoreTopKeyValueAnnotations(service_name string, annotations []string) (err error)
	// Parameters:
	//  - Dependencies
	StoreDependencies(dependencies *zipkindependencies.Dependencies) (err error)
}

type ZipkinCollectorClient 

type ZipkinCollectorClient struct {
	*scribe.ScribeClient
}

func NewZipkinCollectorClientFactory 

func NewZipkinCollectorClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ZipkinCollectorClient

func NewZipkinCollectorClientProtocol 

func NewZipkinCollectorClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ZipkinCollectorClient

func (*ZipkinCollectorClient) StoreDependencies 

func (p *ZipkinCollectorClient) StoreDependencies(dependencies *zipkindependencies.Dependencies) (err error)

Parameters:

  • Dependencies

func (*ZipkinCollectorClient) StoreTopAnnotations 

func (p *ZipkinCollectorClient) StoreTopAnnotations(service_name string, annotations []string) (err error)

Aggregates methods

Parameters:

  • ServiceName
  • Annotations

func (*ZipkinCollectorClient) StoreTopKeyValueAnnotations 

func (p *ZipkinCollectorClient) StoreTopKeyValueAnnotations(service_name string, annotations []string) (err error)

Parameters:

  • ServiceName
  • Annotations

type ZipkinCollectorProcessor 

type ZipkinCollectorProcessor struct {
	*scribe.ScribeProcessor
}

func NewZipkinCollectorProcessor 

func NewZipkinCollectorProcessor(handler ZipkinCollector) *ZipkinCollectorProcessor

Source Files

View all Source files

Directories

Path Synopsis

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.