Documentation ¶
Overview ¶
wire implements the grpc wire protocol that is used later on by the state machine to communicate with restate runtime.
Index ¶
- Variables
- type BackgroundInvokeEntryMessage
- type ClearAllStateEntryMessage
- type ClearStateEntryMessage
- type CompletionMessage
- type EntryAckMessage
- type Flag
- type GetStateEntryMessage
- type GetStateKeysEntryMessage
- type Header
- type InvokeEntryMessage
- type Message
- type OutputStreamEntry
- type PollInputEntry
- type Protocol
- type Reader
- type ReaderMessage
- type SetStateEntryMessage
- type SideEffectEntryMessage
- type SleepEntryMessage
- type StartMessage
- type Type
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrUnexpectedMessage = fmt.Errorf("unexpected message")
)
Functions ¶
This section is empty.
Types ¶
type BackgroundInvokeEntryMessage ¶
type BackgroundInvokeEntryMessage struct { Header Payload protocol.BackgroundInvokeEntryMessage }
type ClearAllStateEntryMessage ¶
type ClearAllStateEntryMessage struct { Header Payload protocol.ClearAllStateEntryMessage }
type ClearStateEntryMessage ¶
type ClearStateEntryMessage struct { Header Payload protocol.ClearStateEntryMessage }
type CompletionMessage ¶
type CompletionMessage struct { Header Payload protocol.CompletionMessage }
type EntryAckMessage ¶ added in v0.8.2
type EntryAckMessage struct { Header Payload protocol.EntryAckMessage }
type Flag ¶
type Flag uint16
Flag section of the header this can have a different meaning based on message type.
type GetStateEntryMessage ¶
type GetStateEntryMessage struct { Header Payload protocol.GetStateEntryMessage }
type GetStateKeysEntryMessage ¶
type GetStateKeysEntryMessage struct { Header Payload protocol.GetStateKeysEntryMessage }
type InvokeEntryMessage ¶
type InvokeEntryMessage struct { Header Payload protocol.InvokeEntryMessage }
type OutputStreamEntry ¶
type OutputStreamEntry struct { Header Payload protocol.OutputStreamEntryMessage }
type PollInputEntry ¶
type PollInputEntry struct { Header Payload protocol.PollInputStreamEntryMessage }
type Protocol ¶
type Protocol struct {
// contains filtered or unexported fields
}
Protocol implements the wire protocol to abstract receiving and sending messages Note that Protocol is not concurrent safe and it's up to the user to make sure it's used correctly
func NewProtocol ¶
func NewProtocol(stream io.ReadWriter) *Protocol
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func (*Reader) Next ¶
func (r *Reader) Next() <-chan ReaderMessage
type ReaderMessage ¶
type SetStateEntryMessage ¶
type SetStateEntryMessage struct { Header Payload protocol.SetStateEntryMessage }
type SideEffectEntryMessage ¶
type SideEffectEntryMessage struct { Header Payload javascript.SideEffectEntryMessage }
type SleepEntryMessage ¶
type SleepEntryMessage struct { Header Payload protocol.SleepEntryMessage }
type StartMessage ¶
type StartMessage struct { Header Version uint16 Payload protocol.StartMessage }
type Type ¶
type Type uint16
const ( // control StartMessageType Type = 0x0000 CompletionMessageType Type = 0x0000 + 1 SuspensionMessageType Type = 0x0000 + 2 ErrorMessageType Type = 0x0000 + 3 EntryAckMessageType Type = 0x0000 + 4 EndMessageType Type = 0x0000 + 5 // Input/Output PollInputEntryMessageType Type = 0x0400 OutputStreamEntryMessageType Type = 0x0400 + 1 // State GetStateEntryMessageType Type = 0x0800 SetStateEntryMessageType Type = 0x0800 + 1 ClearStateEntryMessageType Type = 0x0800 + 2 ClearAllStateEntryMessageType Type = 0x0800 + 3 GetStateKeysEntryMessageType Type = 0x0800 + 4 //SysCalls SleepEntryMessageType Type = 0x0C00 InvokeEntryMessageType Type = 0x0C00 + 1 BackgroundInvokeEntryMessageType Type = 0x0C00 + 2 // SideEffect SideEffectEntryMessageType Type = 0xFC00 + 1 )
Click to show internal directories.
Click to hide internal directories.