agentremote

package module

Go to main page

Versions in this module

v0

v0.0.3

Mar 26, 2026

Changes in this version

+ const ApprovalReactionAliasAllowAlways

+ const ApprovalReactionAliasAllowOnce

+ const ApprovalReactionAliasDeny

+ func ApplyAgentRemoteBridgeInfo(content *event.BridgeEventContent, protocolID string, ...)

+ func LoginErrorCode(parts ...string) string

+ func NewLoginRespError(statusCode int, message string, parts ...string) bridgev2.RespError

+ func WrapLoginRespError(err error, statusCode int, parts ...string) bridgev2.RespError

type ApprovalDecisionPayload

+ ReactionKey string

type ApprovalPromptMessage

+ Content *event.MessageEventContent

+ TopLevelExtra map[string]any

type ApprovalPromptMessageParams

+ ThreadRootEventID id.EventID

type ApprovalPromptRegistration

+ ReactionTargetMessageID networkid.MessageID

type ReactionContext

+ TargetMessageID networkid.MessageID

v0.0.1

Mar 24, 2026

Changes in this version

+ const AIRoomKindAgent

+ const ApprovalPromptStateRequested

+ const ApprovalPromptStateResponded

+ const ApprovalReactionKeyAllowAlways

+ const ApprovalReactionKeyAllowOnce

+ const ApprovalReactionKeyDeny

+ const ApprovalReasonAllowAlways

+ const ApprovalReasonAllowOnce

+ const ApprovalReasonAutoApproved

+ const ApprovalReasonCancelled

+ const ApprovalReasonDeliveryError

+ const ApprovalReasonDeny

+ const ApprovalReasonExpired

+ const ApprovalReasonTimeout

+ const DefaultApprovalExpiry

+ const RejectReasonExpired

+ const RejectReasonInvalidOption

+ const RejectReasonOwnerOnly

+ var ErrApprovalAlreadyHandled = errors.New("approval already resolved")

+ var ErrApprovalExpired = errors.New("approval expired")

+ var ErrApprovalMissingID = errors.New("missing approval id")

+ var ErrApprovalMissingRoom = errors.New("missing room id")

+ var ErrApprovalOnlyOwner = errors.New("only the owner can approve")

+ var ErrApprovalUnknown = errors.New("unknown or expired approval id")

+ var ErrApprovalWrongRoom = errors.New("approval id does not belong to this room")

+ var MediaMessageTypes = []event.MessageType

+ func ApplyAIBridgeInfo(content *event.BridgeEventContent, protocolID string, ...)

+ func ApprovalErrorToastText(err error) string

+ func BuildApprovalPromptBody(presentation ApprovalPromptPresentation, options []ApprovalOption) string

+ func BuildApprovalResponseBody(presentation ApprovalPromptPresentation, decision ApprovalDecisionPayload) string

+ func BuildBotUserInfo(name string, identifiers ...string) *bridgev2.UserInfo

+ func BuildChatInfoWithFallback(metaTitle, portalName, fallbackTitle, portalTopic string) *bridgev2.ChatInfo

+ func BuildContinuationMessage(portal networkid.PortalKey, body string, sender bridgev2.EventSender, ...) *simplevent.PreConvertedMessage

+ func BuildDMChatInfo(p DMChatInfoParams) *bridgev2.ChatInfo

+ func BuildLoginDMChatInfo(p LoginDMChatInfoParams) *bridgev2.ChatInfo

+ func BuildMediaFileFeatureMap(build func() *event.FileFeatures) event.FileFeatureMap

+ func BuildMetaTypes(portal, message, userLogin, ghost func() any) database.MetaTypes

+ func BuildReactionEvent(portal networkid.PortalKey, sender bridgev2.EventSender, ...) *simplevent.Reaction

+ func BuildReactionRemoveEvent(portal networkid.PortalKey, sender bridgev2.EventSender, ...) *simplevent.Reaction

+ func BuildRoomFeatures(p RoomFeaturesParams) *event.RoomFeatures

+ func BuildSystemNotice(body string) *bridgev2.ConvertedMessage

