mess

package module

Go to main page

Versions in this module

v0

v0.0.12

Jan 30, 2026

Changes in this version

+ const MaxNodeID

v0.0.11

Jan 16, 2026

v0.0.10

Jan 16, 2026

v0.0.9

Jan 15, 2026

Changes in this version

+ const EnvAlias

type Environment

+ Alias []string

v0.0.8

Jan 15, 2026

v0.0.7

Jan 6, 2026

Changes in this version

type EventCursor

+ func (ec EventCursor) Clone() EventCursor

+ func (ec EventCursor) Merge(cursor EventCursor) EventCursor

+ func (ec EventCursor) Nodes() []uint64

+ func (ec EventCursor) Set(uuid monotime.UUID) EventCursor

type Subscription

+ func (s *Subscription) Update(uuid monotime.UUID) error

v0.0.6

Jan 6, 2026

v0.0.5

Jan 2, 2026

Changes in this version

type API

+ func (a API) Resolve(ctx context.Context, service string) (NodeList, error)

type NodeState

+ func (ns *NodeState) Resolve(service string) NodeList

type Service

+ func (s *Service) HasAlias(alias string) bool

v0.0.4

Jan 2, 2026

Changes in this version

type API

+ func (a API) Peers(ctx context.Context, service string) (NodeList, error)

type NodeList

+ func (nl NodeList) Clone() NodeList

type NodeState

+ func (ns *NodeState) Peers(service string) NodeList

type Services

+ func (s Services) Filter(fn func(*Service) bool) Services

v0.0.3

Jan 2, 2026

Changes in this version

type Service

+ Private bool

v0.0.2

Dec 29, 2025

v0.0.1

Dec 28, 2025

Changes in this version

+ const CallerHeader

+ const EnvDataDir

+ const EnvMode

+ const EnvNodeID

+ const EnvProxy

+ const EnvRealm

+ const EnvService

+ const MaxEventSize

+ const PublicPort

+ const ServiceName

+ const TargetNodeHeader

+ const TargetRealmHeader

+ const TargetServiceHeader

+ var DefaultAPI = API

+ var DefaultClient = NewClient()

+ var ErrInternalEndpoint = errors.New("internal endpoint")

+ var ErrInterrupt = errors.New("system interrupt")

+ var ErrInvalidNode = errors.New("invalid node")

+ var ErrNoCertProvided = errors.New("no certificates provided")

+ var ErrSubscriptionExists = errors.New("subscription already exists")

+ var ErrSubscriptionNotExist = errors.New("subscription does not exist")

+ func DialContext(ctx context.Context, _ string, _ string) (net.Conn, error)

+ func DialH2CContext(ctx context.Context, _, _ string, _ *tls.Config) (net.Conn, error)

+ func NewClient() *http.Client

+ func NewCustomClient(node uint64, realm string, service string) *http.Client

+ type API struct

+ Client *http.Client

+ func (a API) CreateSubscription(filename string, topic string, cursor EventCursor) (*Subscription, error)

+ func (a API) Emit(ctx context.Context, req EmitRequest) error

+ func (a API) Listen(ctx context.Context, topic string) (<-chan *Event, error)

+ func (a API) NextNamedSequence(ctx context.Context, name string) (uint64, error)

+ func (a API) NextSequence(ctx context.Context) (uint64, error)

+ func (a API) OpenSubscription(topic string, filename string) (*Subscription, error)

+ func (a API) Publish(ctx context.Context, req PublishRequest) error

+ func (a API) State(ctx context.Context) (*NodeState, error)

+ func (a API) Subscribe(ctx context.Context, req SubscribeRequest, handler func(*Event) (bool, error)) error

+ type EmitRequest struct

+ Events []json.RawMessage

+ Meta []MetaField

+ Topic string

+ type Environment struct

+ DataDir string

+ Dev bool

+ Mode string

+ NodeID uint64

