plugins

Documentation

Index

• Constants
• type Dispatcher
• type Heartbeater
• type Server
  • func NewServer[Q Heartbeater[R], R any](call func(Dispatcher, Q) R) (*Server[Q, R], error)

Constants

const StatusInfoLog = 101

TODO(bep) move

Types

type Dispatcher

type Dispatcher interface {
	Infof(format string, args ...interface{})
}

type Heartbeater

type Heartbeater[R any] interface {
	HeartbeatResponse() (R, bool)
}

type Server

type Server[Q, R any] struct {
	*execrpc.Server[Q, R]
}

func NewServer

func NewServer[Q Heartbeater[R], R any](call func(Dispatcher, Q) R) (*Server[Q, R], error)

NewServer creates a new server which will call the given function with a request Q. The Dispatcher an be used for logging. Any errors needs to be sent in R.