thalovant

Sep 12, 2026

Changes in this version

+ func AsSentence(text, lang string) string

+ func ClosestLanguage(target string, available []string) (string, bool)

+ func SpeakableWithLanguage(pattern string, slots map[string]string, lang string) string

type IntentExampleOptions

+ Listing *ListingRules

+ Sentence bool

+ type ListingData struct

+ Languages map[string]ListingLanguage

+ SentenceEnds string

+ type ListingLanguage struct

+ QuestionOpeners []string

+ QuestionPatterns []string

+ QuestionWordsAnywhere []string

+ SlotExamples map[string]string

+ TrailingWords []string

+ WrittenForms map[string]string

+ type ListingRules struct

+ func DefaultListing() *ListingRules

+ func NewListingRules(data *ListingData) (*ListingRules, error)

+ func (r *ListingRules) AsSentence(text, lang string) string

+ func (r *ListingRules) Asks(text, lang string) (bool, error)

+ func (r *ListingRules) Available() bool

+ func (r *ListingRules) Dangling(text, lang string) bool

+ func (r *ListingRules) LanguageData(lang string) ListingLanguage

+ func (r *ListingRules) Rank(phrases []string, lang string) []string

+ func (r *ListingRules) Speakable(pattern string, slots map[string]string, lang string) string

Sep 12, 2026

Changes in this version

+ const EventAudioQueue

+ const MaxAudioClipBytes

+ const MaxReplyMediaBytes

+ func BuildLocation(opts LocationOptions) map[string]any

+ func Speakable(pattern string, slots map[string]string) string

+ type APIError struct

+ Detail string

+ StatusCode int

+ func (e *APIError) Error() string

+ func (e *APIError) Unwrap() error

type AskOptions

+ Location map[string]any

+ Pipeline []string

+ STTLang string

type Context

+ func RequestContext(base Context, opts RequestContextOptions) Context

type ControlPlane

+ func (c *ControlPlane) ReplaceRuntimeGroupConfig(ctx context.Context, runtimeGroupID string, config map[string]any, ...) (map[string]any, error)

type Event

+ func (e Event) AudioBytes() ([]byte, error)

+ func (e Event) AudioBytesWithLimit(maxBytes int) ([]byte, error)

+ func (e Event) HasAudio() bool

+ func (e Event) IsAudio() bool

+ func (e Event) Lang() string

type HubIntent

+ func (i HubIntent) ExamplesWithOptions(lang string, limit int, opts IntentExampleOptions) []string

+ type IntentExampleOptions struct

+ Slots map[string]string

+ Speakable bool

+ type LocationOptions struct

+ City string

+ Country string

+ Latitude any

+ Longitude any

+ Region string

+ Timezone string

type Reply

+ DroppedMedia int

+ func (r Reply) HasAudio() bool

+ func (r Reply) Lang() string

+ func (r Reply) MediaEvents() []Event

+ type RequestContextOptions struct

+ Location map[string]any

+ Pipeline []string

+ STTLang string

Sep 12, 2026

Changes in this version

type ControlPlane

+ func (c *ControlPlane) InstallHubSkill(ctx context.Context, hubID, skill, version string, opts HubSkillWaitOptions) (map[string]any, error)

+ func (c *ControlPlane) ListHubSkillHistory(ctx context.Context, hubID string, limit int) (map[string]any, error)

+ func (c *ControlPlane) ListHubSkills(ctx context.Context, hubID string) (map[string]any, error)

+ func (c *ControlPlane) RemoveHubSkill(ctx context.Context, hubID, skill string, opts HubSkillWaitOptions) (map[string]any, error)

+ func (c *ControlPlane) UpdateHubSkill(ctx context.Context, hubID, skill, version string, opts HubSkillWaitOptions) (map[string]any, error)

+ func (c *ControlPlane) WaitForHubSkillOperation(ctx context.Context, accepted map[string]any, opts HubSkillWaitOptions) (map[string]any, error)

+ type HubSkillWaitOptions struct

+ PollInterval time.Duration

+ Timeout time.Duration

+ Wait bool

Sep 9, 2026

Changes in this version

+ const EventFallbackList

+ const EventFallbackListResponse

+ var ErrEventOverflow = errors.New("runtime event subscription overflow")

+ type AskOptions struct