+ func CompleteLoginStep(stepID string, login *bridgev2.UserLogin) *bridgev2.LoginStep

+ func ComputeApprovalExpiry(ttlSeconds int) time.Time

+ func CreateAndCompleteLogin(persistCtx context.Context, connectCtx context.Context, user *bridgev2.User, ...) (*bridgev2.UserLogin, *bridgev2.LoginStep, error)

+ func DecisionToString(decision ApprovalDecisionPayload, once, always, deny string) string

+ func DefaultBridgeInfoVersion() (info, capabilities int)

+ func DefaultNetworkCapabilities() *bridgev2.NetworkGeneralCapabilities

+ func DownloadAndEncodeMedia(ctx context.Context, login *bridgev2.UserLogin, mediaURL string, ...) (string, string, error)

+ func DownloadMediaBytes(ctx context.Context, login *bridgev2.UserLogin, mediaURL string, ...) ([]byte, string, error)

+ func EnsureClientMap(mu *sync.Mutex, clients *map[networkid.UserLoginID]bridgev2.NetworkAPI)

+ func EnsureLoginMetadata[T any](login *bridgev2.UserLogin) *T

+ func EnsureMetadata[T any](holder *any) *T

+ func EnsurePortalMetadata[T any](portal *bridgev2.Portal) *T

+ func EnsureReactionContent(msg *bridgev2.MatrixReaction) *event.ReactionEventContent

+ func EnsureSyntheticReactionSenderGhost(ctx context.Context, login *bridgev2.UserLogin, userID id.UserID) error

+ func ExpandUserHome(path string) (string, error)

+ func HumanUserID(prefix string, loginID networkid.UserLoginID) networkid.UserID

+ func IsMatrixBotUser(ctx context.Context, bridge *bridgev2.Bridge, userID id.UserID) bool

+ func LoadConnectAndCompleteLogin(persistCtx context.Context, connectCtx context.Context, ...) (*bridgev2.LoginStep, error)

+ func LoadOrCreateClient(mu *sync.Mutex, clients map[networkid.UserLoginID]bridgev2.NetworkAPI, ...) (bridgev2.NetworkAPI, error)

+ func LoadOrCreateTypedClient[T bridgev2.NetworkAPI](mu *sync.Mutex, clients map[networkid.UserLoginID]bridgev2.NetworkAPI, ...) (T, error)

+ func LoadUserLogin[C bridgev2.NetworkAPI](login *bridgev2.UserLogin, cfg LoadUserLoginConfig[C]) error

+ func LoggerFromContext(ctx context.Context, fallback *zerolog.Logger) *zerolog.Logger

+ func MakeUserLoginID(prefix string, mxid id.UserID, ordinal int) networkid.UserLoginID

+ func MatrixEventTimestamp(evt *event.Event) time.Time

+ func MatrixMessageID(eventID id.EventID) networkid.MessageID

+ func MatrixSenderID(userID id.UserID) networkid.UserID

+ func MessageSendStatusError(err error, message string, reason event.MessageStatusReason, ...) error

+ func NewEventID(prefix string) id.EventID

+ func NewMessageID(prefix string) networkid.MessageID

+ func NewTurnID() string

+ func NextUserLoginID(user *bridgev2.User, prefix string) networkid.UserLoginID

+ func NormalizeAIRoomTypeV2(roomType database.RoomType, aiKind string) string

+ func NormalizeAbsolutePath(path string) (string, error)

+ func NormalizeUIParts(raw any) []map[string]any

+ func PreHandleApprovalReaction(msg *bridgev2.MatrixReaction) (bridgev2.MatrixReactionPreResponse, error)

+ func PrimeUserLoginCache(ctx context.Context, br *bridgev2.Bridge)

+ func RedactApprovalPromptPlaceholderReactions(ctx context.Context, login *bridgev2.UserLogin, portal *bridgev2.Portal, ...) error

+ func RedactEventAsSender(ctx context.Context, login *bridgev2.UserLogin, portal *bridgev2.Portal, ...) error

