type callIDGenerator … func (g *callIDGenerator) next() uint64 { … } // reset is for testing only, and doesn't need to be thread safe. func (g *callIDGenerator) reset() { … } var idGen … type MethodLogger … type TruncatingMethodLogger … // NewTruncatingMethodLogger returns a new truncating method logger. // // This is used in the 1.0 release of gcp/observability, and thus must not be // deleted or changed. func NewTruncatingMethodLogger(h, m uint64) *TruncatingMethodLogger { … } // Build is an internal only method for building the proto message out of the // input event. It's made public to enable other library to reuse as much logic // in TruncatingMethodLogger as possible. func (ml *TruncatingMethodLogger) Build(c LogEntryConfig) *binlogpb.GrpcLogEntry { … } // Log creates a proto binary log entry, and logs it to the sink. func (ml *TruncatingMethodLogger) Log(ctx context.Context, c LogEntryConfig) { … } func (ml *TruncatingMethodLogger) truncateMetadata(mdPb *binlogpb.Metadata) (truncated bool) { … } func (ml *TruncatingMethodLogger) truncateMessage(msgPb *binlogpb.Message) (truncated bool) { … } type LogEntryConfig … type ClientHeader … func (c *ClientHeader) toProto() *binlogpb.GrpcLogEntry { … } type ServerHeader … func (c *ServerHeader) toProto() *binlogpb.GrpcLogEntry { … } type ClientMessage … func (c *ClientMessage) toProto() *binlogpb.GrpcLogEntry { … } type ServerMessage … func (c *ServerMessage) toProto() *binlogpb.GrpcLogEntry { … } type ClientHalfClose … func (c *ClientHalfClose) toProto() *binlogpb.GrpcLogEntry { … } type ServerTrailer … func (c *ServerTrailer) toProto() *binlogpb.GrpcLogEntry { … } type Cancel … func (c *Cancel) toProto() *binlogpb.GrpcLogEntry { … } // metadataKeyOmit returns whether the metadata entry with this key should be // omitted. func metadataKeyOmit(key string) bool { … } func mdToMetadataProto(md metadata.MD) *binlogpb.Metadata { … } func addrToProto(addr net.Addr) *binlogpb.Address { … }
Codebase Browser
kubernetes