Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

wire

package

Go to main page

Versions in this module

v0

v0.15.0

Feb 12, 2025

v0.14.0

Jan 20, 2025

v0.13.2

Dec 11, 2024

v0.13.1

Nov 26, 2024

v0.13.0

Nov 8, 2024

v0.12.0

Nov 8, 2024

Changes in this version

+ type CompletePromiseEntryMessage struct

+ func (a *CompletePromiseEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *CompletePromiseEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *CompletePromiseEntryMessage) Completed() bool

+ func (c *CompletePromiseEntryMessage) Done() <-chan struct{}

+ type GetPromiseEntryMessage struct

+ func (a *GetPromiseEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *GetPromiseEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *GetPromiseEntryMessage) Completed() bool

+ func (c *GetPromiseEntryMessage) Done() <-chan struct{}

+ type PeekPromiseEntryMessage struct

+ func (a *PeekPromiseEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *PeekPromiseEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *PeekPromiseEntryMessage) Completed() bool

+ func (c *PeekPromiseEntryMessage) Done() <-chan struct{}

type Type

+ const CompletePromiseEntryMessageType

+ const GetPromiseEntryMessageType

+ const PeekPromiseEntryMessageType

v0.11.0

Aug 22, 2024

v0.10.0

Aug 14, 2024

v0.9.1

Jul 19, 2024

v0.9.0

Jul 17, 2024

Changes in this version

+ var ErrUnexpectedMessage = fmt.Errorf("unexpected message")

+ type AckableMessage interface

+ Ack func()

+ Acked func() bool

+ Await func(ctx context.Context, entryIndex uint32)

+ type AwakeableEntryMessage struct

+ func (a *AwakeableEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *AwakeableEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *AwakeableEntryMessage) Completed() bool

+ func (c *AwakeableEntryMessage) Done() <-chan struct{}

+ type CallEntryMessage struct

+ func (a *CallEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *CallEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *CallEntryMessage) Completed() bool

+ func (c *CallEntryMessage) Done() <-chan struct{}

+ type ClearAllStateEntryMessage struct

+ type ClearStateEntryMessage struct

+ type CompleteAwakeableEntryMessage struct

+ type CompleteableMessage interface

+ Await func(suspensionCtx context.Context, entryIndex uint32)

+ Complete func(*protocol.CompletionMessage) error

+ Completed func() bool

+ Done func() <-chan struct{}

+ type CompletionMessage struct

+ type EndMessage struct

+ type EntryAckMessage struct

+ type ErrorMessage struct

+ type Flag uint16

+ const FlagCompleted

+ const FlagRequiresAck

+ const VersionMask

+ func (r Flag) Ack() bool

+ func (r Flag) Completed() bool

+ type GetStateEntryMessage struct

+ func (a *GetStateEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *GetStateEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *GetStateEntryMessage) Completed() bool

+ func (c *GetStateEntryMessage) Done() <-chan struct{}

+ type GetStateKeysEntryMessage struct

+ func (a *GetStateKeysEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *GetStateKeysEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *GetStateKeysEntryMessage) Completed() bool

+ func (c *GetStateKeysEntryMessage) Done() <-chan struct{}

+ type Header struct

+ Flag Flag

+ Length uint32

+ TypeCode Type

+ func (t *Header) Flags() Flag

+ func (t *Header) Type() Type

+ type InputEntryMessage struct

+ type Message interface

+ type OneWayCallEntryMessage struct

+ type OutputEntryMessage struct

+ type Protocol struct

+ func NewProtocol(stream io.ReadWriter) *Protocol

+ func (s *Protocol) Read() (Message, Type, error)

+ func (s *Protocol) Write(typ Type, message Message) error

+ type Reader struct

+ func (r *Reader) Next() <-chan ReaderMessage

+ func (r *Reader) Read(ctx context.Context) (Message, error)

+ type ReaderMessage struct

+ Err error

+ Message Message

+ type RunEntryMessage struct

+ func (c *RunEntryMessage) Ack()

+ func (c *RunEntryMessage) Acked() bool

+ func (c *RunEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ type SelectorEntryMessage struct

+ func (c *SelectorEntryMessage) Ack()

+ func (c *SelectorEntryMessage) Acked() bool

+ func (c *SelectorEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ type SetStateEntryMessage struct

+ type SleepEntryMessage struct

+ func (a *SleepEntryMessage) Complete(c *protocol.CompletionMessage) error

+ func (c *SleepEntryMessage) Await(suspensionCtx context.Context, entryIndex uint32)

+ func (c *SleepEntryMessage) Completed() bool

+ func (c *SleepEntryMessage) Done() <-chan struct{}

+ type StartMessage struct

+ type SuspensionMessage struct

+ type SuspensionPanic struct

+ EntryIndexes []uint32

+ Err error

+ type Type uint16

+ const AwakeableEntryMessageType

+ const CallEntryMessageType

+ const ClearAllStateEntryMessageType

+ const ClearStateEntryMessageType

+ const CompleteAwakeableEntryMessageType

+ const CompletionMessageType

+ const EndMessageType

+ const EntryAckMessageType

+ const ErrorMessageType

+ const GetStateEntryMessageType

+ const GetStateKeysEntryMessageType

+ const InputEntryMessageType

+ const OneWayCallEntryMessageType

+ const OutputEntryMessageType

+ const RunEntryMessageType

+ const SelectorEntryMessageType

+ const SetStateEntryMessageType

+ const SleepEntryMessageType

+ const StartMessageType

+ const SuspensionMessageType

+ func MessageType(message Message) Type

+ func (t Type) String() string

+ func (t Type) UInt32() *uint32