+ func RemoveClientFromCache(mu *sync.Mutex, clients map[networkid.UserLoginID]bridgev2.NetworkAPI, ...)

+ func SendAIRoomInfo(ctx context.Context, portal *bridgev2.Portal, aiKind string) bool

+ func SendEditViaPortal(login *bridgev2.UserLogin, portal *bridgev2.Portal, ...) error

+ func SendMatrixMessageStatus(ctx context.Context, portal *bridgev2.Portal, evt *event.Event, ...)

+ func SendViaPortal(p SendViaPortalParams) (id.EventID, networkid.MessageID, error)

+ func SingleLoginFlow(enabled bool, flow bridgev2.LoginFlow) []bridgev2.LoginFlow

+ func StopClients(mu *sync.Mutex, clients *map[networkid.UserLoginID]bridgev2.NetworkAPI)

+ func TypedClientLoader[C bridgev2.NetworkAPI](spec TypedClientLoaderSpec[C]) func(context.Context, *bridgev2.UserLogin) error

+ func UnsupportedMessageStatus(err error) error

+ func UpdateAndCompleteLogin(persistCtx context.Context, connectCtx context.Context, ...) (*bridgev2.LoginStep, error)

+ func UpsertAssistantMessage(ctx context.Context, p UpsertAssistantMessageParams)

+ func ValidateLoginState(user *bridgev2.User, br *bridgev2.Bridge) error

+ func ValidateSingleLoginFlow(flowID, expectedFlowID string, enabled bool) error

+ func ValueSummary(value any) string

+ type Aborter interface

+ Abort func(reason string)

+ type ApprovalDecisionPayload struct

+ Always bool

+ ApprovalID string

+ Approved bool

+ Reason string

+ ResolvedBy ApprovalResolutionOrigin

+ type ApprovalDetail struct

+ Label string

+ Value string

+ func AddOptionalDetail(input map[string]any, details []ApprovalDetail, key, label string, ptr *string) (map[string]any, []ApprovalDetail)

+ func AppendDetailsFromMap(details []ApprovalDetail, labelPrefix string, values map[string]any, max int) []ApprovalDetail

+ type ApprovalFlow struct

+ func NewApprovalFlow[D any](cfg ApprovalFlowConfig[D]) *ApprovalFlow[D]

+ func (f *ApprovalFlow[D]) Close()

+ func (f *ApprovalFlow[D]) Drop(approvalID string)

+ func (f *ApprovalFlow[D]) FindByData(predicate func(data D) bool) string

+ func (f *ApprovalFlow[D]) FinishResolved(approvalID string, decision ApprovalDecisionPayload)

+ func (f *ApprovalFlow[D]) Get(approvalID string) *Pending[D]

+ func (f *ApprovalFlow[D]) HandleReaction(ctx context.Context, msg *bridgev2.MatrixReaction, targetEventID id.EventID, ...) bool

+ func (f *ApprovalFlow[D]) HandleReactionRemove(ctx context.Context, msg *bridgev2.MatrixReactionRemove) bool

+ func (f *ApprovalFlow[D]) PendingIDs() []string

+ func (f *ApprovalFlow[D]) Register(approvalID string, ttl time.Duration, data D) (*Pending[D], bool)

+ func (f *ApprovalFlow[D]) Resolve(approvalID string, decision ApprovalDecisionPayload) error

+ func (f *ApprovalFlow[D]) ResolveExternal(ctx context.Context, approvalID string, decision ApprovalDecisionPayload)

+ func (f *ApprovalFlow[D]) SendPrompt(ctx context.Context, portal *bridgev2.Portal, params SendPromptParams)

+ func (f *ApprovalFlow[D]) SetData(approvalID string, updater func(D) D) bool

+ func (f *ApprovalFlow[D]) Wait(ctx context.Context, approvalID string) (ApprovalDecisionPayload, bool)

+ type ApprovalFlowConfig struct

+ BackgroundContext func(ctx context.Context) context.Context

+ DBMetadata func(prompt ApprovalPromptMessage) any

