utils

Documentation

Index

• Constants
• type BlockResponse
• type EmulatorAPIServer
  • func NewEmulatorAPIServer(emulator emulator.Emulator, adapter *adapters.AccessAdapter) *EmulatorAPIServer
  • func (m EmulatorAPIServer) CodeCoverage(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) CommitBlock(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) ComputationReport(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) Config(w http.ResponseWriter, _ *http.Request)
  • func (m EmulatorAPIServer) Logs(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) ResetCodeCoverage(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) Rollback(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) SnapshotCreate(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) SnapshotJump(w http.ResponseWriter, r *http.Request)
  • func (m EmulatorAPIServer) SnapshotList(w http.ResponseWriter, _ *http.Request)
• type HTTPHeader
• type HTTPServer
  • func NewAdminServer(logger *zerolog.Logger, emulator emulator.Emulator, ...) *HTTPServer
  • func (h *HTTPServer) Listen() error
  • func (h *HTTPServer) Start() error
  • func (h *HTTPServer) Stop()
• type LivenessTicker
  • func NewLivenessTicker(tolerance time.Duration) *LivenessTicker
  • func (l *LivenessTicker) Handler() http.Handler
  • func (l *LivenessTicker) Start() error
  • func (l *LivenessTicker) Stop()

Constants

const (
	LivenessPath    = "/live"
	MetricsPath     = "/metrics"
	EmulatorApiPath = "/emulator/"
)

Types

type BlockResponse

type BlockResponse struct {
	Height  int    `json:"height"`
	BlockId string `json:"blockId"`
	Context string `json:"context,omitempty"`
}

type EmulatorAPIServer

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

func NewEmulatorAPIServer

func NewEmulatorAPIServer(emulator emulator.Emulator, adapter *adapters.AccessAdapter) *EmulatorAPIServer

func (EmulatorAPIServer) CodeCoverage

func (m EmulatorAPIServer) CodeCoverage(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) CommitBlock

func (m EmulatorAPIServer) CommitBlock(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) ComputationReport

func (m EmulatorAPIServer) ComputationReport(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) Config

func (m EmulatorAPIServer) Config(w http.ResponseWriter, _ *http.Request)

func (EmulatorAPIServer) Logs

func (m EmulatorAPIServer) Logs(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) ResetCodeCoverage

func (m EmulatorAPIServer) ResetCodeCoverage(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) Rollback

func (m EmulatorAPIServer) Rollback(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) ServeHTTP

func (m EmulatorAPIServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) SnapshotCreate

func (m EmulatorAPIServer) SnapshotCreate(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) SnapshotJump

func (m EmulatorAPIServer) SnapshotJump(w http.ResponseWriter, r *http.Request)

func (EmulatorAPIServer) SnapshotList

func (m EmulatorAPIServer) SnapshotList(w http.ResponseWriter, _ *http.Request)

type HTTPHeader

type HTTPHeader struct {
	Key   string
	Value string
}

type HTTPServer

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

func NewAdminServer

func NewAdminServer(
	logger *zerolog.Logger,
	emulator emulator.Emulator,
	adapter *adapters.AccessAdapter,
	grpcServer *access.GRPCServer,
	liveness *LivenessTicker,
	host string,
	port int,
	headers []HTTPHeader,
) *HTTPServer

func (*HTTPServer) Listen

func (h *HTTPServer) Listen() error

func (*HTTPServer) Start

func (h *HTTPServer) Start() error

func (*HTTPServer) Stop

func (h *HTTPServer) Stop()

type LivenessTicker

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

func NewLivenessTicker

func NewLivenessTicker(tolerance time.Duration) *LivenessTicker

func (*LivenessTicker) Handler

func (l *LivenessTicker) Handler() http.Handler

func (*LivenessTicker) Start

func (l *LivenessTicker) Start() error

func (*LivenessTicker) Stop

func (l *LivenessTicker) Stop()