logging

Documentation

Index

• Variables
• func Background() context.Context
• func ParsePeerAddress(p *peer.Peer, md metadata.MD) (string, string)
• func Prepare(ctx context.Context, deps ExtensionDeps) error
• func SerializeMessage(msg interface{}) string
• type ExtensionDeps
• type Interceptor
  • func (ic Interceptor) Streaming(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (ic Interceptor) Unary(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Variables

var (
	Package__16bc0q = &core.Package{
		PackageName: "namespacelabs.dev/foundation/std/grpc/logging",
	}

	Provider__16bc0q = core.Provider{
		Package:     Package__16bc0q,
		Instantiate: makeDeps__16bc0q,
	}

	Initializers__16bc0q = []*core.Initializer{
		{
			Package: Package__16bc0q,
			Do: func(ctx context.Context, di core.Dependencies) error {
				return di.Instantiate(ctx, Provider__16bc0q, func(ctx context.Context, v interface{}) error {
					return Prepare(ctx, v.(ExtensionDeps))
				})
			},
		},
	}
)

var Log = core.ZLog

Functions

func Background

func Background() context.Context

func ParsePeerAddress

func ParsePeerAddress(p *peer.Peer, md metadata.MD) (string, string)

func Prepare

func Prepare(ctx context.Context, deps ExtensionDeps) error

func SerializeMessage

func SerializeMessage(msg interface{}) string

Types

type ExtensionDeps

type ExtensionDeps struct {
	Interceptors interceptors.Registration
	Middleware   middleware.Middleware
}

Dependencies that are instantiated once for the lifetime of the extension.

type Interceptor

type Interceptor struct {
	Logger *zerolog.Logger
}

func (Interceptor) Streaming

func (ic Interceptor) Streaming(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (Interceptor) Unary

func (ic Interceptor) Unary(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)