transport

Documentation

Index

• Constants
• func InitStatistics(app int)
• func NewRequester(session *spdy.MultiplexedSession, typ uint8, seq uint64, codec Codec) spdy.Requester
• func NewResponser(session *spdy.MultiplexedSession, typ uint8, seq uint64) spdy.Responser
• type Callback
• type Codec
  • func ConvertToCodec(i interface{}) (Codec, error)
• type EventHandler
  • func NewEventHandler(session *spdy.MultiplexedSession, typ uint8, handler Handler, codec Codec) *EventHandler
  • func (eh *EventHandler) CreateRequester(seq uint64) (spdy.Requester, error)
  • func (eh *EventHandler) Handle(r spdy.Requester, w spdy.Responser) error
• type EventHandlerFactory
  • func NewEventHandlerFactory(typ uint8, handler Handler, codec Codec) EventHandlerFactory
  • func (f EventHandlerFactory) CreateEventHandler(session *spdy.MultiplexedSession) spdy.EventHandler
  • func (f EventHandlerFactory) EventHandlerType() uint8
• type Handler
• type Node
  • func (n *Node) Close()
  • func (n *Node) GetPool() *spdy.MultiplexedSessionPool
• type NodeManager
  • func NewMetaNodeManager() *NodeManager
  • func NewNodeManager() *NodeManager
  • func NewWriteNodeManager() *NodeManager
  • func (m *NodeManager) Add(nodeID uint64, address string)
  • func (m *NodeManager) Clear()
  • func (m *NodeManager) Get(nodeID uint64) *Node
  • func (m *NodeManager) SetJob(job *statistics.SpdyJob)
• type Requester
  • func (req *Requester) Data() interface{}
  • func (req *Requester) Decode(data []byte) (interface{}, error)
  • func (req *Requester) Encode(dst []byte, data interface{}) ([]byte, error)
  • func (req *Requester) SetData(data interface{})
  • func (req *Requester) Type() uint8
  • func (req *Requester) WarpResponser() spdy.Responser
• type Responser
  • func (rsp *Responser) Callback(data interface{}) error
  • func (rsp *Responser) Decode(data []byte) (interface{}, error)
  • func (rsp *Responser) Encode(dst []byte, data interface{}) ([]byte, error)
  • func (rsp *Responser) SetCallback(c Callback)
  • func (rsp *Responser) Type() uint8
• type Transport
  • func NewMetaTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)
  • func NewTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)
  • func NewTransportByAddress(nodeId uint64, address string, typ uint8, callback Callback) (*Transport, error)
  • func NewWriteTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)
  • func (s *Transport) EnableDataACK()
  • func (s *Transport) FinishAnalyze()
  • func (s *Transport) Requester() spdy.Requester
  • func (s *Transport) Send(data Codec) error
  • func (s *Transport) SetTimeout(timeout time.Duration)
  • func (s *Transport) StartAnalyze(span *tracing.Span)
  • func (s *Transport) Wait() error

Constants

const (
	AppSql = iota
	AppMeta
	AppStore
)

Functions

func InitStatistics

func InitStatistics(app int)

func NewRequester

func NewRequester(session *spdy.MultiplexedSession, typ uint8, seq uint64, codec Codec) spdy.Requester

func NewResponser

func NewResponser(session *spdy.MultiplexedSession, typ uint8, seq uint64) spdy.Responser

Types

type Callback

type Callback interface {
	Handle(interface{}) error
	GetCodec() Codec
}

type Codec

type Codec interface {
	Size() int
	Marshal([]byte) ([]byte, error)
	Unmarshal([]byte) error
	Instance() Codec
}

func ConvertToCodec

func ConvertToCodec(i interface{}) (Codec, error)

type EventHandler

type EventHandler struct {
	spdy.BaseEventHandler
	// contains filtered or unexported fields
}

func NewEventHandler

func NewEventHandler(session *spdy.MultiplexedSession, typ uint8, handler Handler, codec Codec) *EventHandler

func (*EventHandler) CreateRequester

