tchannel

package module

Go to main page

Versions in this module

v1

v1.34.5

Oct 9, 2024

v1.34.4

May 2, 2024

v1.34.3

Apr 24, 2024

v1.34.2

Feb 16, 2024

v1.34.1

Dec 11, 2023

v1.34.0

Oct 13, 2023

v1.33.0

Mar 20, 2023

Changes in this version

type ConnectionOptions

+ PropagateCancel bool

+ SendCancelOnContextCanceled bool

v1.32.1

Aug 23, 2022

v1.32.0

Jul 12, 2022

Changes in this version

type InboundCall

+ func (call *InboundCall) Connection() net.Conn

v1.31.0

Apr 12, 2022

v1.22.3

Mar 28, 2022

Changes in this version

+ type CheckedFramePoolForTest struct

+ func NewCheckedFramePoolForTest() *CheckedFramePoolForTest

+ func (p *CheckedFramePoolForTest) CheckEmpty() CheckedFramePoolForTestResult

+ func (p *CheckedFramePoolForTest) Get() *Frame

+ func (p *CheckedFramePoolForTest) Release(f *Frame)

+ type CheckedFramePoolForTestResult struct

+ BadReleases []string

+ Unreleased []string

+ func (r CheckedFramePoolForTestResult) HasIssues() bool

v1.22.2

Nov 10, 2021

v1.22.1

Oct 26, 2021

v1.22.0

Aug 17, 2021

Changes in this version

type ChannelOptions

+ SkipHandlerMethods []string

type FrameHeader

+ func (fh FrameHeader) MessageType() byte

type RelayCall

+ CallResponse func(relay.RespFrame)

v1.21.2

May 20, 2021

v1.21.1

Mar 17, 2021

v1.21.0

Dec 14, 2020

Changes in this version

type ChannelOptions

+ RelayMaxTombs uint64

v1.20.1

Sep 24, 2020

Changes in this version

type ChannelOptions

+ ConnContext func(ctx context.Context, conn net.Conn) context.Context

v1.20.0

Sep 19, 2020

Changes in this version

type ConnectionOptions

+ ConnContext func(ctx context.Context, conn net.Conn) context.Context

type ContextBuilder

+ ConnectBaseContext context.Context

+ func (cb *ContextBuilder) SetConnectBaseContext(ctx context.Context) *ContextBuilder

v1.19.1

Aug 4, 2020

Changes in this version

type RelayCall

+ ReceivedBytes func(uint16)

+ SentBytes func(uint16)

v1.19.0

May 22, 2020

Changes in this version

type ChannelOptions

+ RelayMaxConnectionTimeout time.Duration

type RelayerRuntimeState

+ MaxConnectionTimeout time.Duration

v1.18.0

Mar 30, 2020

Changes in this version

+ const DefaultConnectionBufferSize

type ConnectionOptions

+ SendBufferSizeOverrides []SendBufferSizeOverride

type ConnectionRuntimeState

+ LastActivityRead int64

+ LastActivityWrite int64

+ SendBufferSize int

+ SendBufferUsage int

+ SendChCapacity int

+ SendChQueued int

+ type SendBufferSizeOverride struct

+ ProcessNamePrefix string

+ SendBufferSize int

v1.17.0

Feb 20, 2020

v1.16.0

Oct 14, 2019

Changes in this version

type ChannelOptions

+ Dialer func(ctx context.Context, network, hostPort string) (net.Conn, error)

v1.15.0

Aug 27, 2019

v1.14.0

May 20, 2019

Changes in this version

type CallOptions

+ CallerName string

v1.13.0

Apr 4, 2019

Changes in this version

type ConnectionOptions

+ MaxCloseTime time.Duration

v1.12.0

Nov 14, 2018

Changes in this version

type Channel

+ func (ch *Channel) ClosedChan() <-chan struct{}

v1.11.0

Jun 25, 2018

v1.10.0

Apr 2, 2018

Changes in this version

type ChannelOptions

+ RelayTimerVerification bool

type InboundCallResponse

+ func (response *InboundCallResponse) Blackhole()

type RuntimeState

+ ChannelState string

+ InactiveConnections []ConnectionRuntimeState

v1.9.0

Feb 1, 2018

Changes in this version

type ChannelOptions

