grpctool

package

Go to main page

Versions in this module

v14

v14.10.0

Apr 14, 2022

v14.10.0-rc2

Apr 8, 2022

v14.10.0-rc1

Apr 1, 2022

v14.9.1

Mar 17, 2022

v14.9.0

Mar 9, 2022

v14.8.1

Feb 11, 2022

v14.8.0

Feb 11, 2022

v14.7.0

Dec 3, 2021

v14.5.0

Nov 9, 2021

Changes in this version

type HttpRequest

+ func (m *HttpRequest) ValidateAll() error

+ type HttpRequestMultiError []error

+ func (m HttpRequestMultiError) AllErrors() []error

+ func (m HttpRequestMultiError) Error() string

type HttpRequest_Data

+ func (m *HttpRequest_Data) ValidateAll() error

+ type HttpRequest_DataMultiError []error

+ func (m HttpRequest_DataMultiError) AllErrors() []error

+ func (m HttpRequest_DataMultiError) Error() string

type HttpRequest_Header

+ func (m *HttpRequest_Header) ValidateAll() error

+ type HttpRequest_HeaderMultiError []error

+ func (m HttpRequest_HeaderMultiError) AllErrors() []error

+ func (m HttpRequest_HeaderMultiError) Error() string

type HttpRequest_Trailer

+ func (m *HttpRequest_Trailer) ValidateAll() error

+ type HttpRequest_TrailerMultiError []error

+ func (m HttpRequest_TrailerMultiError) AllErrors() []error

+ func (m HttpRequest_TrailerMultiError) Error() string

type HttpResponse

+ func (m *HttpResponse) ValidateAll() error

+ type HttpResponseMultiError []error

+ func (m HttpResponseMultiError) AllErrors() []error

+ func (m HttpResponseMultiError) Error() string

type HttpResponse_Data

+ func (m *HttpResponse_Data) ValidateAll() error

+ type HttpResponse_DataMultiError []error

+ func (m HttpResponse_DataMultiError) AllErrors() []error

+ func (m HttpResponse_DataMultiError) Error() string

type HttpResponse_Header

+ func (m *HttpResponse_Header) ValidateAll() error

+ type HttpResponse_HeaderMultiError []error

+ func (m HttpResponse_HeaderMultiError) AllErrors() []error

+ func (m HttpResponse_HeaderMultiError) Error() string

type HttpResponse_Trailer

+ func (m *HttpResponse_Trailer) ValidateAll() error

+ type HttpResponse_TrailerMultiError []error

+ func (m HttpResponse_TrailerMultiError) AllErrors() []error

+ func (m HttpResponse_TrailerMultiError) Error() string

+ type Pool struct

+ func NewPool(log *zap.Logger, dialOpts ...grpc.DialOption) *Pool

+ func (p *Pool) Close() error

+ func (p *Pool) Dial(ctx context.Context, targetUrl string) (PoolConn, error)

+ type PoolConn interface

+ Done func()

v14.5.0-rc2

Oct 27, 2021

v14.5.0-rc1

Oct 24, 2021

v14.4.0

Oct 13, 2021

Changes in this version

+ func NewServerMaxConnAgeStatsHandler(auxCtx context.Context, maxConnectionAge time.Duration) stats.Handler

+ type HandleProcessingErrorFunc func(msg string, err error)

+ type HandleSendErrorFunc func(msg string, err error) error

+ type HttpRequestClient interface

+ Recv func() (*HttpResponse, error)

+ Send func(*HttpRequest) error

type InboundGrpcToOutboundHttp

+ HandleProcessingError HandleProcessingErrorFunc

+ HandleSendError HandleSendErrorFunc

+ HttpDo HttpDo

+ Log *zap.Logger

+ type InboundGrpcToOutboundStream struct

+ PipeInboundToOutbound func() error

+ PipeOutboundToInbound func() error

+ func (x *InboundGrpcToOutboundStream) Pipe() error

+ type InboundHttpToOutboundGrpc struct

+ HandleProcessingError HandleProcessingErrorFunc

+ Log *zap.Logger

+ MergeHeaders MergeHeadersFunc