+ EmptyReplyWait time.Duration

+ ReplySettle time.Duration

type Client

+ func (c *Client) AskWithOptions(ctx context.Context, text string, opts AskOptions) (Reply, error)

+ func (c *Client) IntentsWithCapabilities(ctx context.Context, languages []string, opts ...IntentOptions) (HubIntentCapabilities, error)

+ func (c *Client) ListFallbacks(ctx context.Context, timeout time.Duration) ([]HubFallback, error)

+ func (c *Client) Listen(ctx context.Context, eventName string, options ListenOptions) (*Subscription[Event], error)

+ func (c *Client) SubscribeEvents(capacity int) *Subscription[Event]

+ func (c *Client) WaitForEvent(ctx context.Context, eventName string, options EventOptions) (Event, error)

+ type EventOptions struct

+ Context Context

+ Predicate func(Event) bool

+ RequestID string

+ SessionID string

+ Timeout time.Duration

+ type EventSubscriber interface

+ SubscribeEvents func(capacity int) *Subscription[Event]

type HTTPTransport

+ func (t *HTTPTransport) SubscribeEvents(capacity int) *Subscription[Event]

+ func (t *HTTPTransport) SubscribeHiveMessages(capacity int) *Subscription[HiveMessage]

+ type HiveMessageSubscriber interface

+ SubscribeHiveMessages func(capacity int) *Subscription[HiveMessage]

+ type HubFallback struct

+ Priority int64

+ SkillID string

+ type HubIntentCapabilities struct

+ Fallbacks []HubFallback

+ FallbacksKnown bool

+ Inventory HubIntentInventory

+ func (c HubIntentCapabilities) MayAnswer(lang string) bool

+ type ListenOptions struct

+ Capacity int

+ MaxEvents int

type MQTTTransport

+ func (t *MQTTTransport) SubscribeEvents(capacity int) *Subscription[Event]

+ func (t *MQTTTransport) SubscribeHiveMessages(capacity int) *Subscription[HiveMessage]

+ type Subscription struct

+ C <-chan T

+ func (s *Subscription[T]) Close()

+ func (s *Subscription[T]) Err() error

type WSSTransport

+ func (t *WSSTransport) SubscribeEvents(capacity int) *Subscription[Event]

+ func (t *WSSTransport) SubscribeHiveMessages(capacity int) *Subscription[HiveMessage]

Sep 9, 2026

Changes in this version

type HTTPTransport

+ NoiseStateDir string

+ func (t *HTTPTransport) RemoteStaticKey() string

type MQTTTransport

+ NoiseStateDir string

+ TLSConfig *tls.Config

+ func (t *MQTTTransport) RemoteStaticKey() string

Sep 8, 2026

Changes in this version

+ const NoisePskFilename

+ func ForgetCachedPSK(dir, nodeID string) error

+ func LoadCachedPSK(dir, nodeID string) []byte

+ func SaveCachedPSK(dir, nodeID string, psk []byte) error

Sep 6, 2026

Changes in this version

+ const NoiseKeyFilename

+ const NoisePinsFilename

+ func ForgetNoisePin(dir, nodeID string) error

+ func LoadNoisePin(dir, nodeID string) (string, error)

+ func LoadOrCreateNoiseKey(dir string) (noise.DHKey, error)

+ func NoiseStateDir() (string, error)

+ func SaveNoisePin(dir, nodeID, publicKey string) error

type WSSTransport

+ NoiseStateDir string

+ func (t *WSSTransport) RemoteStaticKey() string

Sep 5, 2026

Changes in this version

+ const DefaultIntentTimeout

+ const DescribeBatch

+ const EventAdaptManifest

+ const EventAdaptManifestGet

+ const EventIntentDescribe

+ const EventIntentDescribeResponse

+ const EventIntentList

+ const EventIntentListResponse

+ const EventPadatiousManifest

+ const EventPadatiousManifestGet

+ const IntentSourceEngines

+ const IntentSourceManifest

+ func SameLanguage(a, b string) bool

type Client

+ func (c *Client) DescribeIntent(ctx context.Context, skillID, intentName, lang string, opts ...IntentOptions) ([]IntentDefinition, error)

+ func (c *Client) Intents(ctx context.Context, languages []string, opts ...IntentOptions) (HubIntentInventory, error)

