proto

package
v0.0.0-...-4448a72 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2024 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_log_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClientStream 

type ClientStream struct {
	Method        string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	StreamName    string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	ServerStreams bool   `protobuf:"varint,3,opt,name=server_streams,json=serverStreams,proto3" json:"server_streams,omitempty"`
	ClientStreams bool   `protobuf:"varint,4,opt,name=client_streams,json=clientStreams,proto3" json:"client_streams,omitempty"`
	// contains filtered or unexported fields
}

ClientStream logs the client side of a grpc stream request, as intercepted by https://pkg.go.dev/google.golang.org/grpc#StreamClientInterceptor

func (*ClientStream) Descriptor deprecated 

func (*ClientStream) Descriptor() ([]byte, []int)

Deprecated: Use ClientStream.ProtoReflect.Descriptor instead.

func (*ClientStream) GetClientStreams 

func (x *ClientStream) GetClientStreams() bool

func (*ClientStream) GetMethod 

func (x *ClientStream) GetMethod() string

func (*ClientStream) GetServerStreams 

func (x *ClientStream) GetServerStreams() bool

func (*ClientStream) GetStreamName 

func (x *ClientStream) GetStreamName() string

func (*ClientStream) ProtoMessage 

func (*ClientStream) ProtoMessage()

func (*ClientStream) ProtoReflect 

func (x *ClientStream) ProtoReflect() protoreflect.Message

func (*ClientStream) Reset 

func (x *ClientStream) Reset()

func (*ClientStream) String 

func (x *ClientStream) String() string

type ClientUnary 

type ClientUnary struct {
	Method   string     `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Request  *anypb.Any `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	Response *anypb.Any `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

ClientUnary logs the client side of a grpc unary request, as intercepted by https://pkg.go.dev/google.golang.org/grpc#UnaryClientInterceptor

func (*ClientUnary) Descriptor deprecated 

func (*ClientUnary) Descriptor() ([]byte, []int)

Deprecated: Use ClientUnary.ProtoReflect.Descriptor instead.

func (*ClientUnary) GetMethod 

func (x *ClientUnary) GetMethod() string

func (*ClientUnary) GetRequest 

func (x *ClientUnary) GetRequest() *anypb.Any

func (*ClientUnary) GetResponse 

func (x *ClientUnary) GetResponse() *anypb.Any

func (*ClientUnary) ProtoMessage 

func (*ClientUnary) ProtoMessage()

func (*ClientUnary) ProtoReflect 

func (x *ClientUnary) ProtoReflect() protoreflect.Message

func (*ClientUnary) Reset 

func (x *ClientUnary) Reset()

func (*ClientUnary) String 

func (x *ClientUnary) String() string

type Entry 

type Entry struct {
	Start         *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Elapsed       *durationpb.Duration   `protobuf:"bytes,2,opt,name=elapsed,proto3" json:"elapsed,omitempty"`
	StatusCode    int32                  `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage string                 `protobuf:"bytes,4,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	StatusDetails []*anypb.Any           `protobuf:"bytes,5,rep,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
	Error         string                 `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// When cabe receives an incoming gRPC request, that would
	// be logged in the server_unary field. Since cabe does
	// not currently implement any streaming server calls,
	// there is no corresponding server_stream field.
	ServerUnary *ServerUnary `protobuf:"bytes,7,opt,name=server_unary,json=serverUnary,proto3" json:"server_unary,omitempty"`
	// When cabe makes an outgoing unary gRPC call to some
	// other service, that gets logged in client_unary.
	ClientUnary *ClientUnary `protobuf:"bytes,8,opt,name=client_unary,json=clientUnary,proto3" json:"client_unary,omitempty"`
	// When cabe makes an outgoing streaming gRPC call to some
	// other service, that gets logged in client_stream.
	ClientStream *ClientStream `protobuf:"bytes,9,opt,name=client_stream,json=clientStream,proto3" json:"client_stream,omitempty"`
	// These fields are processed by gcp's log to connect log lines
	// to traces and spans, if present. See:
	// https://cloud.google.com/logging/docs/structured-logging#structured_logging_special_fields
	TraceId      string `protobuf:"bytes,10,opt,name=trace_id,json=logging.googleapis.com/trace,proto3" json:"trace_id,omitempty"`
	SpanId       string `protobuf:"bytes,11,opt,name=span_id,json=logging.googleapis.com/spanId,proto3" json:"span_id,omitempty"`
	TraceSampled bool   `protobuf:"varint,12,opt,name=trace_sampled,json=logging.googleapis.com/trace_sampled,proto3" json:"trace_sampled,omitempty"`
	// contains filtered or unexported fields
}

Entry is a structured log message for grpc events. It can represent either side of an rpc: client or server.

func (*Entry) Descriptor deprecated 

func (*Entry) Descriptor() ([]byte, []int)

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetClientStream 

func (x *Entry) GetClientStream() *ClientStream

func (*Entry) GetClientUnary 

func (x *Entry) GetClientUnary() *ClientUnary

func (*Entry) GetElapsed 

func (x *Entry) GetElapsed() *durationpb.Duration

func (*Entry) GetError 

func (x *Entry) GetError() string

func (*Entry) GetServerUnary 

func (x *Entry) GetServerUnary() *ServerUnary

func (*Entry) GetSpanId 

func (x *Entry) GetSpanId() string

func (*Entry) GetStart 

func (x *Entry) GetStart() *timestamppb.Timestamp

func (*Entry) GetStatusCode 

func (x *Entry) GetStatusCode() int32

func (*Entry) GetStatusDetails 

func (x *Entry) GetStatusDetails() []*anypb.Any

func (*Entry) GetStatusMessage 

func (x *Entry) GetStatusMessage() string

func (*Entry) GetTraceId 

func (x *Entry) GetTraceId() string

func (*Entry) GetTraceSampled 

func (x *Entry) GetTraceSampled() bool

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

func (x *Entry) ProtoReflect() protoreflect.Message

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type ServerUnary 

type ServerUnary struct {

	// request is the incoming grpc request proto sent by
	// a client calling cabe.
	Request *anypb.Any `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// response is the outgoing grpc response proto returned
	// by cabe to the caller.
	Response *anypb.Any `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	// full_method is the fully qualified grpc method being
	// called, e.g. "cabe.v1.Analysis/GetAnalysis"
	FullMethod string `protobuf:"bytes,3,opt,name=full_method,json=fullMethod,proto3" json:"full_method,omitempty"`
	// user is the identity of the user making the incoming server request.
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

ServerUnary logs the server side of a grpc unary request, as intercepted by https://pkg.go.dev/google.golang.org/grpc#UnaryServerInterceptor

func (*ServerUnary) Descriptor deprecated 

func (*ServerUnary) Descriptor() ([]byte, []int)

Deprecated: Use ServerUnary.ProtoReflect.Descriptor instead.

func (*ServerUnary) GetFullMethod 

func (x *ServerUnary) GetFullMethod() string

func (*ServerUnary) GetRequest 

func (x *ServerUnary) GetRequest() *anypb.Any

func (*ServerUnary) GetResponse 

func (x *ServerUnary) GetResponse() *anypb.Any

func (*ServerUnary) GetUser 

func (x *ServerUnary) GetUser() string

func (*ServerUnary) ProtoMessage 

func (*ServerUnary) ProtoMessage()

func (*ServerUnary) ProtoReflect 

func (x *ServerUnary) ProtoReflect() protoreflect.Message

func (*ServerUnary) Reset 

func (x *ServerUnary) Reset()

func (*ServerUnary) String 

func (x *ServerUnary) String() string

Source Files

View all Source files

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.