+ func (x *InboundHttpToOutboundGrpc) Pipe(outboundClient HttpRequestClient, w http.ResponseWriter, r *http.Request, ...)

+ type MergeHeadersFunc func(fromOutbound, toInbound http.Header)

type StreamVisitor

+ func HttpRequestStreamVisitor() *StreamVisitor

+ func HttpResponseStreamVisitor() *StreamVisitor

v14.4.0-rc1

Oct 6, 2021

v14.3.3

Sep 21, 2021

v14.3.2

Sep 17, 2021

Changes in this version

+ func HandleSendError(log *zap.Logger, msg string, err error) error

+ func RequestCanceledOrTimedOut(err error) bool

+ func RequestTimedOut(err error) bool

v14.3.1

Sep 15, 2021

v14.3.0

Sep 13, 2021

v14.2.2

Aug 16, 2021

v14.2.1

Aug 16, 2021

v14.2.0

Aug 16, 2021

Changes in this version

+ func AddMaxConnectionAgeContext(ctx, ageCtx context.Context) context.Context

+ func MaxConnectionAgeContextFromStreamContext(streamCtx context.Context) context.Context

+ func NewJoinStatHandlers(handlers ...stats.Handler) stats.Handler

+ func NewMaxConnAgeStatsHandler(auxCtx context.Context, maxConnectionAge time.Duration) stats.Handler

+ func SplitGrpcMethod(fullMethodName string) (string, string)

+ type RpcApi interface

+ HandleProcessingError func(log *zap.Logger, agentId int64, msg string, err error)

+ HandleSendError func(log *zap.Logger, msg string, err error) error

+ Log func() *zap.Logger

v14.1.1

Jul 26, 2021

v14.1.0

Jul 15, 2021

Changes in this version

+ func DeferMaybeWrapWithCorrelationId(err *error, client grpc.ClientStream)

+ func MaxConnectionAge2GrpcKeepalive(maxConnectionAge time.Duration) grpc.ServerOption

+ func MaxConnectionAge2MaxPollDuration(maxConnectionAge time.Duration) time.Duration

+ func MaybeWrapWithCorrelationId(err error, client grpc.ClientStream) error

v14.0.1

Jun 21, 2021

v14.0.0

Jun 11, 2021

Changes in this version

+ const MetadataAuthorization

+ var File_internal_tool_grpctool_grpctool_proto protoreflect.FileDescriptor

+ func AgentMDFromRawContext(ctx context.Context) (*api.AgentMD, error)

+ func InjectLogger(ctx context.Context, log *zap.Logger) context.Context

+ func IsStatusError(err error) bool

+ func LoggerFromContext(ctx context.Context) *zap.Logger

+ func MetaToValuesMap(meta metadata.MD) map[string]*prototool.Values

+ func NewTokenCredentials(token api.AgentToken, insecure bool) credentials.PerRPCCredentials

+ func RequestCanceled(err error) bool

+ func StartServer(stage stager.Stage, server *grpc.Server, interceptorsCancel context.CancelFunc, ...)

+ func StreamClientCtxAugmentingInterceptor(f ContextAugmenter) grpc.StreamClientInterceptor

+ func StreamClientLimitingInterceptor(limiter ClientLimiter) grpc.StreamClientInterceptor

+ func StreamClientValidatingInterceptor(parentCtx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, ...) (grpc.ClientStream, error)

+ func StreamServerAgentMDInterceptor() grpc.StreamServerInterceptor

+ func StreamServerCtxAugmentingInterceptor(f ContextAugmenter) grpc.StreamServerInterceptor

+ func StreamServerLimitingInterceptor(limiter ServerLimiter) grpc.StreamServerInterceptor

+ func StreamServerLoggerInterceptor(log *zap.Logger) grpc.StreamServerInterceptor

+ func UnaryClientCtxAugmentingInterceptor(f ContextAugmenter) grpc.UnaryClientInterceptor

+ func UnaryClientLimitingInterceptor(limiter ClientLimiter) grpc.UnaryClientInterceptor

+ func UnaryClientValidatingInterceptor(parentCtx context.Context, method string, req, reply interface{}, ...) error

