dataexchange

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TypeText     = internaldx.TypeText
	TypeBinary   = internaldx.TypeBinary
	TypeJSON     = internaldx.TypeJSON
	TypeFile     = internaldx.TypeFile
	MaxFrameSize = internaldx.MaxFrameSize
)

Frame types and limits.

Variables

This section is empty.

Functions

func TypeName

func TypeName(t uint32) string

func WriteFrame

func WriteFrame(w io.Writer, f *Frame) error

Wire helpers.

Types

type Client

type Client = internaldx.Client

Type aliases.

type Frame

type Frame = internaldx.Frame

Type aliases.

func ReadFrame

func ReadFrame(r io.Reader) (*Frame, error)

type Handler

type Handler = internaldx.Handler

Type aliases.

type Server

type Server = internaldx.Server

Type aliases.

type Service

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

Service is the L11 plugin adapter. Daemon (L7) holds it only as coreapi.Service; cmd/daemon/main.go (L12) constructs it.

func NewService

func NewService(cfg ServiceConfig) *Service

func (*Service) Name

func (s *Service) Name() string

func (*Service) Order

func (s *Service) Order() int

Order: 110 — after handshake (~70) and the trust subsystem (~50).

func (*Service) Start

func (s *Service) Start(ctx context.Context, deps coreapi.Deps) error

func (*Service) Stop

func (s *Service) Stop(ctx context.Context) error

type ServiceConfig

type ServiceConfig struct {
	ReceivedDir string
	InboxDir    string
	// IncludeBase64 adds a lossless `data_b64` field to inbox JSON
	// alongside `data`. Off by default — only enable when binary
	// payloads (e.g. zlib-compressed envelopes) need to round-trip
	// without UTF-8 mangling.
	IncludeBase64 bool
}

ServiceConfig configures the daemon-side dataexchange handler. Both paths default to ~/.pilot/{received,inbox} when empty.

Jump to

Keyboard shortcuts

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