+ func (c *Client) ListIntents(ctx context.Context, lang string, opts ...IntentOptions) ([]IntentRegistration, error)

+ type HubIntent struct

+ Enabled bool

+ Engine string

+ Languages []string

+ Name string

+ Phrases map[string][]string

+ SkillID string

+ func (i HubIntent) Examples(lang string, limit int) []string

+ func (i HubIntent) ID() string

+ func (i HubIntent) PhrasesFor(lang string) []string

+ type HubIntentInventory struct

+ Denied []string

+ Languages []string

+ Skills []HubSkillIntents

+ Source string

+ func (inv HubIntentInventory) HasPhrases() bool

+ func (inv HubIntentInventory) Intents() []HubIntent

+ type HubSkillIntents struct

+ Intents []HubIntent

+ SkillID string

+ func (s HubSkillIntents) Languages() []string

+ type IntentDefinition struct

+ IntentName string

+ Lang string

+ Method string

+ Raw map[string]any

+ Samples []string

+ SkillID string

+ func (d IntentDefinition) Engine() string

+ type IntentOptions struct

+ Describe *bool

+ Fallback *bool

+ IncludeDefinitions bool

+ Timeout time.Duration

+ type IntentRegistration struct

+ Definition map[string]any

+ Enabled bool

+ IntentName string

+ Lang string

+ Method string

+ SessionID string

+ SkillID string

+ func (r IntentRegistration) Engine() string

+ type PolicyDeniedError struct

+ Allowed []string

+ Code string

+ DeniedType string

+ Reason string

+ func (e *PolicyDeniedError) Error() string

+ func (e *PolicyDeniedError) Unwrap() error

Sep 1, 2026

Changes in this version

+ const EventIntentUnmatched

Aug 15, 2026

Changes in this version

type MqttTopicSet

+ Inbound string

+ Outbound string

Aug 15, 2026

Changes in this version

type ControlPlane

+ func (c ControlPlane) String() string

type Identity

+ func (i Identity) String() string

type MqttBrokerCredentials

+ func (m MqttBrokerCredentials) String() string

Aug 15, 2026

Changes in this version

type ControlPlane

+ func (c *ControlPlane) ClearHubRating(ctx context.Context, hubID string) (map[string]any, error)

+ func (c *ControlPlane) CreateHub(ctx context.Context, payload map[string]any, opts HubCreateOptions) (map[string]any, error)

+ func (c *ControlPlane) CreateRuntimeGroup(ctx context.Context, payload map[string]any) (map[string]any, error)

+ func (c *ControlPlane) DeleteHub(ctx context.Context, hubID string, etag string) error

+ func (c *ControlPlane) DeleteRuntimeGroup(ctx context.Context, runtimeGroupID string) error

+ func (c *ControlPlane) GetHubRuntimeCapabilities(ctx context.Context, hubID string) (map[string]any, error)

+ func (c *ControlPlane) GetRuntimeGroup(ctx context.Context, runtimeGroupID string) (map[string]any, error)

+ func (c *ControlPlane) GetRuntimeGroupConfig(ctx context.Context, runtimeGroupID string) (map[string]any, error)

+ func (c *ControlPlane) InstallRuntimeGroupSkill(ctx context.Context, runtimeGroupID string, skillID string, ...) (map[string]any, error)

+ func (c *ControlPlane) ListMarketplaceSkills(ctx context.Context, opts MarketplaceSkillListOptions) (map[string]any, error)

+ func (c *ControlPlane) ListRuntimeGroupInventory(ctx context.Context, runtimeGroupID string, opts RuntimeGroupInventoryOptions) (map[string]any, error)

+ func (c *ControlPlane) ListRuntimeGroupMarketplace(ctx context.Context, runtimeGroupID string, ...) (map[string]any, error)

+ func (c *ControlPlane) ListRuntimeGroups(ctx context.Context, ownerID string) (map[string]any, error)

+ func (c *ControlPlane) ReleaseHub(ctx context.Context, hubID string, opts ReleaseOptions) (map[string]any, error)

+ func (c *ControlPlane) ReleaseRuntimeGroup(ctx context.Context, runtimeGroupID string, opts ReleaseOptions) (map[string]any, error)

+ func (c *ControlPlane) SetHubRating(ctx context.Context, hubID string, rating int) (map[string]any, error)