+ func UnaryServerAgentMDInterceptor() grpc.UnaryServerInterceptor

+ func UnaryServerCtxAugmentingInterceptor(f ContextAugmenter) grpc.UnaryServerInterceptor

+ func UnaryServerLimitingInterceptor(limiter ServerLimiter) grpc.UnaryServerInterceptor

+ func UnaryServerLoggerInterceptor(log *zap.Logger) grpc.UnaryServerInterceptor

+ func ValuesMapToMeta(vals map[string]*prototool.Values) metadata.MD

+ type API interface

+ HandleProcessingError func(ctx context.Context, log *zap.Logger, msg string, err error)

+ HandleSendError func(log *zap.Logger, msg string, err error) error

+ type ClientLimiter interface

+ Wait func(context.Context) error

+ type ContextAugmenter func(context.Context) (context.Context, error)

+ func JoinContexts(aux context.Context) ContextAugmenter

+ type DialListener struct

+ func NewDialListener() *DialListener

+ func (l *DialListener) Accept() (net.Conn, error)

+ func (l *DialListener) Addr() net.Addr

+ func (l *DialListener) Close() error

+ func (l *DialListener) DialContext(ctx context.Context, addr string) (net.Conn, error)

+ type EOFCallback func() error

+ type HttpDo func(ctx context.Context, header *HttpRequest_Header, body io.Reader) (*http.Response, error)

+ type HttpRequest struct

+ Message isHttpRequest_Message

+ func (*HttpRequest) Descriptor() ([]byte, []int)

+ func (*HttpRequest) ProtoMessage()

+ func (m *HttpRequest) GetMessage() isHttpRequest_Message

+ func (m *HttpRequest) Validate() error

+ func (x *HttpRequest) GetData() *HttpRequest_Data

+ func (x *HttpRequest) GetHeader() *HttpRequest_Header

+ func (x *HttpRequest) GetTrailer() *HttpRequest_Trailer

+ func (x *HttpRequest) ProtoReflect() protoreflect.Message

+ func (x *HttpRequest) Reset()

+ func (x *HttpRequest) String() string

+ type HttpRequestValidationError struct

+ func (e HttpRequestValidationError) Cause() error

+ func (e HttpRequestValidationError) Error() string

+ func (e HttpRequestValidationError) ErrorName() string

+ func (e HttpRequestValidationError) Field() string

+ func (e HttpRequestValidationError) Key() bool

+ func (e HttpRequestValidationError) Reason() string

+ type HttpRequest_Data struct

+ Data []byte

+ func (*HttpRequest_Data) Descriptor() ([]byte, []int)

+ func (*HttpRequest_Data) ProtoMessage()

+ func (m *HttpRequest_Data) Validate() error

+ func (x *HttpRequest_Data) GetData() []byte

+ func (x *HttpRequest_Data) ProtoReflect() protoreflect.Message

+ func (x *HttpRequest_Data) Reset()

+ func (x *HttpRequest_Data) String() string

+ type HttpRequest_DataValidationError struct

+ func (e HttpRequest_DataValidationError) Cause() error

+ func (e HttpRequest_DataValidationError) Error() string

+ func (e HttpRequest_DataValidationError) ErrorName() string

+ func (e HttpRequest_DataValidationError) Field() string

+ func (e HttpRequest_DataValidationError) Key() bool

+ func (e HttpRequest_DataValidationError) Reason() string

+ type HttpRequest_Data_ struct

+ Data *HttpRequest_Data

+ type HttpRequest_Header struct

+ Extra *any.Any

+ Request *prototool.HttpRequest

+ func (*HttpRequest_Header) Descriptor() ([]byte, []int)

+ func (*HttpRequest_Header) ProtoMessage()

+ func (m *HttpRequest_Header) Validate() error

+ func (x *HttpRequest_Header) GetExtra() *any.Any

+ func (x *HttpRequest_Header) GetRequest() *prototool.HttpRequest

+ func (x *HttpRequest_Header) ProtoReflect() protoreflect.Message

+ func (x *HttpRequest_Header) Reset()

+ func (x *HttpRequest_Header) String() string

