Documentation
¶
Index ¶
- type CoalesceFire
- type ConnAdd
- type ConnCloseStream
- type DisseminateLock
- type DisseminateTable
- type DisseminateUnlock
- type DisseminateUpdate
- type DisseminationTimeout
- type EventDisseminator
- type EventNamespace
- type EventStream
- type NamespaceTableRequest
- type ReportedHost
- type Shutdown
- type StateTableRequest
- type StreamShutdown
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CoalesceFire ¶ added in v1.18.0
type CoalesceFire struct {
// contains filtered or unexported fields
}
CoalesceFire is enqueued by the post-round coalesce timer. When it arrives, the disseminator drains any waitingToDelete / waitingToDisseminate accumulated during the coalesce window and starts a single follow-up dissemination round covering all of them.
type ConnAdd ¶
type ConnAdd struct {
Channel v1pb.Placement_ReportDaprStatusServer
Cancel context.CancelCauseFunc
InitialHost *v1pb.Host
// contains filtered or unexported fields
}
ConnAdd is the event for adding a new connection to placement.
type ConnCloseStream ¶
type ConnCloseStream struct {
StreamIDx uint64
Namespace string
Error error
// contains filtered or unexported fields
}
ConnCloseStream is the event for closing a connection to the placement from the stream.
type DisseminateLock ¶
type DisseminateLock struct {
Version uint64
// contains filtered or unexported fields
}
type DisseminateTable ¶ added in v1.17.1
type DisseminateTable struct {
Tables *v1pb.PlacementTables
Version uint64
// contains filtered or unexported fields
}
DisseminateTable is a one-shot event that sends the current placement table to a single stream via LOCK+UPDATE+UNLOCK. Unlike the 3-stage dissemination, this does not participate in the cluster-wide lock protocol. It is used to send the current table to newly connected streams that have no actor types.
type DisseminateUnlock ¶
type DisseminateUnlock struct {
Version uint64
// contains filtered or unexported fields
}
type DisseminateUpdate ¶
type DisseminateUpdate struct {
Tables *v1pb.PlacementTables
Version uint64
// contains filtered or unexported fields
}
type DisseminationTimeout ¶
type DisseminationTimeout struct {
Version uint64
// contains filtered or unexported fields
}
type EventDisseminator ¶ added in v1.18.0
type EventDisseminator interface {
// contains filtered or unexported methods
}
type EventNamespace ¶ added in v1.18.0
type EventNamespace interface {
// contains filtered or unexported methods
}
type EventStream ¶ added in v1.18.0
type EventStream interface {
// contains filtered or unexported methods
}
type NamespaceTableRequest ¶
type NamespaceTableRequest struct {
Table func(*v1pb.StatePlacementTable)
// contains filtered or unexported fields
}
type ReportedHost ¶
type Shutdown ¶
type Shutdown struct {
Error error
// contains filtered or unexported fields
}
Shutdown is the event for shutting down the placement loops.
type StateTableRequest ¶
type StateTableRequest struct {
State func(*v1pb.StatePlacementTables)
// contains filtered or unexported fields
}
type StreamShutdown ¶
type StreamShutdown struct {
Error error
// contains filtered or unexported fields
}
StreamShutdown is the event for shutting down the placement client stream.
Source Files
Directories