+ func (c *ControlPlane) UninstallRuntimeGroupSkill(ctx context.Context, runtimeGroupID string, skillID string) error

+ func (c *ControlPlane) UpdateHub(ctx context.Context, hubID string, payload map[string]any, etag string) (map[string]any, error)

+ func (c *ControlPlane) UpdateRuntimeGroup(ctx context.Context, runtimeGroupID string, payload map[string]any) (map[string]any, error)

+ func (c *ControlPlane) UpdateRuntimeGroupConfig(ctx context.Context, runtimeGroupID string, config map[string]any, ...) (map[string]any, error)

+ type HubCreateOptions struct

+ IdempotencyKey string

+ type MarketplaceSkillListOptions struct

+ ForceRefresh bool

+ IncludeInactive bool

+ OwnerID string

+ type ReleaseOptions struct

+ Channel string

+ Images map[string]string

+ Mode string

+ Reason string

+ Version string

+ type RuntimeGroupConfigOptions struct

+ Personas map[string]any

+ type RuntimeGroupInventoryOptions struct

+ Refresh bool

+ type RuntimeGroupMarketplaceOptions struct

+ RefreshInventory bool

+ type RuntimeGroupSkillInstallOptions struct

+ Active *bool

+ MarketplaceSkillID string

+ SourceRef string

+ SourceType string

+ VersionPin string

Aug 14, 2026

Changes in this version

+ const Version

Aug 13, 2026

Changes in this version

+ const DefaultDeviceLoginTimeout

+ var ErrDeviceAccessDenied = errors.New("thalovant device sign-in denied")

+ var ErrDeviceCodeExpired = errors.New("thalovant device sign-in code expired")

type ControlPlane

+ func (c *ControlPlane) LoginWithBrowser(ctx context.Context, opts DeviceLoginOptions) (map[string]any, error)

+ type DeviceLoginOptions struct

+ ClientName string

+ OpenBrowser *bool

+ Prompt func(grant map[string]any)

+ Scopes []string

+ Timeout time.Duration

Aug 13, 2026

Changes in this version

type ControlPlane

+ func (c *ControlPlane) LoginWithOptions(ctx context.Context, email string, password string, opts LoginOptions) (map[string]any, error)

+ type LoginOptions struct

+ OTPCode string

+ RecoveryCode string

+ Scope string

Jul 12, 2026

Changes in this version

type ControlPlane

+ func (c *ControlPlane) GetOperation(ctx context.Context, operationID string) (OperationResource, error)

+ type OperationResource struct

+ AggregateID *string

+ AggregateType string

+ AppliedAt *string

+ CommittedAt *string

+ CreatedAt string

+ Details map[string]any

+ ErrorCode *string

+ ErrorMessage *string

+ GitCommitSHA *string

+ ID string

+ Kind string

+ Links map[string]*string

+ ReadyAt *string

+ Status OperationStatus

+ TerminalAt *string

+ UpdatedAt string

+ type OperationStatus string

+ const OperationApplied

+ const OperationCommitted

+ const OperationFailed

+ const OperationReady

+ const OperationRequested

+ const OperationTimedOut

Jul 10, 2026

Changes in this version

+ const EventOvosUtteranceSpeak

+ const EventQueryTimeout

type Client

+ ConnectTimeout time.Duration

+ func (c *Client) Query(ctx context.Context, text string, opts QueryOptions) (Reply, error)

type ClientOptions

+ ConnectTimeout time.Duration

type Conversation

+ func (c Conversation) Query(ctx context.Context, text string, opts QueryOptions) (Reply, error)

type HTTPTransport

+ HiveEvents chan HiveMessage

+ func (t *HTTPTransport) HiveMessages() <-chan HiveMessage

+ func (t *HTTPTransport) SendHiveMessage(ctx context.Context, message HiveMessage, encrypt bool) error

type MQTTTransport

+ HiveEvents chan HiveMessage

+ func (t *MQTTTransport) HiveMessages() <-chan HiveMessage

+ func (t *MQTTTransport) SendHiveMessage(ctx context.Context, message HiveMessage, encrypt bool) error

+ type QueryOptions struct

+ Context Context

+ Lang string

+ QueryID string

+ RequestID string

+ SessionID string

+ Timeout time.Duration