+ IdleCheckInterval time.Duration

+ MaxIdleTime time.Duration

type ConnectionRuntimeState

+ LastActivity int64

v1.8.1

Nov 22, 2017

v1.8.0

Nov 7, 2017

Changes in this version

type ChannelOptions

+ TimeTicker func(d time.Duration) *time.Ticker

type ConnectionOptions

+ HealthChecks HealthCheckOptions

type ConnectionRuntimeState

+ HealthChecks []bool

type Frame

+ func (f *Frame) ReadBody(header []byte, r io.Reader) error

+ type HealthCheckOptions struct

+ FailuresToClose int

+ Interval time.Duration

+ Timeout time.Duration

v1.7.0

Aug 4, 2017

Changes in this version

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

v1.6.0

Jun 2, 2017

Changes in this version

type ConnectionOptions

+ TosPriority tos.ToS

v1.5.0

Mar 21, 2017

Changes in this version

+ var ErrNoNewPeers = errors.New("no new peer available")

type PeerList

+ func (l *PeerList) GetNew(prevSelected map[string]struct{}) (*Peer, error)

+ func (l *PeerList) Len() int

v1.4.0

Mar 1, 2017

Changes in this version

type ChannelOptions

+ Handler Handler

v1.3.0

Feb 2, 2017

Changes in this version

type Channel

+ func (ch *Channel) RootPeers() *RootPeerList

type ChannelOptions

+ OnPeerStatusChanged func(*Peer)

v1.2.3

Jan 20, 2017

Changes in this version

type PeerInfo

+ Version PeerVersion

+ type PeerVersion struct

+ Language string

+ LanguageVersion string

+ TChannelVersion string

v1.2.2

Dec 21, 2016

Changes in this version

type Channel

+ func (ch *Channel) RelayHost() RelayHost

type ChannelInfo

+ ID uint32

type ChannelOptions

+ RelayHost RelayHost

+ RelayMaxTimeout time.Duration

type ConnectionRuntimeState

+ RemotePeer PeerInfo

type ContextWithHeaders

+ func Wrap(ctx context.Context) ContextWithHeaders

+ Child func() ContextWithHeaders

type InboundCall

+ func (call *InboundCall) LocalPeer() LocalPeerInfo

type IncomingCall

+ LocalPeer func() LocalPeerInfo

type OutboundCall

+ func (call *OutboundCall) LocalPeer() LocalPeerInfo

+ type RelayCall interface

+ Destination func() (peer *Peer, ok bool)

+ End func()

+ Failed func(reason string)

+ Succeeded func()

+ type RelayHost interface

+ SetChannel func(ch *Channel)

+ Start func(relay.CallFrame, relay.Conn) (RelayCall, error)

type RelayerRuntimeState

+ MaxTimeout time.Duration

type RuntimeState

+ ID uint32

v1.2.1

Sep 30, 2016

v1.2.0

Sep 15, 2016

Changes in this version

type CallOptions

+ RoutingKey string

type ContextBuilder

+ func (cb *ContextBuilder) SetRoutingKey(rk string) *ContextBuilder

type InboundCall

+ func (call *InboundCall) RoutingKey() string

type IncomingCall

+ RoutingKey func() string

type TransportHeaderName

+ const RoutingKey

v1.1.0

Aug 25, 2016

Changes in this version

+ func ExtractInboundSpan(ctx context.Context, call *InboundCall, headers map[string]string, ...) context.Context

+ func InjectOutboundSpan(response *OutboundCallResponse, headers map[string]string) map[string]string

+ func TracerFromRegistrar(registrar Registrar) opentracing.Tracer

type Channel

+ func (ccc Channel) Tracer() opentracing.Tracer

type ChannelOptions

+ RelayLocalHandlers []string

+ Tracer opentracing.Tracer

type Connection

+ func (ccc Connection) Tracer() opentracing.Tracer

type ConnectionOptions

+ CheckedProcessPrefixes []string

type IntrospectionOptions

+ IncludeOtherChannels bool

type Span

+ func (s Span) Flags() byte

type SubChannel

+ func (c *SubChannel) Tracer() opentracing.Tracer

v1.0.9

Jul 21, 2016

Changes in this version

type Channel

+ func (ch *Channel) IntrospectNumConnections() int

