topics

type LateJoinerMessagesRequest struct {
	// messages the late joiner already knows about
	KnownMessages []MessageIdentifier `json:"known_messages"`
}

type LateJoinerMessagesResponse struct {
	// messages that the endpoint is holding that the late joiner doesn't have already
	HeldMessages []Message `json:"held_messages"`
}

type Manager struct {
	// contains filtered or unexported fields
}

type Message struct {
	// trust the sent timestamp as it's the source of truth for the state in this message
	Timestamp time.Time `json:"timestamp"`

	// discard the message after it's this much older
	Expiry time.Duration `json:"expiry"`

	// original source
	EndpointID   ksuid.KSUID `json:"endpoint_id"`
	EndpointName string      `json:"endpoint_name"`

	// incremented by sending endpoint
	SequenceNumber int64 `json:"sequence_number"`

	// topic
	TopicName string `json:"topic_name"`
	TopicType string `json:"topic_type"`

	// to identify and route the payload
	MessageType MessageType `json:"message_type"`

	// the actual user payload / control message content
	Payload []byte `json:"payload"`
}

type MessageIdentifier struct {
	EndpointID     ksuid.KSUID
	SequenceNumber int64
}

type MessageType int

type Publication struct {
	// contains filtered or unexported fields
}

type Publisher struct {
	// contains filtered or unexported fields
}

type Subscriber struct {
	// contains filtered or unexported fields
}

type Subscription struct {
	// contains filtered or unexported fields
}