trxstream

Documentation

Index

• type Server
  • func NewServer(logger *zap.Logger) *Server
  • func (s *Server) PushTransaction(trx *pbtrxstream.Transaction)
  • func (s *Server) Ready() bool
  • func (s *Server) Transactions(r *pbtrxstream.TransactionRequest, ...) error

Types

type Server

type Server struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func NewServer

func NewServer(logger *zap.Logger) *Server

func (*Server) PushTransaction

func (s *Server) PushTransaction(trx *pbtrxstream.Transaction)

func (*Server) Ready

func (s *Server) Ready() bool

func (*Server) Transactions

func (s *Server) Transactions(r *pbtrxstream.TransactionRequest, stream pbtrxstream.TransactionStream_TransactionsServer) error