Documentation
¶
Index ¶
- func Dispatch(path string, msg hermod.Message) error
- func Register(path string) chan hermod.Message
- func Unregister(path string, ch chan hermod.Message)
- type FormSource
- func (s *FormSource) Ack(ctx context.Context, msg hermod.Message) error
- func (s *FormSource) Close() error
- func (s *FormSource) Ping(ctx context.Context) error
- func (s *FormSource) Read(ctx context.Context) (hermod.Message, error)
- func (s *FormSource) Sample(ctx context.Context, table string) (hermod.Message, error)
- type FormSubmission
- type FormSubmissionFilter
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
Register creates the channel a form source reads its path from. It holds the path if nothing else does, and otherwise waits to take it over.
func Unregister ¶
Unregister releases a channel's claim on a path. Only the channel that holds the path removes it, so an outgoing engine's teardown cannot remove the source that took over from it.
Types ¶
type FormSource ¶
FormSource implements the hermod.Source interface for receiving form submissions.
func NewFormSource ¶
func NewFormSource(path string, storage Storage) *FormSource
NewFormSource creates a new FormSource.
func (*FormSource) Close ¶
func (s *FormSource) Close() error
type FormSubmission ¶
type FormSubmissionFilter ¶
Click to show internal directories.
Click to hide internal directories.