+ DeliverDecision func(ctx context.Context, portal *bridgev2.Portal, pending *Pending[D], ...) error

+ IDPrefix string

+ LogKey string

+ Login func() *bridgev2.UserLogin

+ RoomIDFromData func(data D) id.RoomID

+ SendNotice func(ctx context.Context, portal *bridgev2.Portal, msg string)

+ SendTimeout time.Duration

+ Sender func(portal *bridgev2.Portal) bridgev2.EventSender

+ type ApprovalOption struct

+ Always bool

+ Approved bool

+ FallbackKey string

+ ID string

+ Key string

+ Label string

+ Reason string

+ func ApprovalPromptOptions(allowAlways bool) []ApprovalOption

+ func DefaultApprovalOptions() []ApprovalOption

+ type ApprovalPromptMessage struct

+ Body string

+ Options []ApprovalOption

+ Presentation ApprovalPromptPresentation

+ Raw map[string]any

+ UIMessage map[string]any

+ func BuildApprovalPromptMessage(params ApprovalPromptMessageParams) ApprovalPromptMessage

+ func BuildApprovalResponsePromptMessage(params ApprovalResponsePromptMessageParams) ApprovalPromptMessage

+ type ApprovalPromptMessageParams struct

+ ApprovalID string

+ ExpiresAt time.Time

+ Options []ApprovalOption

+ Presentation ApprovalPromptPresentation

+ ReplyToEventID id.EventID

+ ToolCallID string

+ ToolName string

+ TurnID string

+ type ApprovalPromptPresentation struct

+ AllowAlways bool

+ Details []ApprovalDetail

+ Title string

+ type ApprovalPromptReactionCleanupOptions struct

+ PreserveKey string

+ PreserveSenderID networkid.UserID

+ type ApprovalPromptReactionMatch struct

+ ApprovalID string

+ Decision ApprovalDecisionPayload

+ KnownPrompt bool

+ MirrorDecisionReaction bool

+ Prompt ApprovalPromptRegistration

+ RedactResolvedReaction bool

+ RejectReason string

+ ShouldResolve bool

+ type ApprovalPromptRegistration struct

+ ApprovalID string

+ ExpiresAt time.Time

+ Options []ApprovalOption

+ OwnerMXID id.UserID

+ Presentation ApprovalPromptPresentation

+ PromptEventID id.EventID

+ PromptMessageID networkid.MessageID

+ PromptSenderID networkid.UserID

+ PromptVersion uint64

+ RoomID id.RoomID

+ ToolCallID string

+ ToolName string

+ TurnID string

+ type ApprovalReactionHandler interface

+ HandleReaction func(ctx context.Context, msg *bridgev2.MatrixReaction, targetEventID id.EventID, ...) bool

+ type ApprovalReactionRemoveHandler interface

+ HandleReactionRemove func(ctx context.Context, msg *bridgev2.MatrixReactionRemove) bool

+ type ApprovalResolutionOrigin string

+ const ApprovalResolutionOriginAgent

+ const ApprovalResolutionOriginUser

+ func ApprovalResolutionOriginFromString(value string) ApprovalResolutionOrigin

+ type ApprovalResponsePromptMessageParams struct

+ ApprovalID string

+ Decision ApprovalDecisionPayload

+ ExpiresAt time.Time

+ Options []ApprovalOption

+ Presentation ApprovalPromptPresentation

+ ToolCallID string

+ ToolName string

+ TurnID string

+ type AssistantMessageMetadata struct

+ CompletionID string

+ FirstTokenAtMs int64

+ HasToolCalls bool

+ Model string

+ ThinkingTokenCount int

+ Transcript string

+ func (a *AssistantMessageMetadata) CopyFromAssistant(src *AssistantMessageMetadata)

+ type AssistantMetadataParams struct

+ AgentID string

+ Body string

+ CanonicalTurnData map[string]any

+ CompletedAtMs int64

+ CompletionTokens int64

+ FinishReason string

+ GeneratedFiles []GeneratedFileRef

+ PromptTokens int64

+ ReasoningTokens int64

+ StartedAtMs int64

