edgetest

Documentation

Index

• Variables
• type CheckFunc
• type Server
  • func NewServer(serverID string, d edge.Dispatcher) *Server
  • func (s *Server) AppendContext() *context
  • func (s *Server) Context() *context
  • func (s *Server) RealEdge() *edge.Server
  • func (s *Server) RunAll(timeout time.Duration) error
  • func (s *Server) SetHandlers(constructor int64, h ...edge.Handler)
  • func (s *Server) SetPostHandlers(h ...edge.Handler)
  • func (s *Server) SetPreHandlers(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, auth []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) AppendContext

func (s *Server) AppendContext() *context

func (*Server) Context

func (s *Server) Context() *context

func (*Server) RealEdge

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

func (*Server) RunAll

func (s *Server) RunAll(timeout time.Duration) error

func (*Server) SetHandlers

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

func (*Server) SetPostHandlers

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

func (*Server) SetPreHandlers

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

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) Start

func (s *Server) Start()