[FEATURE] новый метод для broker #358

New Issue

vtolstov · 2024-11-20T22:46:53+03:00

vtolstov commented

2024-11-20 22:46:53 +03:00


type EventType int

const (
  EventTypeUnknown = iota
  EventTypeConnect
  EventTypeDisconnect
)

type Event interface {
  Error() error
  Type EventType
  
}

type Watcher interface {
	// Next is a blocking call
	Next() (Event, error)
	// Stop stops the watcher
	Stop()
}

func Watch(context.Context) (Watcher, error)

суть - при изменении внутреннего состояния - дисконнект, реконнект, ошибка подключения и тп - выкидывать ивент соответсвующего типа

```go type EventType int const ( EventTypeUnknown = iota EventTypeConnect EventTypeDisconnect ) type Event interface { Error() error Type EventType } type Watcher interface { // Next is a blocking call Next() (Event, error) // Stop stops the watcher Stop() } func Watch(context.Context) (Watcher, error) ``` суть - при изменении внутреннего состояния - дисконнект, реконнект, ошибка подключения и тп - выкидывать ивент соответсвующего типа

Sign in to join this conversation.