grpc

Documentation

Index

• Constants
• func ActionKeyToCursor(key []byte, shardNo byte, seqNum uint64) *pbaccounthist.Cursor
• type EOSName
  • func (n EOSName) String() string
• type Server
  • func New(grpcAddr string, maxEntries uint64, kvStore store.KVStore) *Server
  • func (s *Server) GetAccountContractActions(req *pbaccounthist.GetTokenActionsRequest, ...) error
  • func (s *Server) GetActions(req *pbaccounthist.GetActionsRequest, ...) error
  • func (s *Server) ServeAccountContractMode()
  • func (s *Server) ServeAccountMode()
  • func (s *Server) StreamAccountActions(ctx context.Context, account uint64, limit uint64, ...) error
  • func (s *Server) StreamAccountContractActions(ctx context.Context, account uint64, contract uint64, limit uint64, ...) error
  • func (s *Server) Terminate(err error)

Constants

const CursorMagicValue = 4374

Functions

func ActionKeyToCursor

func ActionKeyToCursor(key []byte, shardNo byte, seqNum uint64) *pbaccounthist.Cursor

Types

type EOSName

type EOSName uint64

func (EOSName) String

func (n EOSName) String() string

type Server

type Server struct {
	*shutter.Shutter

	MaxEntries uint64
	KVStore    store.KVStore
	// contains filtered or unexported fields
}

func New

func New(grpcAddr string, maxEntries uint64, kvStore store.KVStore) *Server

func (*Server) GetAccountContractActions

func (s *Server) GetAccountContractActions(req *pbaccounthist.GetTokenActionsRequest, stream pbaccounthist.AccountContractHistory_GetAccountContractActionsServer) error

func (*Server) GetActions

func (s *Server) GetActions(req *pbaccounthist.GetActionsRequest, stream pbaccounthist.AccountHistory_GetActionsServer) error

func (*Server) ServeAccountContractMode

func (s *Server) ServeAccountContractMode()

func (*Server) ServeAccountMode

func (s *Server) ServeAccountMode()

func (*Server) StreamAccountActions

func (s *Server) StreamAccountActions(
	ctx context.Context,
	account uint64,
	limit uint64,
	cursor *pbaccounthist.Cursor,
	onAction func(cursor *pbaccounthist.Cursor, actionTrace *pbcodec.ActionTrace) error,
) error

func (*Server) StreamAccountContractActions

func (s *Server) StreamAccountContractActions(
	ctx context.Context,
	account uint64,
	contract uint64,
	limit uint64,
	cursor *pbaccounthist.Cursor,
	onAction func(cursor *pbaccounthist.Cursor, actionTrace *pbcodec.ActionTrace) error,
) error

func (*Server) Terminate

func (s *Server) Terminate(err error)