fcrserver

type FCRServer interface {
	// Start starts the server.
	Start() error

	// Shutdown stops the server.
	Shutdown()

	// AddHandler adds a handler to the server, which handles a given message type.
	AddHandler(msgType byte, handler func(reader FCRServerRequestReader, writer FCRServerResponseWriter, request *fcrmessages.FCRReqMsg) error) FCRServer

	// AddRequester adds a requester to the server, which is used to send a request for a given message type.
	AddRequester(msgType byte, requester func(reader FCRServerResponseReader, writer FCRServerRequestWriter, args ...interface{}) (*fcrmessages.FCRACKMsg, error)) FCRServer

	// Request uses a requester corresponding to the given message type to send a request to given multiaddr.
	Request(multiaddrStr string, msgType byte, args ...interface{}) (*fcrmessages.FCRACKMsg, error)
}

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

type FCRServerRequestReader interface {
	// Read reads a message for a given timeout.
	// It returns the message, and error.
	Read(timeout time.Duration) (*fcrmessages.FCRReqMsg, error)
}

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

type FCRServerRequestWriter interface {
	// Write writes a message for a given timeout.
	// It returns error.
	Write(msg *fcrmessages.FCRReqMsg, privKey string, keyVer byte, timeout time.Duration) error
}

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

type FCRServerResponseReader interface {
	// Read reads a message for a given timeout.
	// It returns the message, and error.
	Read(timeout time.Duration) (*fcrmessages.FCRACKMsg, error)
}

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

type FCRServerResponseWriter interface {
	// Write writes a message for a given timeout.
	// It returns error.
	Write(msg *fcrmessages.FCRACKMsg, privKey string, keyVer byte, timeout time.Duration) error
}

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