type ConnectionRuntimeState

+ OutboundHostPort string

type RuntimeState

+ RuntimeVersion RuntimeVersion

+ type RuntimeVersion struct

+ GoVersion string

+ LibraryVersion string

v1.0.8

Jul 16, 2016

Changes in this version

type Channel

+ func (ch *Channel) RelayHosts() relay.Hosts

type ChannelOptions

+ RelayHosts relay.Hosts

+ RelayStats relay.Stats

type ConnectionRuntimeState

+ Relayer RelayerRuntimeState

type ContextBuilder

+ ConnectTimeout time.Duration

+ func (cb *ContextBuilder) HideListeningOnOutbound() *ContextBuilder

+ func (cb *ContextBuilder) SetConnectTimeout(d time.Duration) *ContextBuilder

type InboundCall

+ func (call *InboundCall) CallOptions() *CallOptions

type IncomingCall

+ CallOptions func() *CallOptions

type IntrospectionOptions

+ IncludeTombstones bool

type OutboundCall

+ func (call *OutboundCall) RemotePeer() PeerInfo

+ type RelayItemSetState struct

+ Count int

+ Items map[string]RelayItemState

+ Name string

+ type RelayItemState struct

+ DestinationConnectionID uint32

+ ID uint32

+ RemapID uint32

+ Tomb bool

+ type Relayer struct

+ func NewRelayer(ch *Channel, conn *Connection) *Relayer

+ func (r *Relayer) Hosts() relay.Hosts

+ func (r *Relayer) IntrospectState(opts *IntrospectionOptions) RelayerRuntimeState

+ func (r *Relayer) Receive(f *Frame, fType frameType)

+ func (r *Relayer) Relay(f *Frame) error

+ type RelayerRuntimeState struct

+ Count int

+ InboundItems RelayItemSetState

+ OutboundItems RelayItemSetState

type RuntimeState

+ Connections []uint32

type SubChannel

+ func (c *SubChannel) GetHandlers() map[string]Handler

type SystemErrCode

+ func (c SystemErrCode) MetricsKey() string

v1.0.6

Jun 16, 2016

v1.0.6-dev

Apr 6, 2016

v1.0.5

Apr 4, 2016

Changes in this version

type ContextBuilder

+ ParentContext context.Context

+ func (cb *ContextBuilder) SetExternalSpan(traceID, spanID, parentID uint64, traced bool) *ContextBuilder

+ func (cb *ContextBuilder) SetParentContext(ctx context.Context) *ContextBuilder

v1.0.4

Mar 10, 2016

Changes in this version

+ type HandlerRuntimeState struct

+ Methods []string

+ Type handlerType

type SubChannel

+ func (c *SubChannel) SetHandler(h Handler)

type SubChannelRuntimeState

+ Handler HandlerRuntimeState

v1.0.3

Feb 16, 2016

Changes in this version

type Channel

+ func (ch *Channel) IntrospectOthers(opts *IntrospectionOptions) map[string][]ChannelInfo

+ func (ch *Channel) ReportInfo(opts *IntrospectionOptions) ChannelInfo

+ type ChannelInfo struct

+ CreatedStack string

+ LocalPeer LocalPeerInfo

type RuntimeState

+ CreatedStack string

+ OtherChannels map[string][]ChannelInfo

v1.0.2

Jan 29, 2016

Changes in this version

+ const DefaultConnectTimeout

type CallOptions

+ RoutingDelegate string

type ContextBuilder

+ func (cb *ContextBuilder) SetRoutingDelegate(rd string) *ContextBuilder

type InboundCall

+ func (call *InboundCall) RoutingDelegate() string

type IncomingCall

+ RoutingDelegate func() string

type TransportHeaderName

+ const RoutingDelegate

v1.0.1

Jan 19, 2016

Changes in this version

+ var ErrPeerNotFound = errors.New("peer not found")

+ type ArgReadable interface

+ Arg2Reader func() (ArgReader, error)

+ Arg3Reader func() (ArgReader, error)

+ type ArgReader io.ReadCloser

+ type ArgWritable interface

+ Arg2Writer func() (ArgWriter, error)

+ Arg3Writer func() (ArgWriter, error)

+ type ErrorHandlerFunc func(ctx context.Context, call *InboundCall) error