type WSSTransport

+ HiveEvents chan HiveMessage

+ func (t *WSSTransport) HiveMessages() <-chan HiveMessage

+ func (t *WSSTransport) SendHiveMessage(ctx context.Context, message HiveMessage, encrypt bool) error

Jul 8, 2026

Changes in this version

type Client

+ func (c *Client) ConnectWithInfo(ctx context.Context) (TransportConnectionInfo, error)

+ func (c *Client) ConnectionInfo() TransportConnectionInfo

type HTTPTransport

+ func (t *HTTPTransport) ConnectionInfo() TransportConnectionInfo

type MQTTTransport

+ func (t *MQTTTransport) ConnectionInfo() TransportConnectionInfo

type RuntimeTransport

+ ConnectionInfo func() TransportConnectionInfo

+ type TransportConnectionInfo struct

+ ConnectMS float64

+ ConnectedAt time.Time

+ HandshakeMS float64

+ LastError string

+ Phase TransportConnectionPhase

+ SocketOpenMS float64

+ StartedAt time.Time

+ TransportOpenMS float64

+ type TransportConnectionPhase string

+ const ConnectionClosed

+ const ConnectionConnecting

+ const ConnectionError

+ const ConnectionHandshake

+ const ConnectionIdle

+ const ConnectionReady

type TransportHealth

+ Connection TransportConnectionInfo

type WSSTransport

+ func (t *WSSTransport) ConnectionInfo() TransportConnectionInfo

Jul 2, 2026

Changes in this version

+ type AnalyticsOverviewOptions struct

+ Admin bool

+ Bucket string

+ ClientID string

+ Country string

+ Hour *int

+ HubID string

+ Intent string

+ Message string

+ OwnerID string

+ Range string

+ TimeEnd string

+ TimeStart string

+ Utterance string

+ Weekday *int

type ControlPlane

+ func (c *ControlPlane) CreateMemoryItem(ctx context.Context, payload map[string]any) (map[string]any, error)

+ func (c *ControlPlane) DeleteMemoryItem(ctx context.Context, memoryID string) error

+ func (c *ControlPlane) GetAnalyticsOverview(ctx context.Context, opts AnalyticsOverviewOptions) (map[string]any, error)

+ func (c *ControlPlane) GetMemoryItem(ctx context.Context, memoryID string) (map[string]any, error)

+ func (c *ControlPlane) GetMemorySummary(ctx context.Context, ownerID string) (map[string]any, error)

+ func (c *ControlPlane) ListMemoryItems(ctx context.Context, opts MemoryListOptions) (map[string]any, error)

+ func (c *ControlPlane) UpdateMemoryItem(ctx context.Context, memoryID string, payload map[string]any) (map[string]any, error)

+ type MemoryListOptions struct

+ HubID string

+ IncludeDeleted bool

+ IncludeExpired bool

+ Kind string

+ Limit int

+ Offset int

+ OwnerID string

+ Query string

+ Scope string

Jun 10, 2026

Changes in this version

+ const DefaultConfigFilename

+ func DefaultConfigPath() (string, error)

type Client

+ func NewClientFromConfig(path string, profile string) (*Client, error)

type Identity

+ func IdentityFromConfig(path string, profile string) (Identity, error)

Jun 9, 2026

Changes in this version

+ const DefaultControlAPIURL

type ControlPlane

+ func NewDefaultControlPlane(accessToken string) *ControlPlane

Jun 9, 2026

Changes in this version

type ControlPlane

+ func (c *ControlPlane) GetPublicHub(ctx context.Context, hubRef string) (map[string]any, error)

+ func (c *ControlPlane) ListPublicHubs(ctx context.Context, limit int, cursor string) (map[string]any, error)

Jun 8, 2026

Changes in this version

+ func DecryptBinary(key string, payload []byte) ([]byte, error)

+ func EncodeHiveBinaryFrame(message HiveMessage) ([]byte, error)

+ func EncryptAsBinary(key string, plaintext []byte) ([]byte, error)

type HiveMessage

+ func DecodeHiveBinaryFrame(payload []byte) (HiveMessage, error)

type Identity

+ Metadata map[string]any

Jun 8, 2026

Changes in this version

type HTTPTransport

+ func (t *HTTPTransport) Events() <-chan Event

