broadcast_server

Documentation

Index

• type Server
  • func NewServer(port int, broadcastHandler func(context.Context, []byte) error) *Server
  • func (s *Server) BroadcastTx(ctx context.Context, request *broadcast_pb.BroadcastRequest) (*broadcast_pb.BroadcastReply, error)
  • func (s *Server) Run() error
  • func (s *Server) Serve() error
  • func (s *Server) Start() error

Types

type Server

type Server struct {
	Port             int
	BroadcastHandler func(context.Context, []byte) error

	broadcast_pb.UnimplementedBroadcastServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(port int, broadcastHandler func(context.Context, []byte) error) *Server

func (*Server) BroadcastTx

func (s *Server) BroadcastTx(ctx context.Context, request *broadcast_pb.BroadcastRequest) (*broadcast_pb.BroadcastReply, error)

func (*Server) Run

func (s *Server) Run() error

func (*Server) Serve

func (s *Server) Serve() error

func (*Server) Start

func (s *Server) Start() error