+ func (f ErrorHandlerFunc) Handle(ctx context.Context, call *InboundCall)

type PeerList

+ func (l *PeerList) Remove(hostPort string) error

v1.0.0

Jan 10, 2016

Changes in this version

+ const AnnotationKeyClientReceive

+ const AnnotationKeyClientSend

+ const AnnotationKeyServerReceive

+ const AnnotationKeyServerSend

+ const CurrentProtocolVersion

+ const DefaultTraceSampleRate

+ const FrameHeaderSize

+ const InitParamHostPort

+ const InitParamProcessName

+ const InitParamTChannelLanguage

+ const InitParamTChannelLanguageVersion

+ const InitParamTChannelVersion

+ const MaxFramePayloadSize

+ const MaxFrameSize

+ const VersionInfo

+ var DefaultFramePool = NewSyncFramePool()

+ var DisabledFramePool = disabledFramePool

+ var ErrChannelClosed = NewSystemError(ErrCodeDeclined, "closed channel")

+ var ErrConnectionClosed = errors.New("connection is closed")

+ var ErrConnectionNotReady = errors.New("connection is not yet ready")

+ var ErrInvalidConnectionState = errors.New("connection is in an invalid state")

+ var ErrMethodTooLarge = NewSystemError(ErrCodeProtocol, "method too large")

+ var ErrNoPeers = errors.New("no peers available")

+ var ErrNoServiceName = errors.New("no service name provided")

+ var ErrRequestCancelled = NewSystemError(ErrCodeCancelled, "request cancelled")

+ var ErrSendBufferFull = errors.New("connection send buffer is full, cannot send frame")

+ var ErrServerBusy = NewSystemError(ErrCodeBusy, "server busy")

+ var ErrTimeout = NewSystemError(ErrCodeTimeout, "timeout")

+ var ErrTimeoutRequired = NewSystemError(ErrCodeBadRequest, "timeout required")

+ var SimpleLogger = NewLogger(os.Stdout)

+ func GetContextError(err error) error

+ func GetSystemErrorMessage(err error) string

+ func Isolated(s *SubChannel)

+ func ListenIP() (net.IP, error)

+ func NewContext(timeout time.Duration) (context.Context, context.CancelFunc)

+ func NewRand(seed int64) *rand.Rand

+ func NewSystemError(code SystemErrCode, msg string, args ...interface{}) error

+ func NewWrappedSystemError(code SystemErrCode, wrapped error) error

+ func WrapContextForTest(ctx context.Context, call IncomingCall) context.Context

+ type Annotation struct

+ Key AnnotationKey

+ Timestamp time.Time

+ type AnnotationKey string

+ type Annotations struct

+ func (as *Annotations) AddAnnotationAt(key AnnotationKey, ts time.Time)

+ func (as *Annotations) AddBinaryAnnotation(key string, value interface{})

+ func (as *Annotations) GetTime() time.Time

+ func (as *Annotations) Report()

+ func (as *Annotations) SetMethod(method string)

+ type ArgReadHelper struct

+ func NewArgReader(reader io.ReadCloser, err error) ArgReadHelper

+ func (r ArgReadHelper) Read(bs *[]byte) error

+ func (r ArgReadHelper) ReadJSON(data interface{}) error

+ type ArgWriteHelper struct

+ func NewArgWriter(writer io.WriteCloser, err error) ArgWriteHelper

+ func (w ArgWriteHelper) Write(bs []byte) error

+ func (w ArgWriteHelper) WriteJSON(data interface{}) error

+ type ArgWriter interface

+ Flush func() error

+ type BinaryAnnotation struct

+ Key string

+ Value interface{}

+ type CallOptions struct

+ Format Format

+ RequestState *RequestState

+ ShardKey string

+ type Channel struct

+ func NewChannel(serviceName string, opts *ChannelOptions) (*Channel, error)

+ func (ch *Channel) BeginCall(ctx context.Context, hostPort, serviceName, methodName string, ...) (*OutboundCall, error)

+ func (ch *Channel) Close()

+ func (ch *Channel) Closed() bool

+ func (ch *Channel) Connect(ctx context.Context, hostPort string) (*Connection, error)

+ func (ch *Channel) ConnectionOptions() *ConnectionOptions