+ type MQTTTransport struct

+ BusEvents chan Event

+ Identity Identity

+ Topics MqttTopicSet

+ UserAgent string

+ func NewMQTTTransport(identity Identity) (*MQTTTransport, error)

+ func (t *MQTTTransport) Connect(ctx context.Context) error

+ func (t *MQTTTransport) Disconnect(ctx context.Context) error

+ func (t *MQTTTransport) EmitBus(ctx context.Context, eventType string, data Data, eventContext Context) error

+ func (t *MQTTTransport) Events() <-chan Event

+ func (t *MQTTTransport) Healthcheck() TransportHealth

+ func (t *MQTTTransport) IsHandshakeComplete() bool

type MqttBrokerCredentials

+ C2STopic string

+ HashTopics bool

+ HubID string

+ QOS byte

+ S2CTopic string

+ StatusTopic string

+ type MqttTopicSet struct

+ C2S string

+ S2C string

+ Status string

+ func MQTTTopicsForIdentity(identity Identity) (MqttTopicSet, error)

+ type RuntimeTransport interface

+ Connect func(ctx context.Context) error

+ Disconnect func(ctx context.Context) error

+ EmitBus func(ctx context.Context, eventType string, data Data, eventContext Context) error

+ Events func() <-chan Event

+ Healthcheck func() TransportHealth

+ type WSSTransport struct

+ BusEvents chan Event

+ Identity Identity

+ UserAgent string

+ func NewWSSTransport(identity Identity) *WSSTransport

+ func (t *WSSTransport) Authorization() string

+ func (t *WSSTransport) Connect(ctx context.Context) error

+ func (t *WSSTransport) Disconnect(_ context.Context) error

+ func (t *WSSTransport) EmitBus(ctx context.Context, eventType string, data Data, eventContext Context) error

+ func (t *WSSTransport) Events() <-chan Event

+ func (t *WSSTransport) Healthcheck() TransportHealth

+ func (t *WSSTransport) IsHandshakeComplete() bool

Jun 8, 2026

Changes in this version

type Identity

+ MQTT *MqttBrokerCredentials

+ type MqttBrokerCredentials struct

+ Endpoint string

+ Password string

+ TLS bool

+ TopicPrefix string

+ Username string

+ func MqttBrokerCredentialsFromMap(raw any) *MqttBrokerCredentials

+ func (m MqttBrokerCredentials) Map(includeSecrets bool) map[string]any

Jun 8, 2026

Changes in this version

+ const DefaultControlUserAgent

+ var DefaultProtocolPreference = []HubProtocol

+ var ErrAPI = errors.New("thalovant api error")

+ var ErrProtocol = errors.New("thalovant unsupported protocol")

+ type BootstrapIdentityOptions struct

+ Active *bool

+ IdempotencyKey string

+ Name string

+ OwnerID string

+ PreferredProtocols []HubProtocol

+ SiteID string

+ Spec map[string]any

+ type BootstrapIdentityResult struct

+ Client map[string]any

+ Endpoint *SelectedHubEndpoint

+ Hub map[string]any

+ Identity Identity

+ func (r BootstrapIdentityResult) SelectedProtocol() HubProtocol

+ func (r BootstrapIdentityResult) Summary(includeSecrets bool) map[string]any

type Client

+ func NewClientWithOptions(identity Identity, opts ClientOptions) (*Client, error)

+ type ClientOptions struct

+ Protocol HubProtocol

+ type ControlPlane struct

+ APIURL string

+ AccessToken string

+ HTTPClient *http.Client

+ UserAgent string

+ func NewControlPlane(apiURL string, accessToken string) *ControlPlane

+ func (c *ControlPlane) CreateClient(ctx context.Context, payload map[string]any, idempotencyKey string) (map[string]any, error)

+ func (c *ControlPlane) CreateClientIdentity(ctx context.Context, hub map[string]any, opts BootstrapIdentityOptions) (BootstrapIdentityResult, error)

+ func (c *ControlPlane) CreateClientIdentityForHubID(ctx context.Context, hubID string, opts BootstrapIdentityOptions) (BootstrapIdentityResult, error)

+ func (c *ControlPlane) GetHub(ctx context.Context, hubID string) (map[string]any, error)

