tchannel

package module

Go to main page

Versions in this module

v1

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