+ func (ch *Channel) GetSubChannel(serviceName string, opts ...SubChannelOption) *SubChannel

+ func (ch *Channel) IntrospectState(opts *IntrospectionOptions) *RuntimeState

+ func (ch *Channel) ListenAndServe(hostPort string) error

+ func (ch *Channel) Logger() Logger

+ func (ch *Channel) PeerInfo() LocalPeerInfo

+ func (ch *Channel) Peers() *PeerList

+ func (ch *Channel) Ping(ctx context.Context, hostPort string) error

+ func (ch *Channel) Register(h Handler, methodName string)

+ func (ch *Channel) RunWithRetry(ctx context.Context, f RetriableFunc) error

+ func (ch *Channel) Serve(l net.Listener) error

+ func (ch *Channel) ServiceName() string

+ func (ch *Channel) State() ChannelState

+ func (ch *Channel) StatsReporter() StatsReporter

+ func (ch *Channel) StatsTags() map[string]string

+ func (ch *Channel) TraceReporter() TraceReporter

+ type ChannelOptions struct

+ DefaultConnectionOptions ConnectionOptions

+ Logger Logger

+ ProcessName string

+ StatsReporter StatsReporter

+ TimeNow func() time.Time

+ TraceReporter TraceReporter

+ TraceReporterFactory TraceReporterFactory

+ TraceSampleRate *float64

+ type ChannelState int

+ const ChannelClient

+ const ChannelClosed

+ const ChannelInboundClosed

+ const ChannelListening

+ const ChannelStartClose

+ func (i ChannelState) String() string

+ type Checksum interface

+ Add func(b []byte) []byte

+ Release func()

+ Reset func()

+ Size func() int

+ Sum func() []byte

+ TypeCode func() ChecksumType

+ type ChecksumType byte

+ const ChecksumTypeCrc32

+ const ChecksumTypeCrc32C

+ const ChecksumTypeFarmhash

+ const ChecksumTypeNone

+ func (t ChecksumType) ChecksumSize() int

+ func (t ChecksumType) New() Checksum

+ func (t ChecksumType) Release(checksum Checksum)

+ type Connectable interface

+ Connect func(ctx context.Context, hostPort string) (*Connection, error)

+ Logger func() Logger

+ type Connection struct

+ func (c *Connection) Close() error

+ func (c *Connection) IntrospectState(opts *IntrospectionOptions) ConnectionRuntimeState

+ func (c *Connection) IsActive() bool

+ func (c *Connection) NextMessageID() uint32

+ func (c *Connection) RemotePeerInfo() PeerInfo

+ func (c *Connection) SendSystemError(id uint32, span *Span, err error) error

+ type ConnectionOptions struct

+ ChecksumType ChecksumType

+ FramePool FramePool

+ RecvBufferSize int

+ SendBufferSize int

+ type ConnectionRuntimeState struct

+ ConnectionState string

+ ID uint32

+ InboundExchange ExchangeSetRuntimeState

+ IsEphemeral bool

+ LocalHostPort string

+ OutboundExchange ExchangeSetRuntimeState

+ RemoteHostPort string

+ type ContextBuilder struct

+ CallOptions *CallOptions

+ Headers map[string]string

+ RetryOptions *RetryOptions

+ Timeout time.Duration

+ TracingDisabled bool

+ func NewContextBuilder(timeout time.Duration) *ContextBuilder

+ func (cb *ContextBuilder) AddHeader(key, value string) *ContextBuilder

+ func (cb *ContextBuilder) Build() (ContextWithHeaders, context.CancelFunc)

+ func (cb *ContextBuilder) DisableTracing() *ContextBuilder

+ func (cb *ContextBuilder) SetFormat(f Format) *ContextBuilder

+ func (cb *ContextBuilder) SetHeaders(headers map[string]string) *ContextBuilder

+ func (cb *ContextBuilder) SetIncomingCallForTest(call IncomingCall) *ContextBuilder

+ func (cb *ContextBuilder) SetRetryOptions(retryOptions *RetryOptions) *ContextBuilder

+ func (cb *ContextBuilder) SetShardKey(sk string) *ContextBuilder

+ func (cb *ContextBuilder) SetSpanForTest(span *Span) *ContextBuilder

+ func (cb *ContextBuilder) SetTimeout(timeout time.Duration) *ContextBuilder

