centrifuge

package

v0.1.1 Latest Latest Go to latest Published: May 13, 2025 License: MIT Imports: 4 Imported by: 0

Details

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

Repository

github.com/GoLabra/labra

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Publish(ctx context.Context, client *gocent.Client, channel string, content any) error
func PublishAppStatusMessage(ctx context.Context, client *gocent.Client, event AppStatusEvent, entities any) error
type AppStatusEvent
type CodeGenerationMessage
type MessageContent

Constants ¶

View Source

const (
	CodeGenerationChannel              = "channel"
	ErrCentrifugeClientNotSetInContext = "centrifuge client is not set in context"
)

Variables ¶

This section is empty.

Functions ¶

func Publish ¶

func Publish(ctx context.Context, client *gocent.Client, channel string, content any) error

func PublishAppStatusMessage ¶

func PublishAppStatusMessage(ctx context.Context, client *gocent.Client, event AppStatusEvent, entities any) error

Types ¶

type AppStatusEvent ¶

type AppStatusEvent string

const (
	AppStatusGenerationStarted   AppStatusEvent = "CODE_GENERATION_STARTED"
	AppStatusGenerationCompleted AppStatusEvent = "CODE_GENERATION_COMPLETED"
	AppStatusGenerationReverted  AppStatusEvent = "CODE_GENERATION_REVERTED"
	AppStatusGenerationFailed    AppStatusEvent = "CODE_GENERATION_FAILED"
	AppStatusShutdown            AppStatusEvent = "SHUTDOWN"
	AppStatusUp                  AppStatusEvent = "UP"
)

type CodeGenerationMessage ¶

type CodeGenerationMessage struct {
	Event     AppStatusEvent `json:"event"`
	Timestamp time.Time      `json:"timestamp"`
	Entities  any            `json:"entities,omitempty"`
}

type MessageContent ¶

type MessageContent interface {
	Marshal() ([]byte, error)
}

Source Files ¶

View all Source files

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