disco_go

type Client interface {
	ClientId() string
	ServiceId() string
	State() api.ClientState
	Endpoint(typ api.EndpointType) (string, error)
	Field(key string) (any, bool)
}

type DiscoClient interface {

	// Leave - unregister client from disco server
	Leave() error

	// Registry - get registry object
	Registry() DiscoRegistry
}

type DiscoClientConfig struct {
	Login                  string
	Password               string
	Token                  string
	DiscoEndpoints         []string
	ClientName             string
	ClientEndpoints        []string
	ClientMeta             map[string]any
	ClientTimeout          time.Duration
	ClientBreakThreshold   uint
	ClientRetryAttempts    uint
	ClientRetryInterval    time.Duration
	PerformSslVerification bool
}

type DiscoRegistry interface {

	// Services - list all registered services
	Services() []string

	// List - list all registered clients
	List() []Client

	// Get - get client for registered service
	//       (only in UP state; next from ring buffer)
	Get(service string) (Client, error)

	// Sync - synchronize registrations data
	Sync(clients []Client)

	// Reset - reset local discovery cache
	Reset()
}

type LoadBalancingHttpClient interface {
	Get(url string, headers map[string]string) ([]byte, map[string]string, int, error)
	GetWithParams(url string, params map[string]any, headers map[string]string) ([]byte, map[string]string, int, error)
}