+ func (cb *ContextBuilder) SetTimeoutPerAttempt(timeoutPerAttempt time.Duration) *ContextBuilder

+ type ContextWithHeaders interface

+ Headers func() map[string]string

+ ResponseHeaders func() map[string]string

+ SetResponseHeaders func(map[string]string)

+ func WrapWithHeaders(ctx context.Context, headers map[string]string) ContextWithHeaders

+ type ExchangeRuntimeState struct

+ ID uint32

+ MessageType messageType

+ type ExchangeSetRuntimeState struct

+ Count int

+ Exchanges []ExchangeRuntimeState

+ Name string

+ type Format string

+ const HTTP

+ const JSON

+ const Raw

+ const Thrift

+ func (f Format) String() string

+ type Frame struct

+ Header FrameHeader

+ Payload []byte

+ func NewFrame(payloadCapacity int) *Frame

+ func (f *Frame) ReadIn(r io.Reader) error

+ func (f *Frame) SizedPayload() []byte

+ func (f *Frame) WriteOut(w io.Writer) error

+ type FrameHeader struct

+ ID uint32

+ func (fh *FrameHeader) SetPayloadSize(size uint16)

+ func (fh FrameHeader) FrameSize() uint16

+ func (fh FrameHeader) MarshalJSON() ([]byte, error)

+ func (fh FrameHeader) PayloadSize() uint16

+ func (fh FrameHeader) String() string

+ type FramePool interface

+ Get func() *Frame

+ Release func(f *Frame)

+ func NewChannelFramePool(capacity int) FramePool

+ func NewSyncFramePool() FramePool

+ type GoRuntimeState struct

+ GoStacks []byte

+ MemStats runtime.MemStats

+ NumCGo int64

+ NumCPU int

+ NumGoroutines int

+ type GoRuntimeStateOptions struct

+ IncludeGoStacks bool

+ type Handler interface

+ Handle func(ctx context.Context, call *InboundCall)

+ type HandlerFunc func(ctx context.Context, call *InboundCall)

+ func (f HandlerFunc) Handle(ctx context.Context, call *InboundCall)

+ type InboundCall struct

+ func (call *InboundCall) Arg2Reader() (io.ReadCloser, error)

+ func (call *InboundCall) Arg3Reader() (io.ReadCloser, error)

+ func (call *InboundCall) CallerName() string

+ func (call *InboundCall) Format() Format

+ func (call *InboundCall) Method() []byte

+ func (call *InboundCall) MethodString() string

+ func (call *InboundCall) RemotePeer() PeerInfo

+ func (call *InboundCall) Response() *InboundCallResponse

+ func (call *InboundCall) ServiceName() string

+ func (call *InboundCall) ShardKey() string

+ type InboundCallResponse struct

+ func (response *InboundCallResponse) Arg2Writer() (ArgWriter, error)

+ func (response *InboundCallResponse) Arg3Writer() (ArgWriter, error)

+ func (response *InboundCallResponse) SendSystemError(err error) error

+ func (response *InboundCallResponse) SetApplicationError() error

+ type IncomingCall interface

+ CallerName func() string

+ RemotePeer func() PeerInfo

+ ShardKey func() string

+ func CurrentCall(ctx context.Context) IncomingCall

+ type IntrospectionOptions struct

+ IncludeEmptyPeers bool

+ IncludeExchanges bool

+ type LocalPeerInfo struct

+ ServiceName string

+ func (p LocalPeerInfo) String() string

+ type LogField struct

+ Key string

+ Value interface{}

+ func ErrField(err error) LogField

+ type LogFields []LogField

+ type LogLevel int

+ const LogLevelAll

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelWarn

+ type Logger interface

+ Debug func(msg string)

+ Debugf func(msg string, args ...interface{})

+ Enabled func(level LogLevel) bool

+ Error func(msg string)

+ Fatal func(msg string)

+ Fields func() LogFields

+ Info func(msg string)

+ Infof func(msg string, args ...interface{})

+ Warn func(msg string)

+ WithFields func(fields ...LogField) Logger

+ var NullLogger Logger = nullLogger{}

+ func NewLevelLogger(logger Logger, level LogLevel) Logger

+ func NewLogger(writer io.Writer, fields ...LogField) Logger