+ type HttpRequest_HeaderValidationError struct

+ func (e HttpRequest_HeaderValidationError) Cause() error

+ func (e HttpRequest_HeaderValidationError) Error() string

+ func (e HttpRequest_HeaderValidationError) ErrorName() string

+ func (e HttpRequest_HeaderValidationError) Field() string

+ func (e HttpRequest_HeaderValidationError) Key() bool

+ func (e HttpRequest_HeaderValidationError) Reason() string

+ type HttpRequest_Header_ struct

+ Header *HttpRequest_Header

+ type HttpRequest_Trailer struct

+ func (*HttpRequest_Trailer) Descriptor() ([]byte, []int)

+ func (*HttpRequest_Trailer) ProtoMessage()

+ func (m *HttpRequest_Trailer) Validate() error

+ func (x *HttpRequest_Trailer) ProtoReflect() protoreflect.Message

+ func (x *HttpRequest_Trailer) Reset()

+ func (x *HttpRequest_Trailer) String() string

+ type HttpRequest_TrailerValidationError struct

+ func (e HttpRequest_TrailerValidationError) Cause() error

+ func (e HttpRequest_TrailerValidationError) Error() string

+ func (e HttpRequest_TrailerValidationError) ErrorName() string

+ func (e HttpRequest_TrailerValidationError) Field() string

+ func (e HttpRequest_TrailerValidationError) Key() bool

+ func (e HttpRequest_TrailerValidationError) Reason() string

+ type HttpRequest_Trailer_ struct

+ Trailer *HttpRequest_Trailer

+ type HttpResponse struct

+ Message isHttpResponse_Message

+ func (*HttpResponse) Descriptor() ([]byte, []int)

+ func (*HttpResponse) ProtoMessage()

+ func (m *HttpResponse) GetMessage() isHttpResponse_Message

+ func (m *HttpResponse) Validate() error

+ func (x *HttpResponse) GetData() *HttpResponse_Data

+ func (x *HttpResponse) GetHeader() *HttpResponse_Header

+ func (x *HttpResponse) GetTrailer() *HttpResponse_Trailer

+ func (x *HttpResponse) ProtoReflect() protoreflect.Message

+ func (x *HttpResponse) Reset()

+ func (x *HttpResponse) String() string

+ type HttpResponseValidationError struct

+ func (e HttpResponseValidationError) Cause() error

+ func (e HttpResponseValidationError) Error() string

+ func (e HttpResponseValidationError) ErrorName() string

+ func (e HttpResponseValidationError) Field() string

+ func (e HttpResponseValidationError) Key() bool

+ func (e HttpResponseValidationError) Reason() string

+ type HttpResponse_Data struct

+ Data []byte

+ func (*HttpResponse_Data) Descriptor() ([]byte, []int)

+ func (*HttpResponse_Data) ProtoMessage()

+ func (m *HttpResponse_Data) Validate() error

+ func (x *HttpResponse_Data) GetData() []byte

+ func (x *HttpResponse_Data) ProtoReflect() protoreflect.Message

+ func (x *HttpResponse_Data) Reset()

+ func (x *HttpResponse_Data) String() string

+ type HttpResponse_DataValidationError struct

+ func (e HttpResponse_DataValidationError) Cause() error

+ func (e HttpResponse_DataValidationError) Error() string

+ func (e HttpResponse_DataValidationError) ErrorName() string

+ func (e HttpResponse_DataValidationError) Field() string

+ func (e HttpResponse_DataValidationError) Key() bool

+ func (e HttpResponse_DataValidationError) Reason() string

+ type HttpResponse_Data_ struct

+ Data *HttpResponse_Data

+ type HttpResponse_Header struct

+ Response *prototool.HttpResponse

+ func (*HttpResponse_Header) Descriptor() ([]byte, []int)

+ func (*HttpResponse_Header) ProtoMessage()

+ func (m *HttpResponse_Header) Validate() error

+ func (x *HttpResponse_Header) GetResponse() *prototool.HttpResponse

+ func (x *HttpResponse_Header) ProtoReflect() protoreflect.Message

+ func (x *HttpResponse_Header) Reset()

