package otlptracegrpc

import "github.com/moby/buildkit/util/tracing/otlptracegrpc"

Index ¶

• func NewClient(cc *grpc.ClientConn) otlptrace.Client
• type Connection
• func NewConnection(cc *grpc.ClientConn, handler func(cc *grpc.ClientConn)) *Connection
• func (c *Connection) Connected() bool
• func (c *Connection) ContextWithMetadata(ctx context.Context) context.Context
• func (c *Connection) ContextWithStop(ctx context.Context) (context.Context, context.CancelCauseFunc)
• func (c *Connection) LastConnectError() error
• func (c *Connection) SetStateDisconnected(err error)
• func (c *Connection) Shutdown(ctx context.Context) error
• func (c *Connection) StartConnection(ctx context.Context) error

Functions ¶

func NewClient ¶

func NewClient(cc *grpc.ClientConn) otlptrace.Client

NewClient creates a new gRPC trace client.

Types ¶

type Connection ¶

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

func NewConnection ¶

func NewConnection(cc *grpc.ClientConn, handler func(cc *grpc.ClientConn)) *Connection

func (*Connection) Connected ¶

func (c *Connection) Connected() bool

func (*Connection) ContextWithMetadata ¶

func (c *Connection) ContextWithMetadata(ctx context.Context) context.Context

func (*Connection) ContextWithStop ¶

func (c *Connection) ContextWithStop(ctx context.Context) (context.Context, context.CancelCauseFunc)

func (*Connection) LastConnectError ¶

func (c *Connection) LastConnectError() error

func (*Connection) SetStateDisconnected ¶

func (c *Connection) SetStateDisconnected(err error)

func (*Connection) Shutdown ¶

func (c *Connection) Shutdown(ctx context.Context) error

func (*Connection) StartConnection ¶

func (c *Connection) StartConnection(ctx context.Context) error

Source Files ¶

client.go connection.go errors.go