+ type OutboundCall struct

+ func (call *OutboundCall) Arg2Writer() (ArgWriter, error)

+ func (call *OutboundCall) Arg3Writer() (ArgWriter, error)

+ func (call *OutboundCall) Response() *OutboundCallResponse

+ type OutboundCallResponse struct

+ func (response *OutboundCallResponse) ApplicationError() bool

+ func (response *OutboundCallResponse) Arg2Reader() (io.ReadCloser, error)

+ func (response *OutboundCallResponse) Arg3Reader() (io.ReadCloser, error)

+ func (response *OutboundCallResponse) Format() Format

+ type Peer struct

+ func (p *Peer) AddInboundConnection(c *Connection) error

+ func (p *Peer) AddOutboundConnection(c *Connection) error

+ func (p *Peer) BeginCall(ctx context.Context, serviceName, methodName string, callOptions *CallOptions) (*OutboundCall, error)

+ func (p *Peer) Connect(ctx context.Context) (*Connection, error)

+ func (p *Peer) GetConnection(ctx context.Context) (*Connection, error)

+ func (p *Peer) HostPort() string

+ func (p *Peer) IntrospectState(opts *IntrospectionOptions) PeerRuntimeState

+ func (p *Peer) NumConnections() (inbound int, outbound int)

+ func (p *Peer) NumPendingOutbound() int

+ type PeerHeap struct

+ PeerScores []*peerScore

+ func (ph *PeerHeap) Less(i, j int) bool

+ func (ph *PeerHeap) Pop() interface{}

+ func (ph *PeerHeap) PopPeer() *peerScore

+ func (ph *PeerHeap) Push(x interface{})

+ func (ph *PeerHeap) PushPeer(peerScore *peerScore)

+ func (ph *PeerHeap) RemovePeer(peerScore *peerScore)

+ func (ph *PeerHeap) UpdatePeer(peerScore *peerScore)

+ func (ph PeerHeap) Len() int

+ func (ph PeerHeap) Swap(i, j int)

+ type PeerInfo struct

+ HostPort string

+ IsEphemeral bool

+ ProcessName string

+ func (p PeerInfo) IsEphemeralHostPort() bool

+ func (p PeerInfo) String() string

+ type PeerList struct

+ func (l *PeerList) Add(hostPort string) *Peer

+ func (l *PeerList) Copy() map[string]*Peer

+ func (l *PeerList) Get(prevSelected map[string]struct{}) (*Peer, error)

+ func (l *PeerList) GetOrAdd(hostPort string) *Peer

+ func (l *PeerList) IntrospectList(opts *IntrospectionOptions) []SubPeerScore

+ func (l *PeerList) IntrospectState(opts *IntrospectionOptions) map[string]PeerRuntimeState

+ func (l *PeerList) SetStrategy(sc ScoreCalculator)

+ func (l *PeerList) UpdatePeer(p *Peer)

+ type PeerRuntimeState struct

+ ChosenCount uint64

+ HostPort string

+ InboundConnections []ConnectionRuntimeState

+ OutboundConnections []ConnectionRuntimeState

+ SCCount uint32

+ type Registrar interface

+ Logger func() Logger

+ Peers func() *PeerList

+ Register func(h Handler, methodName string)

+ ServiceName func() string

+ StatsReporter func() StatsReporter

+ StatsTags func() map[string]string

+ type RequestState struct

+ Attempt int

+ SelectedPeers map[string]struct{}

+ Start time.Time

+ func (rs *RequestState) AddSelectedPeer(hostPort string)

+ func (rs *RequestState) HasRetries(err error) bool

+ func (rs *RequestState) PrevSelectedPeers() map[string]struct{}

+ func (rs *RequestState) RetryCount() int

+ func (rs *RequestState) SinceStart(now time.Time, fallback time.Duration) time.Duration

+ type ResponseCode byte

+ type RetriableFunc func(context.Context, *RequestState) error

+ type RetryOn int

+ const RetryConnectionError

+ const RetryDefault

+ const RetryIdempotent

+ const RetryNever

+ const RetryNonIdempotent

+ const RetryUnexpected

+ func (i RetryOn) String() string

+ func (r RetryOn) CanRetry(err error) bool

+ type RetryOptions struct

+ MaxAttempts int

