api

type Client interface {
	ClientId() string
	ServiceId() string
	Tenant() string
	Endpoints() []Endpoint
	Meta() map[string]any
	Ping() bool
	LastSeen() time.Time
	State() ClientState
	SetState(state ClientState)
	SetDirty(value bool)
	IsDirty() bool
}

type ClientState uint8

type Duration struct {
	time.Duration
}

type Endpoint interface {
	Url() string
	Type() EndpointType
}

type EndpointType uint8

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

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

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

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

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

type JoinRequest struct {
	ServiceId string         `json:"service,omitempty"`
	Endpoints []string       `json:"endpoints,omitempty"`
	Meta      map[string]any `json:"meta,omitempty"`
}

type JoinResponse struct {
	ClientId     string   `json:"id,omitempty"`
	PingInterval Duration `json:"interval,omitempty"`
}

type Ping struct {
}

type Pong struct {
	Response PongType `json:"response"`
	Error    string   `json:"error"`
}

type PongType uint8

type Registry interface {
	Join(ctx context.Context, request JoinRequest) (*JoinResponse, error)
	Leave(ctx context.Context, clientId string) error
	List(ctx context.Context) []Client
	Ping(clientId string) (Pong, error)
}

type Tenant interface {
	Name() string
	Clients() []Client
	Get(clientId string) Client
	Set(clientId string, client Client)
	Delete(clientId string)
}