+ func (x *HttpResponse_Header) String() string

+ type HttpResponse_HeaderValidationError struct

+ func (e HttpResponse_HeaderValidationError) Cause() error

+ func (e HttpResponse_HeaderValidationError) Error() string

+ func (e HttpResponse_HeaderValidationError) ErrorName() string

+ func (e HttpResponse_HeaderValidationError) Field() string

+ func (e HttpResponse_HeaderValidationError) Key() bool

+ func (e HttpResponse_HeaderValidationError) Reason() string

+ type HttpResponse_Header_ struct

+ Header *HttpResponse_Header

+ type HttpResponse_Trailer struct

+ func (*HttpResponse_Trailer) Descriptor() ([]byte, []int)

+ func (*HttpResponse_Trailer) ProtoMessage()

+ func (m *HttpResponse_Trailer) Validate() error

+ func (x *HttpResponse_Trailer) ProtoReflect() protoreflect.Message

+ func (x *HttpResponse_Trailer) Reset()

+ func (x *HttpResponse_Trailer) String() string

+ type HttpResponse_TrailerValidationError struct

+ func (e HttpResponse_TrailerValidationError) Cause() error

+ func (e HttpResponse_TrailerValidationError) Error() string

+ func (e HttpResponse_TrailerValidationError) ErrorName() string

+ func (e HttpResponse_TrailerValidationError) Field() string

+ func (e HttpResponse_TrailerValidationError) Key() bool

+ func (e HttpResponse_TrailerValidationError) Reason() string

+ type HttpResponse_Trailer_ struct

+ Trailer *HttpResponse_Trailer

+ type InboundGrpcToOutboundHttp struct

+ func NewInboundGrpcToOutboundHttp(api API, httpDo HttpDo) *InboundGrpcToOutboundHttp

+ func (x *InboundGrpcToOutboundHttp) Pipe(server InboundGrpcToOutboundHttpStream) error

+ type InboundGrpcToOutboundHttpStream interface

+ Send func(*HttpResponse) error

+ type InvalidTransitionCallback func(from, to protoreflect.FieldNumber, allowed []protoreflect.FieldNumber, ...) error

+ type JWTAuther struct

+ func NewJWTAuther(secret []byte, opts ...jwt.ParserOption) *JWTAuther

+ func (a *JWTAuther) StreamServerInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func (a *JWTAuther) UnaryServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ type JwtCredentials struct

+ Audience string

+ Insecure bool

+ Issuer string

+ Secret []byte

+ func (c *JwtCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

+ func (c *JwtCredentials) RequireTransportSecurity() bool

+ type MessageCallback interface

+ type RawCodec struct

+ func (c RawCodec) Marshal(v interface{}) ([]byte, error)

+ func (c RawCodec) Name() string

+ func (c RawCodec) String() string

+ func (c RawCodec) Unmarshal(data []byte, v interface{}) error

+ type RawCodecWithProtoFallback struct

+ func (c RawCodecWithProtoFallback) Marshal(v interface{}) ([]byte, error)

+ func (c RawCodecWithProtoFallback) Name() string

+ func (c RawCodecWithProtoFallback) String() string

+ func (c RawCodecWithProtoFallback) Unmarshal(data []byte, v interface{}) error

+ type RawFrame struct

+ Data []byte

+ type ServerLimiter interface

+ Allow func(ctx context.Context) bool

+ type Stream interface

+ RecvMsg func(m interface{}) error

+ type StreamVisitor struct

+ func NewStreamVisitor(streamMessage proto.Message) (*StreamVisitor, error)

+ func (s *StreamVisitor) Visit(stream Stream, opts ...StreamVisitorOption) error

+ type StreamVisitorOption func(*config) error

+ func WithCallback(transitionTo protoreflect.FieldNumber, cb MessageCallback) StreamVisitorOption

+ func WithEOFCallback(cb EOFCallback) StreamVisitorOption

+ func WithInvalidTransitionCallback(cb InvalidTransitionCallback) StreamVisitorOption

+ func WithStartState(startState protoreflect.FieldNumber) StreamVisitorOption

Other modules containing this package

gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v15

gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16

gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v17

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL