sync

Documentation

Index

• Constants
• func DealBlocks(seqs *types.BlockSeqs, d *store.SeqNum, seqNumStore store.SeqNumStore, ...) error
• type Receiver
  • func CreateReceiver(cfg *proto.ConfigNew, s SeqSaver) (Receiver, error)
  • func NewReceiver(p *pusher, pushBind string) (Receiver, error)
• type ReceiverConvert
  • func CreateReceiverConvert(cfg *proto.ConfigNew, EsWrite escli.ESClient) (ReceiverConvert, error)
• type SaveSeq
• type SeqSaver
• type SeqsProc
  • func NewSeqsProc(seqNumStore store.SeqNumStore, seqStore store.SeqStore, chain *proto.Chain33) (*SeqsProc, error)
  • func (p *SeqsProc) Proc(startSeq int64)
  • func (p *SeqsProc) Save(block *types.BlockSeqs) error

Constants

const (
	PushFormatJSON = "json"
	PushFormatPb   = "pb"
)

push format

Functions

func DealBlocks

func DealBlocks(seqs *types.BlockSeqs, d *store.SeqNum, seqNumStore store.SeqNumStore, seqStore store.SeqStore) error

DealBlocks 处理输入流程

Types

type Receiver

type Receiver interface {
	Register() error
	ReceiveLoop(s SeqSaver) // 内部启动http

}

Receiver 从节点接受推送

1. 注册/重新激活推送
2. 接受推送: (BlockSeqs, pb/json Receiver 处理, gzip http 外部处理) 数据协议: *types.BlockSeqs < pb/json < gzip < http

func CreateReceiver

func CreateReceiver(cfg *proto.ConfigNew, s SeqSaver) (Receiver, error)

CreateReceiver ...

func NewReceiver

func NewReceiver(p *pusher, pushBind string) (Receiver, error)

type ReceiverConvert

type ReceiverConvert interface {
	RecoverStats() error
	Register() error
	ReceiveLoop() // 内部启动http, http请求内部直接解析请求数据，写入rpc es查询库

}

func CreateReceiverConvert

func CreateReceiverConvert(cfg *proto.ConfigNew, EsWrite escli.ESClient) (ReceiverConvert, error)

type SaveSeq

type SaveSeq func(seq *types.BlockSeqs) error

SaveSeq 保存seq

type SeqSaver

type SeqSaver interface {
	Save(seq *types.BlockSeqs) error
}

SeqSaver 保存seq

type SeqsProc

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

SeqsProc SeqsProc

func NewSeqsProc

func NewSeqsProc(seqNumStore store.SeqNumStore, seqStore store.SeqStore, chain *proto.Chain33) (*SeqsProc, error)

NewSeqsProc 将推送和处理等功能组合起来

func (*SeqsProc) Proc

func (p *SeqsProc) Proc(startSeq int64)

func (*SeqsProc) Save

func (p *SeqsProc) Save(block *types.BlockSeqs) error

Save save seq