Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrProtoNameNotFound = errors.New("protocol name not found")
Functions ¶
func MustMarshalAny ¶
MustMarshalAny serializes a protobuf message into an Any or panics.
func NameFromMessage ¶
func NameFromMessage(msg *protocolpb.Message) (string, error)
NameFromMessage extracts the name of the protocol to which the supplied message belongs.
Types ¶
type Instance ¶
type Instance interface {
HandleMessage(*protocolpb.Message) error
HasCompleted() bool
}
Instance is the required interface for protocol objects.
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry stores running protocols.
func NewRegistry ¶
func NewRegistry() *Registry
func (*Registry) ClearCompleted ¶
func (r *Registry) ClearCompleted()
ClearCompleted walks the registered protocols and removes those that have completed.
Source Files
Click to show internal directories.
Click to hide internal directories.