service

package

v0.0.0-...-5a53b6d Latest Latest Go to latest Published: May 3, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Connector[T any] func(ctx context.Context) (T, error)

Connector represents a function that attempts to connect to a service

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

Service wraps a connection to an external service with reconnection capabilities

func New[T any](name string, connector Connector[T]) *Service[T]

New creates a new service wrapper

func (s *Service[T]) Connect(ctx context.Context) (T, error)

Connect attempts to connect to the service, retrying every 500ms for 3 seconds

func (s *Service[T]) ConnectedChan() <-chan bool

func (s *Service[T]) Get(ctx context.Context) (T, error)

Get returns the current client, attempting to connect if not connected

func (s *Service[T]) IsConnected() bool

IsConnected returns whether the service is currently connected

func (s *Service[T]) StartReconnectLoop(ctx context.Context)

StartReconnectLoop starts a goroutine that attempts to connect periodically, to check whether the service is still available.