gax

Jul 5, 2023

Changes in this version

+ func BuildHeaders(ctx context.Context, keyvals ...string) http.Header

+ func InsertMetadataIntoOutgoingContext(ctx context.Context, keyvals ...string) context.Context

Jun 13, 2023

Changes in this version

+ var GoVersion string

Mar 15, 2023

Changes in this version

type CallOption

+ func WithTimeout(t time.Duration) CallOption

Oct 14, 2022

Changes in this version

+ func DetermineContentType(media io.Reader) (io.Reader, string)

May 10, 2022

Changes in this version

type Retryer

+ func OnHTTPCodes(bo Backoff, cc ...int) Retryer

Apr 11, 2022

Changes in this version

type CallOption

+ func WithPath(p string) CallOption

type CallSettings

+ Path string

Mar 16, 2022

Changes in this version

+ type ProtoJSONStream struct

+ func NewProtoJSONStreamReader(rc io.ReadCloser, typ protoreflect.MessageType) *ProtoJSONStream

+ func (s *ProtoJSONStream) Close() error

+ func (s *ProtoJSONStream) Recv() (proto.Message, error)

Aug 23, 2021

Changes in this version

type Retryer

+ func OnErrorFunc(bo Backoff, shouldRetry func(err error) bool) Retryer

Nov 13, 2018

Changes in this version

+ const Version

+ func Invoke(ctx context.Context, call APICall, opts ...CallOption) error

+ func Sleep(ctx context.Context, d time.Duration) error

+ func XGoogHeader(keyval ...string) string

+ type APICall func(context.Context, CallSettings) error

+ type Backoff struct

+ Initial time.Duration

+ Max time.Duration

+ Multiplier float64

+ func (bo *Backoff) Pause() time.Duration

+ type CallOption interface

+ Resolve func(cs *CallSettings)

+ func WithGRPCOptions(opt ...grpc.CallOption) CallOption

+ func WithRetry(fn func() Retryer) CallOption

+ type CallSettings struct

+ GRPC []grpc.CallOption

+ Retry func() Retryer

+ type Retryer interface

+ Retry func(err error) (pause time.Duration, shouldRetry bool)

+ func OnCodes(cc []codes.Code, bo Backoff) Retryer