+ RetryOn RetryOn

+ TimeoutPerAttempt time.Duration

+ type RootPeerList struct

+ func (l *RootPeerList) Add(hostPort string) *Peer

+ func (l *RootPeerList) Copy() map[string]*Peer

+ func (l *RootPeerList) Get(hostPort string) (*Peer, bool)

+ func (l *RootPeerList) GetOrAdd(hostPort string) *Peer

+ func (l *RootPeerList) IntrospectState(opts *IntrospectionOptions) map[string]PeerRuntimeState

+ type RuntimeState struct

+ LocalPeer LocalPeerInfo

+ NumConnections int

+ Peers []SubPeerScore

+ RootPeers map[string]PeerRuntimeState

+ SubChannels map[string]SubChannelRuntimeState

+ type ScoreCalculator interface

+ GetScore func(p *Peer) uint64

+ type ScoreCalculatorFunc func(p *Peer) uint64

+ func (f ScoreCalculatorFunc) GetScore(p *Peer) uint64

+ type Span struct

+ func CurrentSpan(ctx context.Context) *Span

+ func NewRootSpan() *Span

+ func (s *Span) EnableTracing(enabled bool)

+ func (s Span) NewChildSpan() *Span

+ func (s Span) ParentID() uint64

+ func (s Span) SpanID() uint64

+ func (s Span) String() string

+ func (s Span) TraceID() uint64

+ func (s Span) TracingEnabled() bool

+ type StatsReporter interface

+ IncCounter func(name string, tags map[string]string, value int64)

+ RecordTimer func(name string, tags map[string]string, d time.Duration)

+ UpdateGauge func(name string, tags map[string]string, value int64)

+ var NullStatsReporter StatsReporter = nullStatsReporter{}

+ var SimpleStatsReporter StatsReporter = simpleStatsReporter{}

+ type SubChannel struct

+ func (c *SubChannel) BeginCall(ctx context.Context, methodName string, callOptions *CallOptions) (*OutboundCall, error)

+ func (c *SubChannel) Isolated() bool

+ func (c *SubChannel) Logger() Logger

+ func (c *SubChannel) Peers() *PeerList

+ func (c *SubChannel) Register(h Handler, methodName string)

+ func (c *SubChannel) ServiceName() string

+ func (c *SubChannel) StatsReporter() StatsReporter

+ func (c *SubChannel) StatsTags() map[string]string

+ type SubChannelOption func(*SubChannel)

+ type SubChannelRuntimeState struct

+ Isolated bool

+ IsolatedPeers []SubPeerScore

+ Service string

+ type SubPeerScore struct

+ HostPort string

+ Score uint64

+ type SystemErrCode byte

+ const ErrCodeBadRequest

+ const ErrCodeBusy

+ const ErrCodeCancelled

+ const ErrCodeDeclined

+ const ErrCodeInvalid

+ const ErrCodeNetwork

+ const ErrCodeProtocol

+ const ErrCodeTimeout

+ const ErrCodeUnexpected

+ func GetSystemErrorCode(err error) SystemErrCode

+ func (i SystemErrCode) String() string

+ type SystemError struct

+ func (se SystemError) Code() SystemErrCode

+ func (se SystemError) Error() string

+ func (se SystemError) Message() string

+ func (se SystemError) Wrapped() error

+ type TraceData struct

+ Annotations []Annotation

+ BinaryAnnotations []BinaryAnnotation

+ Method string

+ Source TraceEndpoint

+ Span Span

+ Target TraceEndpoint

+ type TraceEndpoint struct

+ HostPort string

+ ServiceName string

+ type TraceReporter interface

+ Report func(data TraceData)

+ var NullReporter TraceReporter = nullReporter{}

+ var SimpleTraceReporter TraceReporter = simpleTraceReporter{}

+ type TraceReporterFactory func(*Channel) TraceReporter

+ type TraceReporterFunc func(TraceData)

+ func (f TraceReporterFunc) Report(data TraceData)

+ type TransportHeaderName string

+ const ArgScheme

+ const CallerName

+ const ClaimAtFinish

+ const ClaimAtStart

+ const FailureDomain

+ const RetryFlags

+ const ShardKey

+ const SpeculativeExecution

+ func (cn TransportHeaderName) String() string

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