shard

Documentation

Index

• type ProcessBlock
• type Shard
  • func NewShard(shardId int, verbose bool) *Shard
  • func (s *Shard) Ping(_ context.Context, req *cluster_pb.PingReq) (*cluster_pb.PingResp, error)
  • func (s *Shard) Run() error
  • func (s *Shard) SaveTxs(ctx context.Context, req *cluster_pb.SaveReq) (*cluster_pb.EmptyResp, error)
  • func (s *Shard) Serve() error
  • func (s *Shard) Start() error

Types

type ProcessBlock

type ProcessBlock struct {
	Block *wire.MsgBlock
	Added time.Time
}

type Shard

type Shard struct {
	Id      int
	Verbose bool
	Error   chan error

	Blocks map[chainhash.Hash]ProcessBlock
	cluster_pb.UnimplementedClusterServer
	// contains filtered or unexported fields
}

func NewShard

func NewShard(shardId int, verbose bool) *Shard

func (*Shard) Ping

func (s *Shard) Ping(_ context.Context, req *cluster_pb.PingReq) (*cluster_pb.PingResp, error)

func (*Shard) Run

func (s *Shard) Run() error

func (*Shard) SaveTxs

func (s *Shard) SaveTxs(ctx context.Context, req *cluster_pb.SaveReq) (*cluster_pb.EmptyResp, error)

func (*Shard) Serve

func (s *Shard) Serve() error

func (*Shard) Start

func (s *Shard) Start() error