+ func (c *ControlPlane) ListHubs(ctx context.Context, limit int, cursor string, ownerID string) (map[string]any, error)

+ func (c *ControlPlane) Login(ctx context.Context, email string, password string, scope string) (map[string]any, error)

+ func (c *ControlPlane) RequireRuntimeProtocol(result BootstrapIdentityResult, protocol HubProtocol) (*SelectedHubEndpoint, error)

+ type SelectedHubEndpoint struct

+ Endpoint string

+ Protocol HubProtocol

+ func SelectDataPlaneEndpoint(endpoints HubDataPlaneEndpoints, protocols HubProtocolSettings, ...) *SelectedHubEndpoint

Jun 7, 2026

Changes in this version

+ func EndpointFromDomain(domain string, protocol HubProtocol) string

+ type HubDataPlaneEndpoints struct

+ HTTPS string

+ MQTT string

+ WSS string

+ func DataPlaneEndpointsFromHub(hub map[string]any) HubDataPlaneEndpoints

+ func DataPlaneEndpointsFromMap(values map[string]any) HubDataPlaneEndpoints

+ func (e HubDataPlaneEndpoints) EndpointFor(protocol HubProtocol) string

+ func (e HubDataPlaneEndpoints) HTTPBase(fallbackMaster string, fallbackPort int, fallbackPath string) string

+ func (e HubDataPlaneEndpoints) Map(redactCredentials bool) map[string]string

+ type HubProtocol string

+ const ProtocolHTTPS

+ const ProtocolMQTT

+ const ProtocolWSS

+ type HubProtocolSettings struct

+ HTTP bool

+ MQTT bool

+ WSS bool

+ func DefaultHubProtocolSettings() HubProtocolSettings

+ func ProtocolSettingsFromMap(values map[string]any) HubProtocolSettings

+ func (s HubProtocolSettings) EnabledProtocols() []HubProtocol

+ func (s HubProtocolSettings) IsEnabled(protocol HubProtocol) bool

+ func (s HubProtocolSettings) SpecMap() map[string]any

type Identity

+ DataPlaneEndpoints HubDataPlaneEndpoints

+ Protocols HubProtocolSettings

+ func (i Identity) EnabledProtocols() []HubProtocol

+ func (i Identity) EndpointFor(protocol HubProtocol) string

+ func (i Identity) SupportsProtocol(protocol HubProtocol) bool

Jun 5, 2026

Changes in this version

+ const DefaultUserAgent

+ const EventIntentFailure

+ const EventPolicyDenied

+ const EventRecognizerLoopUtterance

+ const EventSpeak

+ const EventUtteranceHandled

+ var ErrConnection = errors.New("thalovant connection error")

+ var ErrIdentity = errors.New("thalovant identity error")

+ var ErrRuntime = errors.New("thalovant runtime error")

+ var ErrTimeout = errors.New("thalovant timeout")

+ func DecryptFromJSON(key string, raw string) (string, error)

+ func EncryptAsJSON(key string, plaintext string) (string, error)

+ func EventMatchesContext(event Event, expected Context) bool

+ func NewRequestID() string

+ func NewSessionID() string

+ func RequestIDFromContext(context Context) string

+ func RichMediaFromData(data Data) map[string]any

+ func RuntimeCryptoKey(raw string) []byte

+ func SessionIDFromContext(context Context) string

+ func StripSSML(text string) string

+ type ActionOptions struct

+ Context Context

+ Lang string

+ RequestID string

+ SessionID string

+ Title string

+ type Client struct

+ Identity Identity

+ Transport *HTTPTransport

+ func NewClient(identity Identity) *Client

+ func NewClientFromEnv() (*Client, error)

+ func NewClientFromFile(path string) (*Client, error)

+ func (c *Client) Ask(ctx context.Context, text string, opts RequestOptions) (Reply, error)

+ func (c *Client) Close(ctx context.Context) error

+ func (c *Client) Connect(ctx context.Context) error

+ func (c *Client) Conversation(opts ConversationOptions) Conversation

+ func (c *Client) Emit(ctx context.Context, eventType string, data Data, eventContext Context) error

+ func (c *Client) Healthcheck() TransportHealth

+ func (c *Client) SendAction(ctx context.Context, payload string, opts ActionOptions) error

+ func (c *Client) SendCode(ctx context.Context, value string, opts CodeOptions) error