+ Proxy string

+ ProxyAddr string

+ ProxyNetwork string

+ Realm string

+ Service string

+ func Env() Environment

+ type Event struct

+ Data json.RawMessage

+ ID monotime.UUID

+ Meta []MetaField

+ Topic string

+ type EventCursor []monotime.UUID

+ func (ec EventCursor) ExtractNode(id uint64) monotime.UUID

+ func (ec EventCursor) Update(uuid monotime.UUID) EventCursor

+ type EventsRequest struct

+ Filter []MetaFilter

+ Limit uint64

+ Offset monotime.UUID

+ Realm string

+ Stream bool

+ Topic string

+ type ListenMap map[string][]string

+ func (cm ListenMap) Clone() ListenMap

+ func (cm ListenMap) Has(realm, topic string) bool

+ type ListenRequest struct

+ Topic string

+ type LogRecord struct

+ Data json.RawMessage

+ ID int64

+ type LogsRequest struct

+ Limit uint64

+ Offset int64

+ Realm string

+ Service string

+ Stream bool

+ type MetaField struct

+ Key string

+ Value string

+ type MetaFilter struct

+ Any []string

+ Key string

+ Not []string

+ type Node struct

+ Addr string

+ Bind string

+ CertExpires int64

+ Country string

+ Datacenter string

+ ID uint64

+ LastSync int64

+ Listen ListenMap

+ Meta map[string]string

+ Publish PublishMap

+ Region string

+ Services Services

+ func (n *Node) Address() string

+ func (n *Node) Clone() *Node

+ func (n *Node) Get(service string) *Service

+ func (n *Node) Has(service string) bool

+ func (n *Node) Location() string

+ func (n *Node) ProximitySort(a, b *Node) int

+ type NodeList []*Node

+ func (nl NodeList) Filter(fn func(n *Node) bool) NodeList

+ type NodeMap map[uint64]*Node

+ func (nm NodeMap) Clone() NodeMap

+ func (nm NodeMap) Filter(fn func(n *Node) bool) NodeList

+ func (nm NodeMap) Get(id uint64) *Node

+ func (nm NodeMap) List() NodeList

+ type NodeState struct

+ Map NodeMap

+ Node *Node

+ func (ns *NodeState) Clone() *NodeState

+ func (ns *NodeState) Filter(fn func(n *Node) bool) NodeList

+ func (ns *NodeState) GetNode(id uint64) *Node

+ func (ns *NodeState) NodesByProximity() NodeList

+ type PublishMap map[string]map[string]monotime.UUID

+ func (pm PublishMap) Clone() PublishMap

+ func (pm PublishMap) Has(realm, topic string) bool

+ type PublishRequest struct

+ Events []json.RawMessage

+ Meta []MetaField

+ Topic string

+ type RoundTripper struct

+ Node uint64

+ Realm string

+ Service string

+ func NewCustomTransport(node uint64, realm string, service string) RoundTripper

+ func NewTransport() RoundTripper

+ func (r RoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

+ type Service struct

+ Active bool

+ Alias []string

+ Args []string

+ Env []string

+ Listen string

+ Manual bool

+ Meta map[string]string

+ Name string

+ Order int

+ Passive bool

+ Proxy string

+ Realm string

+ Start string

+ Timeout int

+ func (s *Service) Clone() *Service

+ type Services []*Service

+ func (s Services) Clone() Services

+ func (s Services) Get(service string) *Service

+ func (s Services) Has(service string) bool

+ type SubscribeRequest struct

+ Cursor EventCursor

+ Filter []MetaFilter

+ Topic string

+ type Subscription struct

+ func (s *Subscription) Close() error

+ func (s *Subscription) Cursor() EventCursor

+ func (s *Subscription) Receive(ctx context.Context, filter []MetaFilter, handler func(*Event) (bool, error)) (err error)

+ func (s *Subscription) Topic() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL