pubsub

package

v1.0.2 Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 0 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/teradata-labs/loom

Links

Open Source Insights

Documentation ¶

Overview ¶

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. Package pubsub provides event pub/sub types compatible with Crush's interface.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Event ¶

type Event[T any] struct {
	Type    EventType
	Payload T
}

Event wraps an event with type information. Matches Crush's pubsub.Event[T] pattern.

func NewCreatedEvent ¶

func NewCreatedEvent[T any](payload T) Event[T]

NewCreatedEvent creates a new "created" event.

func NewDeletedEvent ¶

func NewDeletedEvent[T any](payload T) Event[T]

NewDeletedEvent creates a new "deleted" event.

func NewUpdatedEvent ¶

func NewUpdatedEvent[T any](payload T) Event[T]

NewUpdatedEvent creates a new "updated" event.

type EventType ¶

type EventType int

EventType represents the type of event.

const (
	// CreatedEvent indicates a new item was created.
	CreatedEvent EventType = iota
	// UpdatedEvent indicates an existing item was updated.
	UpdatedEvent
	// DeletedEvent indicates an item was deleted.
	DeletedEvent
)

type UpdateAvailableMsg ¶

type UpdateAvailableMsg struct {
	CurrentVersion string
	LatestVersion  string
	IsDevelopment  bool
}

UpdateAvailableMsg is sent when an update is available.

Source Files ¶

View all Source files

pubsub.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL