loops

type ConnAdd ¶

type ConnAdd struct {
	Channel     v1pb.Placement_ReportDaprStatusServer
	Cancel      context.CancelCauseFunc
	InitialHost *v1pb.Host
}

ConnAdd is the event for adding a new connection to placement.

type ConnCloseStream ¶

type ConnCloseStream struct {
	StreamIDx uint64
	Namespace string
	Error     error
}

ConnCloseStream is the event for closing a connection to the placement from the stream.

type DisseminateLock ¶

type DisseminateLock struct {
	Version uint64
}

type DisseminateTable ¶ added in v1.17.1

type DisseminateTable struct {
	Tables  *v1pb.PlacementTables
	Version uint64
}

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
}

type DisseminateUpdate ¶

type DisseminateUpdate struct {
	Tables  *v1pb.PlacementTables
	Version uint64
}

type DisseminationTimeout ¶

type DisseminationTimeout struct {
	Version uint64
}

type Event ¶

type Event any

Event is a generic interface for all events in placement.

type NamespaceTableRequest ¶

type NamespaceTableRequest struct {
	Table func(*v1pb.StatePlacementTable)
}

type ReportedHost ¶

type ReportedHost struct {
	Host      *v1pb.Host
	StreamIDx uint64
}

type Shutdown ¶

type Shutdown struct {
	Error error
}

Shutdown is the event for shutting down the placement loops.

type StateTableRequest ¶

type StateTableRequest struct {
	State func(*v1pb.StatePlacementTables)
}

type StreamShutdown ¶

type StreamShutdown struct {
	Error error
}

StreamShutdown is the event for shutting down the placement client stream.