trxstream

Documentation

Index

• type Server
  • func NewServer(server *grpc.Server) *Server
  • func (s *Server) Close()
  • func (s *Server) PushTransaction(trx *pbbstream.Transaction)
  • func (s *Server) Ready() bool
  • func (s *Server) Serve(listener net.Listener) error
  • func (s *Server) Transactions(r *pbbstream.TransactionRequest, ...) error

Types

type Server

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

func NewServer

func NewServer(server *grpc.Server) *Server

func (*Server) Close

func (s *Server) Close()

func (*Server) PushTransaction

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

func (*Server) Ready

func (s *Server) Ready() bool

func (*Server) Serve

func (s *Server) Serve(listener net.Listener) error

func (*Server) Transactions

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