flow

README

Event Flow

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (c *Client) Configure(config ClientConfig) *Client
  • func (client *Client) Connect() error
  • func (client *Client) Disconnect()
• type ClientConfig
• type Event
  • func NewEvent[T any](triggerer string, eventType EventType, payload T) *Event[T]
• type EventFlow
  • func NewEventFlow[T any](client *Client, eventType EventType) *EventFlow[T]
  • func (flow *EventFlow[T]) Publish(triggerer string, payload T) (*Event[T], error)
  • func (flow *EventFlow[T]) SetCallback(callback func(event Event[T]))
  • func (flow *EventFlow[T]) Subscribe() error
  • func (flow *EventFlow[T]) Unsubscribe() error
• type EventType

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Configure

func (c *Client) Configure(config ClientConfig) *Client

func (*Client) Connect

func (client *Client) Connect() error

func (*Client) Disconnect

func (client *Client) Disconnect()

type ClientConfig

type ClientConfig struct {
	URL              string
	Username         string
	Password         string
	OnConnectHandler func()
}

type Event

type Event[T any] struct {
	Id        string    `json:"id"`
	Timestamp int64     `json:"timestamp"`
	EventType EventType `json:"event_type"`
	Triggerer string    `json:"triggerer"`
	Payload   T         `json:"payload"`
}

func NewEvent

func NewEvent[T any](triggerer string, eventType EventType, payload T) *Event[T]

type EventFlow

type EventFlow[T any] struct {
	EventType EventType
	// contains filtered or unexported fields
}

func NewEventFlow

func NewEventFlow[T any](client *Client, eventType EventType) *EventFlow[T]

func (*EventFlow[T]) Publish

func (flow *EventFlow[T]) Publish(triggerer string, payload T) (*Event[T], error)

func (*EventFlow[T]) SetCallback

func (flow *EventFlow[T]) SetCallback(callback func(event Event[T]))

func (*EventFlow[T]) Subscribe

func (flow *EventFlow[T]) Subscribe() error

func (*EventFlow[T]) Unsubscribe

func (flow *EventFlow[T]) Unsubscribe() error

type EventType

type EventType string