+ func (c *Client) SendUtterance(ctx context.Context, text string, opts RequestOptions) error

+ type ClientContextOptions struct

+ AuthClaims map[string]any

+ AuthProvider string

+ AuthToken string

+ Channel string

+ Destination string

+ DeviceID string

+ Locale string

+ Metadata map[string]any

+ Platform string

+ Roles []string

+ SessionID string

+ Source string

+ UserID string

+ UserName string

+ type CodeOptions struct

+ Context Context

+ Kind string

+ Label string

+ Lang string

+ RequestID string

+ SessionID string

+ type Context map[string]any

+ func BuildClientContext(base Context, opts ClientContextOptions) Context

+ func ContextWithCorrelation(raw Context, sessionID, siteID, lang, requestID string) Context

+ func MergeContext(base, extra Context) Context

+ type Conversation struct

+ Client *Client

+ Options ConversationOptions

+ func (c Conversation) Ask(ctx context.Context, text string, opts RequestOptions) (Reply, error)

+ func (c Conversation) SendAction(ctx context.Context, payload string, opts ActionOptions) error

+ func (c Conversation) SendCode(ctx context.Context, value string, opts CodeOptions) error

+ func (c Conversation) SendUtterance(ctx context.Context, text string, opts RequestOptions) error

+ type ConversationOptions struct

+ Context Context

+ Lang string

+ SessionID string

+ type Data map[string]any

+ func UtterancePayload(text, lang string) Data

+ type DisplayItem struct

+ Data any

+ Kind string

+ Payload string

+ Silent bool

+ Text string

+ Title string

+ URL string

+ func DisplayItemsFromEventData(data Data, eventName string, maxTextChars int) []DisplayItem

+ type Event struct

+ Context Context

+ Data Data

+ Name string

+ Raw any

+ func (e Event) DisplayItems(maxTextChars int) []DisplayItem

+ func (e Event) DisplayText() string

+ func (e Event) IsFailure() bool

+ func (e Event) RequestID() string

+ func (e Event) RichMedia() map[string]any

+ func (e Event) SessionID() string

+ func (e Event) Text() string

+ func (e Event) Utterances() []string

+ type HTTPTransport struct

+ BusEvents chan Event

+ HTTPClient *http.Client

+ Identity Identity

+ PollInterval time.Duration

+ UserAgent string

+ func NewHTTPTransport(identity Identity) *HTTPTransport

+ func (t *HTTPTransport) Authorization() string

+ func (t *HTTPTransport) BaseURL() string

+ func (t *HTTPTransport) Connect(ctx context.Context) error

+ func (t *HTTPTransport) Disconnect(ctx context.Context) error

+ func (t *HTTPTransport) EmitBus(ctx context.Context, eventType string, data Data, eventContext Context) error

+ func (t *HTTPTransport) Healthcheck() TransportHealth

+ func (t *HTTPTransport) IsHandshakeComplete() bool

+ func (t *HTTPTransport) PollOnce(ctx context.Context) error

+ type HiveMessage struct

+ Metadata map[string]any

+ MsgType string

+ Node any

+ Payload map[string]any

+ Route []any

+ SourcePeer any

+ TargetPubKey any

+ TargetSiteID any

+ type Identity struct

+ AccessKey string

+ CryptoKey string

+ DefaultMaster string

+ DefaultPath string

+ DefaultPort int

+ Password string

+ PublicKey string

+ SiteID string

+ func IdentityFromEnv(prefix string) (Identity, error)

+ func IdentityFromFile(path string) (Identity, error)

+ func IdentityFromMap(values map[string]any) (Identity, error)

+ func (i Identity) EndpointBase() string

+ func (i Identity) Summary() map[string]any

+ type Reply struct

+ Events []Event

+ FailureEvent *Event

+ Handled bool

+ OK bool

+ RequestID string

+ SessionID string

+ Text string

+ Utterances []string

+ func (r Reply) DisplayItems(maxTextChars int) []DisplayItem

+ func (r Reply) DisplayText() string

+ type RequestOptions struct

+ Context Context

+ Lang string

+ RequestID string

+ SessionID string

+ Timeout time.Duration

+ type TransportHealth struct

+ Connected bool

+ HandshakeComplete bool

+ LastError string

+ TransportAlive bool