cborplugin

type Client struct {
	worker.Worker
	// contains filtered or unexported fields
}

type ClientPlugin interface {
	OnCommand(Command) error
	RegisterConsumer(*Client)
}

type Command interface {
	Marshal() ([]byte, error)
	Unmarshal(b []byte) error
}

type CommandBuilder interface {
	Build() Command
}

type CommandIO struct {
	worker.Worker
	// contains filtered or unexported fields
}

type Parameters map[string]string

type Request struct {
	// RequestAt is the time when the Request corresponding to this Response was received
	RequestAt time.Time
	// Delay is the amount of time that the Response should be delayed before transmission
	Delay time.Duration // the Delay specififed for this hop
	// ID is the Request's packet ID
	ID uint64
	// Payload is the encrypted Request
	Payload []byte
	// SURB is the routing header used to return the Response to the requesting client
	SURB []byte

	// IsParametersRequest signals this is a request for plugin parameters,
	// not a regular service request. Old plugins ignore this field.
	IsParametersRequest bool `cbor:",omitempty"`
}

type RequestFactory struct {
}

type Response struct {
	// RequestAt is the time when the Request corresponding to this Response was received
	RequestAt time.Time
	// Delay is the amount of time that the Response should be delayed before transmission
	Delay time.Duration
	// ID is the Request's packet ID
	ID uint64
	// Payload is the encrypted response
	Payload []byte
	// SURB is the routing header used to return the Response to the requesting client
	SURB []byte

	// IsParametersResponse signals this is a response containing plugin parameters,
	// not a regular service response. Old plugins never set this field.
	IsParametersResponse bool `cbor:",omitempty"`
	// Params contains dynamic parameters from the plugin when IsParametersResponse is true.
	// This is used for plugin-advertised data in the mix descriptor.
	Params map[string]interface{} `cbor:",omitempty"`
}

type ResponseFactory struct {
}

type Server struct {
	worker.Worker
	// contains filtered or unexported fields
}

type ServerPlugin interface {
	OnCommand(Command) error
	RegisterConsumer(*Server)
}

type ServicePlugin interface {
	// OnRequest is the method that is called when the Provider receives
	// a request designed for a particular agent. The caller will handle
	// extracting the payload component of the message
	OnRequest(request *Request) ([]byte, error)

	// Capability returns the agent's functionality for publication in
	// the Provider's descriptor.
	Capability() string

	// Parameters returns the agent's paramenters for publication in
	// the Provider's descriptor.
	GetParameters() *Parameters

	// Halt stops the plugin.
	Halt()
}