edgetest

Documentation

Index

• Variables
• type CheckFunc
• type Server
  • func NewServer(serverID string, d edge.Dispatcher) *Server
  • func (s *Server) REST() *restCtx
  • func (s *Server) RPC() *rpcCtx
  • func (s *Server) RealEdge() *edge.Server
  • func (s *Server) Scenario() *scenario
  • func (s *Server) SetGlobalPostHandlers(h ...edge.Handler)
  • func (s *Server) SetGlobalPreHandlers(h ...edge.Handler)
  • func (s *Server) SetHandlers(constructor uint64, h ...edge.Handler)
  • func (s *Server) Shutdown()
  • func (s *Server) Start()

Variables

var (
	ErrTimeout           = fmt.Errorf("timeout")
	ErrExpectationFailed = fmt.Errorf("expectation failed")
)

Types

type CheckFunc

type CheckFunc func(b []byte, kv ...*rony.KeyValue) error

type Server

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

func NewServer

func NewServer(serverID string, d edge.Dispatcher) *Server

func (*Server) REST

func (s *Server) REST() *restCtx

func (*Server) RPC

func (s *Server) RPC() *rpcCtx

func (*Server) RealEdge

func (s *Server) RealEdge() *edge.Server

func (*Server) Scenario

func (s *Server) Scenario() *scenario

func (*Server) SetGlobalPostHandlers

func (s *Server) SetGlobalPostHandlers(h ...edge.Handler)

func (*Server) SetGlobalPreHandlers

func (s *Server) SetGlobalPreHandlers(h ...edge.Handler)

func (*Server) SetHandlers

func (s *Server) SetHandlers(constructor uint64, h ...edge.Handler)

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) Start

func (s *Server) Start()