Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

qezap

package module

Go to main page

Versions in this module

v1

v1.1.1

Dec 12, 2022

Changes in this version

+ const LocalScheme

+ const LocalServiceName

+ const ModeDebug

+ const ModeRelease

+ const TransportGRPC

+ const TransportHTTP

+ const TransportMock

+ var DialLocalServiceName = fmt.Sprintf("%s:///%s", LocalScheme, LocalServiceName)

+ var ErrUnavailable = errors.New("Push Unavailable")

+ func ConditionOne(v string) zap.Field

+ func ConditionThree(v string) zap.Field

+ func ConditionTwo(v string) zap.Field

+ func FieldTraceID(ctx context.Context) zap.Field

+ func TraceID(ctx context.Context) types.TraceID

+ func WithTraceID(ctx context.Context) context.Context

+ type DataPacket struct

+ func (d *DataPacket) CanPush() bool

+ func (d *DataPacket) Data() *receiverpb.Packet

+ func (d *DataPacket) IsEmpty() bool

+ type LocalOption struct

+ Filename string

+ GzipCompress bool

+ MaxAge time.Duration

+ MaxSize int64

+ func DefaultLocalOption() *LocalOption

+ type LocalResolverBuilder struct

+ func NewLocalResolverBuilder(address []string) *LocalResolverBuilder

+ func (*LocalResolverBuilder) Scheme() string

+ func (lrb *LocalResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

+ type Logger struct

+ func New(opts ...Option) *Logger

+ func (lg *Logger) Close() error

+ func (lg *Logger) ConditionOne(v interface{}) zap.Field

+ func (lg *Logger) ConditionThree(v interface{}) zap.Field

+ func (lg *Logger) ConditionTwo(v interface{}) zap.Field

+ func (lg *Logger) FieldTraceID(ctx context.Context) zap.Field

+ func (lg *Logger) NewLevelWriter(level zapcore.Level, msg string) *Writer

+ func (lg *Logger) SetEnabledLevel(lvl zapcore.Level) *Logger

+ func (lg *Logger) TraceID(ctx context.Context) types.TraceID

+ func (lg *Logger) WithTraceID(ctx context.Context) context.Context

+ type Mode string

+ type Option interface

+ func WithAddrsAndModuleName(addrs []string, moduleName string) Option

+ func WithFilename(filename string) Option

+ func WithGzipCompress(enable bool) Option

+ func WithLevel(lvl zapcore.Level) Option

+ func WithMode(mode Mode) Option

+ func WithRemoteConcurrent(n uint) Option

+ func WithRemotePacketSize(n uint) Option

+ func WithRemoteWriteTimeout(timeout time.Duration) Option

+ func WithRotateMaxSizeAge(size uint64, age time.Duration) Option

+ func WithTransport(trans Transport) Option

+ func WithZapOptions(opts ...zap.Option) Option

+ type Packet struct

+ func (p *Packet) Append(b []byte) *DataPacket

+ func (p *Packet) DataPacket() *DataPacket

+ func (p *Packet) PoolPutDataPacket(d *DataPacket)

+ func (p *Packet) SetCanPush(d *DataPacket)

+ func (p *Packet) SwitchNextDataPacket()

+ type Pusher interface

+ Close func() error

+ Concurrent func() int

+ PushPacket func(ctx context.Context, in *receiverpb.Packet) error

+ type Transport string

+ type WriteLocal struct

+ func NewWriteLocal(opt *LocalOption) *WriteLocal

+ func (w *WriteLocal) Close() error

+ func (w *WriteLocal) Sync() error

+ func (w *WriteLocal) Write(b []byte) (n int, err error)

+ type WriteRemote struct

+ func (w *WriteRemote) Close() error

+ func (w *WriteRemote) Sync() error

+ func (w *WriteRemote) Write(b []byte) (n int, err error)

+ type Writer struct

+ func (w *Writer) Write(b []byte) (n int, err error)

v1.1.0

Dec 10, 2022

v1.0.3

Jun 15, 2021