clusters

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

type BarrierConfig struct {
	TTL        time.Duration `json:"ttl"`
	Interval   time.Duration `json:"interval"`
	Standalone bool          `json:"standalone"`
}

type BarrierValue []byte

type Cluster interface {
	Construct(options ClusterOptions) (err error)
	AddService(service Service)
	Join(ctx context.Context) (err error)
	Leave(ctx context.Context) (err error)
	NodeEvents() (events <-chan NodeEvent)
	Shared() (shared shareds.Shared)
}

type ClusterBuilderOptions struct {
	Config configures.Config
	Log    logs.Logger
}

type ClusterEndpointsManager interface {
	services.EndpointsManager
	Address() string
	PublicFnAddress(ctx context.Context, endpoint []byte, fnName []byte, options ...services.EndpointGetOption) (address string, has bool)
}

type ClusterOptions struct {
	Log     logs.Logger
	Config  configures.Config
	Id      string
	Name    string
	Version versions.Version
	Address string
}

type Config struct {
	Secret        string          `json:"secret"`
	HostRetriever string          `json:"hostRetriever"`
	Barrier       BarrierConfig   `json:"barrier"`
	Name          string          `json:"name"`
	Proxy         bool            `json:"proxy"`
	Option        json.RawMessage `json:"option"`
}

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

type DevelopmentConfig struct {
	ProxyAddr string `json:"proxyAddr"`
}

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

type Endpoints []*Endpoint

type Entry struct {
	Key []byte          `json:"key"`
	Val json.RawMessage `json:"val"`
}

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

type HostRetriever func() (host string, err error)

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

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

type Node struct {
	Id       string           `json:"id"`
	Version  versions.Version `json:"version"`
	Address  string           `json:"address"`
	Services []Service        `json:"services"`
}

type NodeEvent struct {
	Kind NodeEventKind
	Node Node
}

type NodeEventKind int

type Nodes []Node

type Options struct {
	Id      string
	Name    string
	Version versions.Version
	Port    int
	Log     logs.Logger
	Worker  workers.Workers
	Local   services.EndpointsManager
	Dialer  transports.Dialer
	Config  Config
}

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

type Registrations []*Registration

type RequestBody struct {
	ContextUserValues []Entry         `json:"contextUserValues"`
	Params            json.RawMessage `json:"params"`
}

type ResponseAttachment struct {
	Name  string          `json:"name"`
	Value json.RawMessage `json:"value"`
}

type ResponseAttachments []ResponseAttachment

type ResponseBody struct {
	Succeed     bool                `json:"succeed"`
	Data        json.RawMessage     `json:"data"`
	Attachments ResponseAttachments `json:"attachments"`
}

type Service struct {
	Name        string           `json:"name"`
	Internal    bool             `json:"internal"`
	Functions   services.FnInfos `json:"functions"`
	DocumentRaw []byte           `json:"document"`
}