+ ThinkingContent string

+ ToolCalls []ToolCallMetadata

+ TurnID string

+ type BaseLoginProcess struct

+ func (p *BaseLoginProcess) BackgroundProcessContext() context.Context

+ func (p *BaseLoginProcess) Cancel()

+ type BaseMessageMetadata struct

+ AgentID string

+ Body string

+ CanonicalTurnData map[string]any

+ CompletedAtMs int64

+ CompletionTokens int64

+ ExcludeFromHistory bool

+ FinishReason string

+ GeneratedFiles []GeneratedFileRef

+ PromptTokens int64

+ ReasoningTokens int64

+ Role string

+ StartedAtMs int64

+ ThinkingContent string

+ ToolCalls []ToolCallMetadata

+ TurnID string

+ func BuildAssistantBaseMetadata(p AssistantMetadataParams) BaseMessageMetadata

+ func (b *BaseMessageMetadata) CopyFromBase(src *BaseMessageMetadata)

+ type BaseReactionHandler struct

+ Target ReactionTarget

+ func (h BaseReactionHandler) HandleMatrixReaction(ctx context.Context, msg *bridgev2.MatrixReaction) (*database.Reaction, error)

+ func (h BaseReactionHandler) HandleMatrixReactionRemove(ctx context.Context, msg *bridgev2.MatrixReactionRemove) error

+ func (h BaseReactionHandler) PreHandleMatrixReaction(_ context.Context, msg *bridgev2.MatrixReaction) (bridgev2.MatrixReactionPreResponse, error)

+ type BaseStreamState struct

+ StreamFallbackToDebounced atomic.Bool

+ StreamMu sync.Mutex

+ StreamSessions map[string]*turns.StreamSession

+ func (s *BaseStreamState) BeginStreamShutdown()

+ func (s *BaseStreamState) CloseAllSessions()

+ func (s *BaseStreamState) InitStreamState()

+ func (s *BaseStreamState) IsStreamShuttingDown() bool

+ func (s *BaseStreamState) ResetStreamShutdown()

+ type BrokenLoginClient struct

+ OnLogout func(context.Context, *bridgev2.UserLogin)

+ Reason string

+ UserLogin *bridgev2.UserLogin

+ func NewBrokenLoginClient(login *bridgev2.UserLogin, reason string) *BrokenLoginClient

+ func (c *BrokenLoginClient) Connect(_ context.Context)

+ func (c *BrokenLoginClient) Disconnect()

+ func (c *BrokenLoginClient) GetCapabilities(_ context.Context, _ *bridgev2.Portal) *event.RoomFeatures

+ func (c *BrokenLoginClient) GetChatInfo(_ context.Context, _ *bridgev2.Portal) (*bridgev2.ChatInfo, error)

+ func (c *BrokenLoginClient) GetUserInfo(_ context.Context, _ *bridgev2.Ghost) (*bridgev2.UserInfo, error)

+ func (c *BrokenLoginClient) HandleMatrixMessage(_ context.Context, _ *bridgev2.MatrixMessage) (*bridgev2.MatrixMessageResponse, error)

+ func (c *BrokenLoginClient) IsLoggedIn() bool

+ func (c *BrokenLoginClient) IsThisUser(_ context.Context, _ networkid.UserID) bool

+ func (c *BrokenLoginClient) LogoutRemote(ctx context.Context)

+ type ClientBase struct

+ HumanUserIDPrefix string

+ MessageIDPrefix string

+ MessageLogKey string

+ func (c *ClientBase) BackgroundContext(ctx context.Context) context.Context

+ func (c *ClientBase) GetUserLogin() *bridgev2.UserLogin

+ func (c *ClientBase) HumanUserID() networkid.UserID

+ func (c *ClientBase) InitClientBase(login *bridgev2.UserLogin, target ReactionTarget)

+ func (c *ClientBase) IsLoggedIn() bool

+ func (c *ClientBase) IsThisUser(_ context.Context, userID networkid.UserID) bool

