services

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

type Component interface {
	Name() (name string)
	Construct(options Options) (err error)
	Shutdown(ctx context.Context)
}

type Components []Component

type Config map[string]json.RawMessage

type Empty struct{}

type Endpoint interface {
	Name() (name string)
	Internal() (ok bool)
	Document() (document documents.Endpoint)
	Functions() (functions Fns)
	Shutdown(ctx context.Context)
}

type EndpointGetOption func(options *EndpointGetOptions)

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

type EndpointInfo struct {
	Id        string             `json:"id"`
	Version   versions.Version   `json:"version"`
	Address   string             `json:"address"`
	Name      string             `json:"name"`
	Internal  bool               `json:"internal"`
	Functions FnInfos            `json:"functions"`
	Document  documents.Endpoint `json:"document"`
}

type EndpointInfos []EndpointInfo

type Endpoints interface {
	Info() (infos EndpointInfos)
	Get(ctx context.Context, name []byte, options ...EndpointGetOption) (endpoint Endpoint, has bool)
	RequestAsync(ctx context.Context, name []byte, fn []byte, param any, options ...RequestOption) (future futures.Future, err error)
	Request(ctx context.Context, name []byte, fn []byte, param any, options ...RequestOption) (response Response, err error)
}

type EndpointsManager interface {
	Endpoints
	Add(service Service) (err error)
	Listen(ctx context.Context) (err error)
	Shutdown(ctx context.Context)
}

type Fn interface {
	Name() string
	Internal() bool
	Readonly() bool
	Handle(ctx Request) (v any, err error)
}

type FnInfo struct {
	Name     string `json:"name"`
	Readonly bool   `json:"readonly"`
	Internal bool   `json:"internal"`
}

type FnInfos []FnInfo

type FnTask struct {
	Fn      Fn
	Promise futures.Promise
}

type Fns []Fn

type HashRequestOption func(options *HashRequestOptions)

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

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

type Listenable interface {
	Service
	// Listen
	// ctx with runtime
	Listen(ctx context.Context) (err error)
}

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

type Middleware interface {
	transports.Middleware
	Services() []Service
}

type MuxHandler interface {
	transports.MuxHandler
	Services() []Service
}

type Options struct {
	Id      string
	Version versions.Version
	Log     logs.Logger
	Config  configures.Config
}

type Param interface {
	objects.Object
}

type Request interface {
	context.Context
	Fn() (endpoint []byte, fn []byte)
	Header() (header Header)
	Param() (param Param)
}

type RequestOption func(*RequestOptions)

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

type Response interface {
	objects.Object
}

type Service interface {
	Endpoint
	Construct(options Options) (err error)
	Components() (components Components)
}

type Services []Service