func (eh *EventHandler) CreateRequester(seq uint64) (spdy.Requester, error)

func (*EventHandler) Handle

func (eh *EventHandler) Handle(r spdy.Requester, w spdy.Responser) error

type EventHandlerFactory

type EventHandlerFactory struct {
	// contains filtered or unexported fields
}

func NewEventHandlerFactory

func NewEventHandlerFactory(typ uint8, handler Handler, codec Codec) EventHandlerFactory

func (EventHandlerFactory) CreateEventHandler

func (f EventHandlerFactory) CreateEventHandler(session *spdy.MultiplexedSession) spdy.EventHandler

func (EventHandlerFactory) EventHandlerType

func (f EventHandlerFactory) EventHandlerType() uint8

type Handler

type Handler interface {
	Handle(spdy.Responser, interface{}) error
}

type Node

type Node struct {
	// contains filtered or unexported fields
}

func (*Node) Close

func (n *Node) Close()

func (*Node) GetPool

func (n *Node) GetPool() *spdy.MultiplexedSessionPool

type NodeManager

type NodeManager struct {
	// contains filtered or unexported fields
}

func NewMetaNodeManager

func NewMetaNodeManager() *NodeManager

NewMetaNodeManager Used for meta service

func NewNodeManager

func NewNodeManager() *NodeManager

NewNodeManager Used for Select and DDL

func NewWriteNodeManager

func NewWriteNodeManager() *NodeManager

NewWriteNodeManager Used for write requests

func (*NodeManager) Add

func (m *NodeManager) Add(nodeID uint64, address string)

func (*NodeManager) Clear

func (m *NodeManager) Clear()

func (*NodeManager) Get

func (m *NodeManager) Get(nodeID uint64) *Node

func (*NodeManager) SetJob

func (m *NodeManager) SetJob(job *statistics.SpdyJob)

type Requester

type Requester struct {
	spdy.BaseRequester
	// contains filtered or unexported fields
}

func (*Requester) Data

func (req *Requester) Data() interface{}

func (*Requester) Decode

func (req *Requester) Decode(data []byte) (interface{}, error)

func (*Requester) Encode

func (req *Requester) Encode(dst []byte, data interface{}) ([]byte, error)

func (*Requester) SetData

func (req *Requester) SetData(data interface{})

func (*Requester) Type

func (req *Requester) Type() uint8

func (*Requester) WarpResponser

func (req *Requester) WarpResponser() spdy.Responser

type Responser

type Responser struct {
	spdy.BaseResponser
	// contains filtered or unexported fields
}

func (*Responser) Callback

func (rsp *Responser) Callback(data interface{}) error

func (*Responser) Decode

func (rsp *Responser) Decode(data []byte) (interface{}, error)

func (*Responser) Encode

func (rsp *Responser) Encode(dst []byte, data interface{}) ([]byte, error)

func (*Responser) SetCallback

func (rsp *Responser) SetCallback(c Callback)

func (*Responser) Type

func (rsp *Responser) Type() uint8

type Transport

type Transport struct {
	// contains filtered or unexported fields
}

func NewMetaTransport

func NewMetaTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)

func NewTransport

func NewTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)

func NewTransportByAddress

func NewTransportByAddress(nodeId uint64, address string, typ uint8, callback Callback) (*Transport, error)

func NewWriteTransport

func NewWriteTransport(nodeId uint64, typ uint8, callback Callback) (*Transport, error)

func (*Transport) EnableDataACK

func (s *Transport) EnableDataACK()

func (*Transport) FinishAnalyze

func (s *Transport) FinishAnalyze()

func (*Transport) Requester

func (s *Transport) Requester() spdy.Requester

func (*Transport) Send

func (s *Transport) Send(data Codec) error

func (*Transport) SetTimeout

func (s *Transport) SetTimeout(timeout time.Duration)

func (*Transport) StartAnalyze

func (s *Transport) StartAnalyze(span *tracing.Span)

func (*Transport) Wait

func (s *Transport) Wait() error