+ func (c *ClientBase) SendViaPortal(portal *bridgev2.Portal, sender bridgev2.EventSender, ...) (id.EventID, networkid.MessageID, error)

+ func (c *ClientBase) SendViaPortalWithOptions(portal *bridgev2.Portal, sender bridgev2.EventSender, ...) (id.EventID, networkid.MessageID, error)

+ func (c *ClientBase) SetLoggedIn(v bool)

+ func (c *ClientBase) SetUserLogin(login *bridgev2.UserLogin)

+ type ConnectorBase struct

+ func NewConnector(spec ConnectorSpec) *ConnectorBase

+ func (c *ConnectorBase) Bridge() *bridgev2.Bridge

+ func (c *ConnectorBase) CreateLogin(ctx context.Context, user *bridgev2.User, flowID string) (bridgev2.LoginProcess, error)

+ func (c *ConnectorBase) FillPortalBridgeInfo(portal *bridgev2.Portal, content *event.BridgeEventContent)

+ func (c *ConnectorBase) GetBridgeInfoVersion() (info, capabilities int)

+ func (c *ConnectorBase) GetCapabilities() *bridgev2.NetworkGeneralCapabilities

+ func (c *ConnectorBase) GetConfig() (example string, data any, upgrader configupgrade.Upgrader)

+ func (c *ConnectorBase) GetDBMetaTypes() database.MetaTypes

+ func (c *ConnectorBase) GetLoginFlows() []bridgev2.LoginFlow

+ func (c *ConnectorBase) GetName() bridgev2.BridgeName

+ func (c *ConnectorBase) Init(br *bridgev2.Bridge)

+ func (c *ConnectorBase) LoadUserLogin(ctx context.Context, login *bridgev2.UserLogin) error

+ func (c *ConnectorBase) Start(ctx context.Context) error

+ func (c *ConnectorBase) Stop(ctx context.Context)

+ type ConnectorSpec struct

+ AIRoomKind string

+ BridgeInfoVersion func() (info, capabilities int)

+ Capabilities func() *bridgev2.NetworkGeneralCapabilities

+ Config func() (example string, data any, upgrader configupgrade.Upgrader)

+ CreateLogin func(context.Context, *bridgev2.User, string) (bridgev2.LoginProcess, error)

+ DBMeta func() database.MetaTypes

+ FillBridgeInfo func(*bridgev2.Portal, *event.BridgeEventContent)

+ Init func(*bridgev2.Bridge)

+ LoadLogin func(context.Context, *bridgev2.UserLogin) error

+ LoginFlows func() []bridgev2.LoginFlow

+ Name func() bridgev2.BridgeName

+ ProtocolID string

+ Start func(context.Context) error

+ Stop func(context.Context)

+ type DMChatInfoParams struct

+ BotDisplayName string

+ BotUserID networkid.UserID

+ CanBackfill bool

+ HumanUserID networkid.UserID

+ LoginID networkid.UserLoginID

+ Title string

+ type EventTiming struct

+ StreamOrder int64

+ Timestamp time.Time

+ func NextEventTiming(lastStreamOrder int64, timestamp time.Time) EventTiming

+ func ResolveEventTiming(timestamp time.Time, streamOrder int64) EventTiming

+ type GeneratedFileRef struct

+ MimeType string

+ URL string

+ func GeneratedFileRefsFromParts(parts []citations.GeneratedFilePart) []GeneratedFileRef

+ type LoadUserLoginConfig struct

+ AfterLoad func(client C)

+ BridgeName string

+ Clients map[networkid.UserLoginID]bridgev2.NetworkAPI

+ ClientsRef *map[networkid.UserLoginID]bridgev2.NetworkAPI

+ Create func(login *bridgev2.UserLogin) (C, error)

+ MakeBroken func(login *bridgev2.UserLogin, reason string) *BrokenLoginClient

+ Mu *sync.Mutex

+ Update func(existing C, login *bridgev2.UserLogin)

+ type LoginDMChatInfoParams struct

+ BotDisplayName string

+ BotUserID networkid.UserID

+ CanBackfill bool

+ HumanUserIDPrefix string

