grpc

Documentation

Index

• func DoWithTimeout(f func() error, d time.Duration) error
• func GetDDAgentClient(ctx context.Context, opts ...grpc.DialOption) (pb.AgentClient, error)
• func GetDDAgentSecureClient(ctx context.Context, opts ...grpc.DialOption) (pb.AgentSecureClient, error)
• func NewLogger() grpclog.LoggerV2

Functions

func DoWithTimeout

func DoWithTimeout(f func() error, d time.Duration) error

DoWithTimeout runs f and returns its error. If the deadline d elapses first, it returns a grpc DeadlineExceeded error instead.

func GetDDAgentClient

func GetDDAgentClient(ctx context.Context, opts ...grpc.DialOption) (pb.AgentClient, error)

GetDDAgentClient creates a pb.AgentClient for IPC with the main agent via gRPC. This call is blocking by default, so it is up to the caller to supply a context with appropriate timeout/cancel options

func GetDDAgentSecureClient

func GetDDAgentSecureClient(ctx context.Context, opts ...grpc.DialOption) (pb.AgentSecureClient, error)

GetDDAgentSecureClient creates a pb.AgentSecureClient for IPC with the main agent via gRPC. This call is blocking by default, so it is up to the caller to supply a context with appropriate timeout/cancel options

func NewLogger

func NewLogger() grpclog.LoggerV2

NewLogger returns a gRPC logger that logs to the Datadog logger instead of directly to stderr.