Documentation ¶
Index ¶
- Constants
- Variables
- func TxFrameAddBody(builder *flatbuffers.Builder, body flatbuffers.UOffsetT)
- func TxFrameAddChannel(builder *flatbuffers.Builder, channel uint64)
- func TxFrameAddFlags(builder *flatbuffers.Builder, flags byte)
- func TxFrameAddFrametype(builder *flatbuffers.Builder, frametype int8)
- func TxFrameAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)
- func TxFrameAddStream(builder *flatbuffers.Builder, stream uint64)
- func TxFrameAddVersion(builder *flatbuffers.Builder, version int8)
- func TxFrameEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TxFrameStart(builder *flatbuffers.Builder)
- func TxFrameStartBodyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TxFrameStartHeadersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TxHeaderLineAddId(builder *flatbuffers.Builder, id uint16)
- func TxHeaderLineAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
- func TxHeaderLineAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
- func TxHeaderLineEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func TxHeaderLineStart(builder *flatbuffers.Builder)
- func TxHeaderLineStartKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func TxHeaderLineStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- type LogLevel
- type Logger
- func (g *Logger) Debug(m string)
- func (g *Logger) Debugf(m string, args ...interface{})
- func (g *Logger) Error(m string)
- func (g *Logger) Errorf(m string, args ...interface{})
- func (g *Logger) Fatal(m string)
- func (g *Logger) Fatalf(m string, args ...interface{})
- func (g *Logger) Info(m string)
- func (g *Logger) Infof(m string, args ...interface{})
- func (g *Logger) Warn(m string)
- func (g *Logger) Warnf(m string, args ...interface{})
- type Server
- type TxFrame
- func (rcv *TxFrame) Body(j int) byte
- func (rcv *TxFrame) BodyBytes() []byte
- func (rcv *TxFrame) BodyLength() int
- func (rcv *TxFrame) Channel() uint64
- func (rcv *TxFrame) Flags() byte
- func (rcv *TxFrame) Frametype() int8
- func (rcv *TxFrame) Headers(obj *TxHeaderLine, j int) bool
- func (rcv *TxFrame) HeadersLength() int
- func (rcv *TxFrame) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TxFrame) MutateChannel(n uint64) bool
- func (rcv *TxFrame) MutateFlags(n byte) bool
- func (rcv *TxFrame) MutateFrametype(n int8) bool
- func (rcv *TxFrame) MutateStream(n uint64) bool
- func (rcv *TxFrame) MutateVersion(n int8) bool
- func (rcv *TxFrame) Stream() uint64
- func (rcv *TxFrame) Version() int8
- type TxHeaderLine
- func (rcv *TxHeaderLine) Id() uint16
- func (rcv *TxHeaderLine) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *TxHeaderLine) Key(j int) byte
- func (rcv *TxHeaderLine) KeyBytes() []byte
- func (rcv *TxHeaderLine) KeyLength() int
- func (rcv *TxHeaderLine) MutateId(n uint16) bool
- func (rcv *TxHeaderLine) Value(j int) byte
- func (rcv *TxHeaderLine) ValueBytes() []byte
- func (rcv *TxHeaderLine) ValueLength() int
Constants ¶
View Source
const ( TxFrameTypeHeader = 0 TxFrameTypeBody = 1 TxFrameTypeAbort = 2 TxFrameTypePause = 3 TxFrameTypeResume = 4 )
View Source
const ( TxHttpVersionHttp10 = 0 TxHttpVersionHttp11 = 1 TxHttpVersionHttp2 = 2 )
View Source
const (
TxFrameFlagsFinal = 1
)
Variables ¶
View Source
var EnumNamesTxFrameFlags = map[int]string{ TxFrameFlagsFinal: "Final", }
View Source
var EnumNamesTxFrameType = map[int]string{ TxFrameTypeHeader: "Header", TxFrameTypeBody: "Body", TxFrameTypeAbort: "Abort", TxFrameTypePause: "Pause", TxFrameTypeResume: "Resume", }
View Source
var EnumNamesTxHttpVersion = map[int]string{ TxHttpVersionHttp10: "Http10", TxHttpVersionHttp11: "Http11", TxHttpVersionHttp2: "Http2", }
Functions ¶
func TxFrameAddBody ¶
func TxFrameAddBody(builder *flatbuffers.Builder, body flatbuffers.UOffsetT)
func TxFrameAddChannel ¶
func TxFrameAddChannel(builder *flatbuffers.Builder, channel uint64)
func TxFrameAddFlags ¶
func TxFrameAddFlags(builder *flatbuffers.Builder, flags byte)
func TxFrameAddFrametype ¶
func TxFrameAddFrametype(builder *flatbuffers.Builder, frametype int8)
func TxFrameAddHeaders ¶
func TxFrameAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)
func TxFrameAddStream ¶
func TxFrameAddStream(builder *flatbuffers.Builder, stream uint64)
func TxFrameAddVersion ¶
func TxFrameAddVersion(builder *flatbuffers.Builder, version int8)
func TxFrameEnd ¶
func TxFrameEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TxFrameStart ¶
func TxFrameStart(builder *flatbuffers.Builder)
func TxFrameStartBodyVector ¶
func TxFrameStartBodyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TxFrameStartHeadersVector ¶
func TxFrameStartHeadersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TxHeaderLineAddId ¶
func TxHeaderLineAddId(builder *flatbuffers.Builder, id uint16)
func TxHeaderLineAddKey ¶
func TxHeaderLineAddKey(builder *flatbuffers.Builder, key flatbuffers.UOffsetT)
func TxHeaderLineAddValue ¶
func TxHeaderLineAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)
func TxHeaderLineEnd ¶
func TxHeaderLineEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
func TxHeaderLineStart ¶
func TxHeaderLineStart(builder *flatbuffers.Builder)
func TxHeaderLineStartKeyVector ¶
func TxHeaderLineStartKeyVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
func TxHeaderLineStartValueVector ¶
func TxHeaderLineStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
Types ¶
type Server ¶
type Server struct { // If you already have an HTTP listener, then you can forward requests from there // to this Server, by calling Server.ServeHTTP(). In such a case, you'll want to // set DisableHttpListener to true. DisableHttpListener bool HttpPort string BackendPort string BackendTimeout time.Duration Log Logger // contains filtered or unexported fields }
HttpBridge Server
When Stop() is called, we try to stop sending all communication, to backends or clients. We assume that the closed TCP socket will be interpreted correctly by backends and clients. The alternative is to send an ABORT frame to backends, but that poses the risk of delaying shutdown time significantly, for no apparent gain.
func (*Server) AcceptBackendConnections ¶
func (*Server) ListenAndServe ¶
type TxFrame ¶
type TxFrame struct {
// contains filtered or unexported fields
}
func GetRootAsTxFrame ¶
func GetRootAsTxFrame(buf []byte, offset flatbuffers.UOffsetT) *TxFrame
func (*TxFrame) BodyLength ¶
func (*TxFrame) HeadersLength ¶
func (*TxFrame) MutateChannel ¶
func (*TxFrame) MutateFlags ¶
func (*TxFrame) MutateFrametype ¶
func (*TxFrame) MutateStream ¶
func (*TxFrame) MutateVersion ¶
type TxHeaderLine ¶
type TxHeaderLine struct {
// contains filtered or unexported fields
}
func GetRootAsTxHeaderLine ¶
func GetRootAsTxHeaderLine(buf []byte, offset flatbuffers.UOffsetT) *TxHeaderLine
func (*TxHeaderLine) Id ¶
func (rcv *TxHeaderLine) Id() uint16
func (*TxHeaderLine) Init ¶
func (rcv *TxHeaderLine) Init(buf []byte, i flatbuffers.UOffsetT)
func (*TxHeaderLine) Key ¶
func (rcv *TxHeaderLine) Key(j int) byte
func (*TxHeaderLine) KeyBytes ¶
func (rcv *TxHeaderLine) KeyBytes() []byte
func (*TxHeaderLine) KeyLength ¶
func (rcv *TxHeaderLine) KeyLength() int
func (*TxHeaderLine) MutateId ¶
func (rcv *TxHeaderLine) MutateId(n uint16) bool
func (*TxHeaderLine) Value ¶
func (rcv *TxHeaderLine) Value(j int) byte
func (*TxHeaderLine) ValueBytes ¶
func (rcv *TxHeaderLine) ValueBytes() []byte
func (*TxHeaderLine) ValueLength ¶
func (rcv *TxHeaderLine) ValueLength() int
Click to show internal directories.
Click to hide internal directories.