kaetzchen

type BuiltInCtorFn func(*config.Kaetzchen, glue.Glue) (Kaetzchen, error)

type CBORPluginWorker struct {
	sync.Mutex
	worker.Worker
	// contains filtered or unexported fields
}

type Kaetzchen interface {
	// 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.
	Parameters() Parameters

	// 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.
	//
	// Implementations MUST:
	//
	//  * Be thread (go routine) safe.
	//
	//  * Return ErrNoResponse if there is no response to be sent.  A nil
	//    byte slice and nil error will result in a response with a 0 byte
	//    payload being sent.
	//
	//  * NOT assume payload will be valid past the call to OnMessage.
	//    Any contents that need to be preserved, MUST be copied out,
	//    except if it is only used as a part of the response body.
	OnRequest(id uint64, payload []byte, hasSURB bool) ([]byte, error)

	// Halt cleans up the agent prior to de-registration and teardown.
	Halt()
}

type KaetzchenWorker struct {
	sync.Mutex
	worker.Worker
	// contains filtered or unexported fields
}

type Parameters map[string]interface{}

type PluginChans = map[[sConstants.RecipientIDLength]byte]*channels.InfiniteChannel

type PluginName = string

type PluginParameters = map[PluginName]interface{}

type ServiceMap = map[PluginName]PluginParameters