transport

package
v0.1.21 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2026 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHTTPHandler

func NewHTTPHandler(service Service, policy *authn.Policy, configs ...HTTPConfig) http.Handler

Types

type ConsoleAnalyticsConfig added in v0.1.11

type ConsoleAnalyticsConfig struct {
	Provider      string
	MeasurementID string
}

type ConsoleConfig added in v0.1.11

type ConsoleConfig struct {
	Analytics ConsoleAnalyticsConfig
}

type HTTPConfig added in v0.1.11

type HTTPConfig struct {
	PublicBaseURL string
	ClockIdentity string
	Console       ConsoleConfig
}

type Service

type Service interface {
	Health(ctx context.Context) error
	Network() protocol.Network
	GetAgent(agentID string) (protocol.AgentSummary, error)
	GetAgentContext(ctx context.Context, agentID string) (protocol.AgentSummary, error)
	GetDirectConversationContext(ctx context.Context, dmID string) (protocol.DirectConversation, error)
	GetRoom(roomID string) (protocol.Room, error)
	GetRoomContext(ctx context.Context, roomID string) (protocol.Room, error)
	GetThread(threadID string) (protocol.Thread, error)
	GetThreadContext(ctx context.Context, threadID string) (protocol.Thread, error)
	ListAgentsContext(ctx context.Context, page protocol.PageRequest) (protocol.AgentPage, error)
	ListPairingsContext(ctx context.Context, page protocol.PageRequest) (protocol.PairingPage, error)
	PairingForPairScopedContext(ctx context.Context) (protocol.Pairing, bool)
	PairingNetwork(ctx context.Context, pairingID string) (protocol.Network, error)
	PairingRoomsContext(ctx context.Context, pairingID string, page protocol.PageRequest) (protocol.RoomPage, error)
	PairingAgentsContext(ctx context.Context, pairingID string, page protocol.PageRequest) (protocol.AgentPage, error)
	ListRoomsContext(ctx context.Context, page protocol.PageRequest) (protocol.RoomPage, error)
	ApplyConfigContext(ctx context.Context, request protocol.ApplyConfigRequest) (protocol.ApplyConfigResult, error)
	CreateRoomContext(ctx context.Context, request protocol.CreateRoomRequest) (protocol.Room, error)
	JoinRoomContext(ctx context.Context, roomID string, request protocol.JoinRoomRequest) (protocol.Room, error)
	RemoveRoomContext(ctx context.Context, roomID string) (protocol.RemoveResult, error)
	UpdateRoomMembers(ctx context.Context, roomID string, request protocol.UpdateRoomMembersRequest) (protocol.Room, error)
	RegisterAgentContext(ctx context.Context, request protocol.RegisterAgentRequest) (store.RegistrationResult, error)
	RemoveAgentContext(ctx context.Context, agentID string) (protocol.RemoveResult, error)
	AgentConnected(ctx context.Context, agent protocol.Actor)
	AgentDisconnected(ctx context.Context, agent protocol.Actor, reason string, err error)
	AgentWakeDelivered(ctx context.Context, agent protocol.Actor, event protocol.Event)
	AgentWakeFailed(ctx context.Context, agent protocol.Actor, event protocol.Event, err error, details protocol.WakeFailureDetails)
	ListRoomMessagesContext(ctx context.Context, roomID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListThreadsContext(ctx context.Context, roomID string, page protocol.PageRequest) (protocol.ThreadPage, error)
	ListThreadMessagesContext(ctx context.Context, threadID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListDirectConversationsContext(ctx context.Context, page protocol.PageRequest) (protocol.DirectConversationPage, error)
	ListDMMessagesContext(ctx context.Context, dmID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListArtifactsContext(ctx context.Context, filter protocol.ArtifactFilter, page protocol.PageRequest) (protocol.ArtifactPage, error)
	SendMessageContext(ctx context.Context, request protocol.SendMessageRequest) (protocol.MessageAccepted, error)
	AuthenticateAgentTokenContext(ctx context.Context, token string) (authn.Claims, bool, error)
	Subscribe(ctx context.Context) <-chan protocol.Event
	SubscribeFromContext(ctx context.Context, lastEventID string) (<-chan protocol.Event, error)
}

Jump to

Keyboard shortcuts

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