proxy

Documentation

Index

• Constants
• type Proxy
  • func New(config ProxyConfig, logger hclog.Logger) (*Proxy, error)
  • func (p *Proxy) Capabilities(ctx context.Context, r *storage_v1.CapabilitiesRequest) (*storage_v1.CapabilitiesResponse, error)
  • func (p *Proxy) Close(ctx context.Context, _ *storage_v1.CloseWriterRequest) (*storage_v1.CloseWriterResponse, error)
  • func (p *Proxy) FindTraceIDs(ctx context.Context, r *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error)
  • func (p *Proxy) FindTraces(r *storage_v1.FindTracesRequest, ...) error
  • func (p *Proxy) GetArchiveTrace(r *storage_v1.GetTraceRequest, ...) error
  • func (p *Proxy) GetDependencies(ctx context.Context, r *storage_v1.GetDependenciesRequest) (*storage_v1.GetDependenciesResponse, error)
  • func (p *Proxy) GetOperations(ctx context.Context, r *storage_v1.GetOperationsRequest) (*storage_v1.GetOperationsResponse, error)
  • func (p *Proxy) GetServices(ctx context.Context, r *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error)
  • func (p *Proxy) GetTrace(r *storage_v1.GetTraceRequest, ...) error
  • func (p *Proxy) WriteArchiveSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)
  • func (p *Proxy) WriteSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)
• type ProxyConfig

Constants

const DefaultTimeout = time.Duration(5 * time.Second)

Types

type Proxy

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

func New

func New(config ProxyConfig, logger hclog.Logger) (*Proxy, error)

func (*Proxy) Capabilities

func (p *Proxy) Capabilities(ctx context.Context, r *storage_v1.CapabilitiesRequest) (*storage_v1.CapabilitiesResponse, error)

func (*Proxy) Close

func (p *Proxy) Close(ctx context.Context, _ *storage_v1.CloseWriterRequest) (*storage_v1.CloseWriterResponse, error)

func (*Proxy) FindTraceIDs

func (p *Proxy) FindTraceIDs(ctx context.Context, r *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error)

func (*Proxy) FindTraces

func (p *Proxy) FindTraces(r *storage_v1.FindTracesRequest, stream storage_v1.SpanReaderPlugin_FindTracesServer) error

func (*Proxy) GetArchiveTrace

func (p *Proxy) GetArchiveTrace(r *storage_v1.GetTraceRequest, stream storage_v1.ArchiveSpanReaderPlugin_GetArchiveTraceServer) error

func (*Proxy) GetDependencies

func (p *Proxy) GetDependencies(ctx context.Context, r *storage_v1.GetDependenciesRequest) (*storage_v1.GetDependenciesResponse, error)

func (*Proxy) GetOperations

func (p *Proxy) GetOperations(
	ctx context.Context,
	r *storage_v1.GetOperationsRequest,
) (*storage_v1.GetOperationsResponse, error)

func (*Proxy) GetServices

func (p *Proxy) GetServices(ctx context.Context, r *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error)

func (*Proxy) GetTrace

func (p *Proxy) GetTrace(r *storage_v1.GetTraceRequest, stream storage_v1.SpanReaderPlugin_GetTraceServer) error

func (*Proxy) WriteArchiveSpan

func (p *Proxy) WriteArchiveSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)

func (*Proxy) WriteSpan

func (p *Proxy) WriteSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)

type ProxyConfig

type ProxyConfig struct {
	TLS                bool          `yaml:"tls"`
	CaFile             string        `yaml:"cafile,omitempty"`
	ServerAddr         string        `yaml:"grpc-server"`
	ServerHostOverride string        `yaml:"grpc-server-host-override,omitempty"`
	ConnectTimeout     time.Duration `yaml:"connection-timeout,omitempty"`
}