server

Documentation

Index

• type OnConnectionHandler
• type OnErrorHandler
• type Server
  • func New(key bifrost.KeyOpts, crypto bifrost.Crypto, metaData map[string]string) *Server
  • func (s Server) BifrostStream(streamServer pb.StreamService_BifrostStreamServer) error
  • func (s *Server) Listen(ip string)
  • func (s *Server) OnConnection(handler OnConnectionHandler)
  • func (s *Server) OnError(handler OnErrorHandler)
  • func (s *Server) Stop()
  • func (s Server) ValidatePeerInfo(envelope *pb.Envelope) (bool, string, bifrost.Key)
  • func (s Server) ValidateResponsePeerInfo(envelope *pb.Envelope) (bool, string, bifrost.Key)

Types

type OnConnectionHandler

type OnConnectionHandler func(connection bifrost.Connection)

type OnErrorHandler

type OnErrorHandler func(err error)

type Server

type Server struct {
	bifrost.Crypto
	// contains filtered or unexported fields
}

func New

func New(key bifrost.KeyOpts, crypto bifrost.Crypto, metaData map[string]string) *Server

func (Server) BifrostStream

func (s Server) BifrostStream(streamServer pb.StreamService_BifrostStreamServer) error

func (*Server) Listen

func (s *Server) Listen(ip string)

func (*Server) OnConnection

func (s *Server) OnConnection(handler OnConnectionHandler)

func (*Server) OnError

func (s *Server) OnError(handler OnErrorHandler)

func (*Server) Stop

func (s *Server) Stop()

func (Server) ValidatePeerInfo

func (s Server) ValidatePeerInfo(envelope *pb.Envelope) (bool, string, bifrost.Key)

func (Server) ValidateResponsePeerInfo

func (s Server) ValidateResponsePeerInfo(envelope *pb.Envelope) (bool, string, bifrost.Key)