Versions in this module Expand all Collapse all v0 v0.10.0 Sep 22, 2026 Changes in this version + func ConnectClient(ctx context.Context, stream net.Conn, key ed25519.PrivateKey, expected string) (*protocol.Conn, error) v0.9.0 Sep 22, 2026 Changes in this version + func ParsePeerID(id string) (ed25519.PublicKey, error) + func PeerID(key ed25519.PublicKey) string + type Bridge struct + func Open(store connect.Store, create bool) (*Bridge, error) + func (b *Bridge) AddGrant(g Grant) error + func (b *Bridge) Admin(_ context.Context, method string, params json.RawMessage) (json.RawMessage, error) + func (b *Bridge) Allowed(p connect.Principal, id, permission string) bool + func (b *Bridge) Approve(id, claimant string) error + func (b *Bridge) Attach(id, credential, boot string, endpoint connect.Endpoint) (string, error) + func (b *Bridge) Authorize(r connect.Request) bool + func (b *Bridge) Available(id string) bool + func (b *Bridge) Block(peer string) error + func (b *Bridge) Call(ctx context.Context, p connect.Principal, call connect.Call) (json.RawMessage, error) + func (b *Bridge) Catalog(p connect.Principal) []Instance + func (b *Bridge) Changes() <-chan struct{} + func (b *Bridge) Claim(peer, id, token string, locators ...string) (Invitation, error) + func (b *Bridge) Close() error + func (b *Bridge) Connect(ctx context.Context, stream net.Conn, expected string, server bool) (*protocol.Conn, string, error) + func (b *Bridge) Connection(peer string) *protocol.Conn + func (b *Bridge) Contacts(peer, scope string) ([]Record, error) + func (b *Bridge) Detach(id, generation string) + func (b *Bridge) Enroll(alias, group string) (Instance, string, error) + func (b *Bridge) Handle(ctx context.Context, peer, method string, params json.RawMessage) (json.RawMessage, error) + func (b *Bridge) Hello() Hello + func (b *Bridge) Invite(grants []Grant) (Invitation, error) + func (b *Bridge) MergeContact(sender string, r Record) (bool, error) + func (b *Bridge) Outbound(instance, peer string, call connect.Call) (connect.Subject, error) + func (b *Bridge) PairStatus(peer, id string) (Invitation, error) + func (b *Bridge) PeerID() string + func (b *Bridge) PeerLocator(peer string) (string, error) + func (b *Bridge) PersonalGroup() string + func (b *Bridge) Principal() connect.Principal + func (b *Bridge) PublishContact(scope, name string, endpoints []Locator, withdraw bool) (Record, error) + func (b *Bridge) SavePeer(peer, locator string) error + func (b *Bridge) SaveTransportState(raw json.RawMessage) error + func (b *Bridge) SetScope(id string, peers []string) error + func (b *Bridge) TLSConfig(expected string, server bool) (*tls.Config, error) + func (b *Bridge) TransportState() json.RawMessage + type Contact struct + Endpoints []Locator + Extensions map[string]json.RawMessage + Name string + Peer string + Protocols []string + Revision string + Schema string + Scope string + Withdrawn bool + type Grant struct + Destination string + GroupID string + ID string + IncludeFuture bool + Instances []string + Permissions []string + Principal connect.Principal + type Hello struct + BootID string + MaxFrame int + MaxPage int + PeerID string + Protocol string + type Instance struct + Alias string + Available bool + BootID string + Credential string + Generation string + Group string + ID string + type Invitation struct + Claimant string + ClaimantLocator string + Expires int64 + Grants []Grant + ID string + Locator string + PeerID string + Status string + Token string + type Locator struct + Locator string + Transport string + type Record struct + Payload string + Signature string + func (r Record) Verify() (Contact, error)