+ Login *bridgev2.UserLogin

+ Title string

+ type Pending struct

+ Data D

+ ExpiresAt time.Time

+ type ReactionContext struct

+ Emoji string

+ TargetEventID id.EventID

+ func ExtractReactionContext(msg *bridgev2.MatrixReaction) ReactionContext

+ type ReactionTarget interface

+ GetApprovalHandler func() ApprovalReactionHandler

+ GetUserLogin func() *bridgev2.UserLogin

+ type RemoteEdit struct

+ LogKey string

+ Portal networkid.PortalKey

+ PreBuilt *bridgev2.ConvertedEdit

+ Sender bridgev2.EventSender

+ StreamOrder int64

+ TargetMessage networkid.MessageID

+ Timestamp time.Time

+ func (e *RemoteEdit) AddLogContext(c zerolog.Context) zerolog.Context

+ func (e *RemoteEdit) ConvertEdit(_ context.Context, _ *bridgev2.Portal, _ bridgev2.MatrixAPI, ...) (*bridgev2.ConvertedEdit, error)

+ func (e *RemoteEdit) GetPortalKey() networkid.PortalKey

+ func (e *RemoteEdit) GetSender() bridgev2.EventSender

+ func (e *RemoteEdit) GetStreamOrder() int64

+ func (e *RemoteEdit) GetTargetMessage() networkid.MessageID

+ func (e *RemoteEdit) GetTimestamp() time.Time

+ func (e *RemoteEdit) GetType() bridgev2.RemoteEventType

+ type RoomFeaturesParams struct

+ Delete event.CapabilitySupportLevel

+ DeleteChat bool

+ Edit event.CapabilitySupportLevel

+ File event.FileFeatureMap

+ ID string

+ MaxTextLength int

+ Reaction event.CapabilitySupportLevel

+ ReadReceipts bool

+ Reply event.CapabilitySupportLevel

+ Thread event.CapabilitySupportLevel

+ TypingNotifications bool

+ type SendPromptParams struct

+ OwnerMXID id.UserID

+ RoomID id.RoomID

+ type SendViaPortalParams struct

+ Converted *bridgev2.ConvertedMessage

+ IDPrefix string

+ LogKey string

+ Login *bridgev2.UserLogin

+ MsgID networkid.MessageID

+ Portal *bridgev2.Portal

+ Sender bridgev2.EventSender

+ StreamOrder int64

+ Timestamp time.Time

+ type StreamTurnHost struct

+ func NewStreamTurnHost[S any](cb StreamTurnHostCallbacks[S]) *StreamTurnHost[S]

+ func (h *StreamTurnHost[S]) DeleteIfMatch(turnID string, state *S)

+ func (h *StreamTurnHost[S]) DeleteLocked(turnID string)

+ func (h *StreamTurnHost[S]) DrainAndAbort(reason string)

+ func (h *StreamTurnHost[S]) GetLocked(turnID string) *S

+ func (h *StreamTurnHost[S]) IsActive(turnID string) bool

+ func (h *StreamTurnHost[S]) Lock()

+ func (h *StreamTurnHost[S]) SetLocked(turnID string, state *S)

+ func (h *StreamTurnHost[S]) Unlock()

+ type StreamTurnHostCallbacks struct

+ GetAborter func(state *S) Aborter

+ type ToolCallMetadata struct

+ CallEventID string

+ CallID string

+ CompletedAtMs int64

+ ErrorMessage string

+ Input map[string]any

+ Output map[string]any

+ ResultEventID string

+ ResultStatus string

+ StartedAtMs int64

+ Status string

+ ToolName string

+ ToolType string

+ type TypedClientLoaderSpec struct

+ Accept func(*bridgev2.UserLogin) (ok bool, reason string)

+ type UpsertAssistantMessageParams struct

+ InitialEventID id.EventID

+ Logger zerolog.Logger

+ Login *bridgev2.UserLogin

+ Metadata any

+ NetworkMessageID networkid.MessageID

+ Portal *bridgev2.Portal

+ SenderID networkid.UserID

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