github.com/l1fe-labs/forge-go/comm
Go comm package.
Go comm package.
Package contract
| Field | Value |
|---|---|
| Language | go |
| Source version | module source snapshot |
| Manifest | forge-go/go.mod |
| Source files | 6 |
| Evidence | Source reference; registry publication and runtime conformance are separate checks |
Import boundary
import "github.com/l1fe-labs/forge-go/comm"Use a source checkout or your verified private registry. Manifest coordinates identify the package; they do not establish that a public registry release exists.
Source reference
Download package reference JSON. Each original source file and generated declaration artifact has its own SHA-256 digest. Function bodies and constant values are omitted from downloads. These are source declaration inventories, not compiler-resolved rustdoc, TypeDoc, DocC, or Dokka output. Private modules can contain public declarations that are not reachable through the package boundary; consult the entry point before importing.
channel.go
Read declaration text · 5 declaration entries
type ChannelTransport struct
func NewChannelPair(capacity int) (*ChannelTransport, *ChannelTransport)
func (t *ChannelTransport) Send(msg AgentMessage) error
func (t *ChannelTransport) Receive() (AgentMessage, error)
func (t *ChannelTransport) CloseChannel()errors.go
Read declaration text · 12 declaration entries
type CommError struct
type CommErrorKind string
const (
// ErrKindSerializationFailed indicates message serialization failed.
ErrKindSerializationFailed CommErrorKind;
func (e *CommError) Error() string
func (e *CommError) Unwrap() error
func NewSerializationError(message string, cause error) *CommError
func NewDeserializationError(message string, cause error) *CommError
func NewTransportError(message string, cause error) *CommError
func NewNotConnectedError(message string) *CommError
func NewChannelClosedError(message string) *CommError
func NewProtocolNegotiationError(message string) *CommError
func NewMessageTooLargeError(size, maxSize int) *CommError
func NewTimeoutError(operation string) *CommErrormessage.go
Read declaration text · 6 declaration entries
type AgentMessage struct
func NewAgentMessage(sender, recipient, protocol, messageType string, payload []byte) AgentMessage
func (m AgentMessage) WithCorrelationID(id string) AgentMessage
func (m AgentMessage) WithReplyTo(id string) AgentMessage
func (m AgentMessage) IsSigned() bool
func (m AgentMessage) Kind() stringnoop.go
Read declaration text · 3 declaration entries
type NoopTransport struct
func (NoopTransport) Send(_ AgentMessage) error
func (NoopTransport) Receive() (AgentMessage, error)protocol.go
Read declaration text · 3 declaration entries
type ProtocolOffer struct
type ProtocolAccept struct
func NegotiateProtocol(initiator, responder ProtocolOffer) (*ProtocolAccept, error)transport.go
Read declaration text · 1 declaration entries
type MessageTransport interface