dwp

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

type APIKeyEntry struct {
	Token    string
	Identity Identity
}

type AuthRequest struct {
	Token  string `json:"token"`
	Format string `json:"format,omitempty"` // "json" (default), "msgpack", "protobuf"
}

type AuthResponse struct {
	Format    string `json:"format"`
	SessionID string `json:"session_id"`
}

type Authenticator interface {
	Authenticate(ctx context.Context, token string) (*Identity, error)
}

type Codec interface {
	// Encode serializes a frame to bytes.
	Encode(frame *Frame) ([]byte, error)

	// Decode deserializes bytes into a frame.
	Decode(data []byte) (*Frame, error)

	// Name returns the codec identifier (e.g., "json", "msgpack", "protobuf").
	Name() string
}

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

type Connection struct {
	// ID uniquely identifies this connection.
	ID string

	// Identity is the authenticated identity for this connection.
	Identity *Identity

	// Codec is the negotiated wire format.
	Codec Codec

	// ConnectedAt records when the connection was established.
	ConnectedAt time.Time

	// LastActivity tracks the most recent frame received.
	LastActivity atomic.Value // time.Time
	// contains filtered or unexported fields
}

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

type ErrorDetail struct {
	Code    int    `json:"code" msgpack:"code"`
	Message string `json:"message" msgpack:"message"`
	Details string `json:"details,omitempty" msgpack:"details,omitempty"`
}

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

type FederationEnqueueRequest struct {
	Name     string          `json:"name"`
	Payload  json.RawMessage `json:"payload"`
	Queue    string          `json:"queue,omitempty"`
	Priority int             `json:"priority,omitempty"`
	SourceID string          `json:"source_id"` // ID of the originating peer
}

type FederationEventRequest struct {
	Name     string          `json:"name"`
	Payload  json.RawMessage `json:"payload,omitempty"`
	SourceID string          `json:"source_id"`
}

type FederationHeartbeatRequest struct {
	PeerID string `json:"peer_id"`
}

type FederationOption func(*Federation)

type FederationStats struct {
	TotalPeers      int   `json:"total_peers"`
	ConnectedPeers  int   `json:"connected_peers"`
	JobsForwarded   int64 `json:"jobs_forwarded"`
	EventsForwarded int64 `json:"events_forwarded"`
}

type ForgeAuthenticator struct{ Auth security.Authenticator }

type Frame struct {
	// ID uniquely identifies this frame (ULID or UUID).
	ID string `json:"id" msgpack:"id"`

	// Type categorizes the frame.
	Type FrameType `json:"type" msgpack:"type"`

	// Method names the operation for request frames (e.g., "job.enqueue").
	Method string `json:"method,omitempty" msgpack:"method,omitempty"`

	// CorrelID links a response to its originating request.
	CorrelID string `json:"correl_id,omitempty" msgpack:"correl_id,omitempty"`

	// Token carries auth credentials (typically only on the auth frame).
	Token string `json:"token,omitempty" msgpack:"token,omitempty"`

	// AppID scopes the request to a tenant application.
	AppID string `json:"app_id,omitempty" msgpack:"app_id,omitempty"`

	// OrgID scopes the request to a tenant organization.
	OrgID string `json:"org_id,omitempty" msgpack:"org_id,omitempty"`

	// Data carries the method-specific payload.
	Data json.RawMessage `json:"data,omitempty" msgpack:"data,omitempty"`

	// Error carries error details for error frames.
	Error *ErrorDetail `json:"error,omitempty" msgpack:"error,omitempty"`

	// Channel identifies the subscription channel for event/subscribe frames.
	Channel string `json:"channel,omitempty" msgpack:"channel,omitempty"`

	// Credits replenishes flow-control credits (backpressure).
	Credits int `json:"credits,omitempty" msgpack:"credits,omitempty"`

	// Timestamp records when this frame was created.
	Timestamp time.Time `json:"ts" msgpack:"ts"`
}

type FrameType string

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

type Identity struct {
	Kind string `json:"kind,omitempty"`
	// Subject is the authenticated user/service ID.
	Subject string `json:"subject"`

	// AppID scopes to a tenant application.
	AppID string `json:"app_id,omitempty"`

	// OrgID scopes to a tenant organization.
	OrgID string `json:"org_id,omitempty"`

	// Scopes defines what operations are permitted.
	// Examples: "job:write", "workflow:read", "admin", "*"
	Scopes []string `json:"scopes,omitempty"`
}

type JSONCodec struct{}

type JobCancelRequest struct {
	JobID string `json:"job_id"`
}

type JobEnqueueRequest struct {
	Name     string          `json:"name"`
	Payload  json.RawMessage `json:"payload"`
	Queue    string          `json:"queue,omitempty"`
	Priority int             `json:"priority,omitempty"`
}

type JobEnqueueResponse struct {
	JobID string `json:"job_id"`
	Queue string `json:"queue"`
	State string `json:"state"`
}

type JobGetRequest struct {
	JobID string `json:"job_id"`
}

type MsgpackCodec struct{}

type NoopAuthenticator struct{}

type Option func(*Server)

type Peer struct {
	// ID uniquely identifies this peer (typically hostname:port).
	ID string

	// URL is the WebSocket endpoint for the peer's DWP server.
	URL string

	// Token is the authentication token for the peer.
	Token string

	// State tracks the connection state.
	State PeerState

	// LastSeen is the timestamp of the last heartbeat.
	LastSeen time.Time

	// Metadata carries arbitrary peer information.
	Metadata map[string]string
	// contains filtered or unexported fields
}

type PeerState string

type RejectAuthenticator struct{}

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

type SubscribeRequest struct {
	Channel string `json:"channel"`
	Credits int    `json:"credits,omitempty"` // Initial credits (0 = use default)
}

type UnsubscribeRequest struct {
	Channel string `json:"channel"`
}

type WorkflowCancelRequest struct {
	RunID string `json:"run_id"`
}

type WorkflowEventRequest struct {
	Name    string          `json:"name"`
	Payload json.RawMessage `json:"payload,omitempty"`
}

type WorkflowGetRequest struct {
	RunID string `json:"run_id"`
}

type WorkflowStartRequest struct {
	Name  string          `json:"name"`
	Input json.RawMessage `json:"input"`
}

type WorkflowStartResponse struct {
	RunID string `json:"run_id"`
	Name  string `json:"name"`
	State string `json:"state"`
}

type WorkflowTimelineRequest struct {
	RunID string `json:"run_id"`
}