Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
Register creates a new channel for a gRPC source path, superseding any existing registration. The newest registration owns the path: when a workflow moves between workers, the one taking the lease over is the one that should receive.
It used to return the existing channel instead, which meant the worker taking over and the worker being replaced read from the same one — so the outgoing teardown closed the channel its successor was reading.
func Unregister ¶
Unregister releases a path, but only if ch is still the channel registered for it.
The ownership check is what makes a handover safe. Nothing orders the outgoing worker's teardown against the incoming worker's registration, so deleting by path alone let a worker that had already lost the lease close and remove its successor's channel. The successor was then reading from a closed channel that no longer appeared in the registry: the workflow reported itself running and never received another message.
Types ¶
type GenericProtoSource ¶
type GenericProtoSource struct {
ProtoFile string
MessageName string
Source hermod.Source
// contains filtered or unexported fields
}
GenericProtoSource wraps another source and decodes its payload using dynamic Protobuf descriptors.
func NewGenericProtoSource ¶
func NewGenericProtoSource(protoFile, messageName string, source hermod.Source) (*GenericProtoSource, error)
NewGenericProtoSource creates a new GenericProtoSource.
func (*GenericProtoSource) Close ¶
func (s *GenericProtoSource) Close() error
type GrpcSource ¶
type GrpcSource struct {
Path string
// contains filtered or unexported fields
}
GrpcSource implements the hermod.Source interface for receiving gRPC calls.
func NewGrpcSource ¶
func NewGrpcSource(path string) *GrpcSource
NewGrpcSource creates a new GrpcSource.
func (*GrpcSource) Close ¶
func (s *GrpcSource) Close() error
Source Files
Directories