base

package

Go to main page

Versions in this module

v1

v1.2.2

Oct 20, 2022

v1.2.1

Oct 19, 2022

v1.2.0

Oct 19, 2022

v1.1.5

Oct 14, 2022

v1.1.4

Oct 14, 2022

v1.1.3

Oct 14, 2022

v1.1.2

Oct 13, 2022

v1.1.1

Oct 12, 2022

v1.1.0

Oct 11, 2022

Changes in this version

+ func SafeGetStructMap(strpb *structpb.Struct) map[string]any

v1.0.3

Oct 5, 2022

v1.0.2

Oct 5, 2022

Changes in this version

type AgentBuilder

+ func (b *AgentBuilder) WithEngine(engine *Engine) *AgentBuilder

type Engine

+ func (e *Engine) Connect() concurrent.CastFuture[Session]

v1.0.1

Sep 25, 2022

Changes in this version

+ func SDKLanguage() string

+ func SDKVersion() string

v1.0.0

Sep 20, 2022

Changes in this version

+ const DefaultConnectTimeout

+ const DefaultKeepAlivePingInterval

+ const DefaultRoutineInterval

+ const DefaultServiceDomain

+ const DefaultServiceScheme

+ const DefaultTransitTimeout

+ var ErrCantGetServiceResource = fmt.Errorf("can't get service resource")

+ var ErrConfigIsEmpty = errors.Errorf("config is empty")

+ var ErrConnectTimeout = fmt.Errorf("connect timeout")

+ var ErrConnectionClosed = errors.Errorf("connection closed")

+ var ErrSessionNotFound = errors.Errorf("session not found")

+ var ErrTransitTimeout = errors.Errorf("request transit timeout")

+ var ErrUnexpectError = errors.Errorf("unexcept error")

+ type Agent interface

+ Broadcast func(msg string) SendFuture

+ ChannelCount func(channelId string) SendFuture

+ ChannelMessage func(channelId string, message string, metadata *Metadata) SendFuture

+ ChannelOwnerMessage func(channelId string, message string, metadata *Metadata) SendFuture

+ Close func() concurrent.Future

+ CloseChannel func(channelId, key string) SendFuture

+ CloseVote func(voteId, key string) SendFuture

+ CreateChannel func(createChannel apirequest.CreateChannel) concurrent.CastFuture[*apiresponse.CreateChannel]

+ CreateVote func(createVote apirequest.CreateVote) concurrent.CastFuture[*apiresponse.CreateVote]

+ GetChannelMetadata func(channelId string) SendFuture

+ GetRemoteSession func(sessionId string) concurrent.CastFuture[RemoteSession]

+ GetSessionMeta func(sessionId string) SendFuture

+ GetVoteMetadata func(voteId string) SendFuture

+ Hello func() SendFuture

+ IsClosed func() bool

+ JoinChannel func(channelId string, key string) SendFuture

+ JoinVote func(voteId string, key string) SendFuture

+ LeaveChannel func(channelId string) SendFuture

+ LeaveVote func(voteId string) SendFuture

+ OnBroadcast func(f func(tf *omega.TransitFrame))

+ OnClosed func(f func())

+ OnError func(f func(err error))

+ OnMessage func(f func(tf *omega.TransitFrame))

+ OnNotification func(f func(tf *omega.TransitFrame))

+ OnNotificationReplay func(f func(tf *omega.TransitFrame))

+ OnRequest func(f func(tf *omega.TransitFrame))

+ OnRequestReplay func(f func(tf *omega.TransitFrame))

+ OnResponse func(f func(tf *omega.TransitFrame))

+ OnResponseReplay func(f func(tf *omega.TransitFrame))

+ OnSessionMessage func(f func(tf *omega.TransitFrame))

+ Ping func() SendFuture

+ PlaybackChannelMessage func(channelId string, targetTimestamp int64, inverse bool, volume omega.Volume, ...) SendFuture

+ ReplayChannelMessage func(channelId string, targetTimestamp int64, inverse bool, volume omega.Volume, ...) SendFuture

+ ServerTime func() SendFuture

+ Session func() Session

+ SessionMessage func(sessionId string, message string) SendFuture

+ SessionsMessage func(sessionIds []string, message string) SendFuture

+ SetChannelMetadata func(channelId string, name string, metadata *Metadata, skill *omega.Skill) SendFuture

+ SetSessionMeta func(metadata *Metadata) SendFuture

+ SetVoteMetadata func(voteId string, name string, metadata *Metadata) SendFuture

+ VoteCount func(voteId string) SendFuture

+ VoteMessage func(voteId string, message string) SendFuture

+ VoteOwnerMessage func(voteId string, message string) SendFuture

+ VoteSelect func(voteId string, voteOptionId string) SendFuture

+ VoteStatus func(voteId string, statusType omega.Vote_Status) SendFuture

+ func NewAgent(session Session) Agent

+ type AgentBuilder struct

+ func NewAgentBuilder(conf *Config) *AgentBuilder

+ func (b *AgentBuilder) Connect() concurrent.CastFuture[Agent]

+ type Config struct

+ AppId string

+ ConnectTimeout time.Duration

+ Domain string

+ Scheme string

+ Token string

+ TransitTimeout time.Duration

+ func NewConfig(appId string, token string) *Config

+ type DefaultSendFuture struct

+ func (f *DefaultSendFuture) SentTransitFrame() *omega.TransitFrame

+ type Engine struct

+ APIUri string

+ Config *Config

+ WSUri string

+ func NewEngine(conf *Config) *Engine

+ type Metadata = structpb.Struct

+ func NewMetadata(v map[string]interface{}) *Metadata

+ type RemoteSession interface

+ Close func() concurrent.Future

+ Fetch func() SendFuture

+ GetId func() string

+ GetMetadata func() *Metadata

+ GetName func() string

+ GetSubject func() string

+ OnMessage func(f func(msg *omega.TransitFrame))

+ SendMessage func(message string) SendFuture

+ type SendFuture interface

+ SentTransitFrame func() *omega.TransitFrame

+ type Session interface

+ Ch func() channel.Channel

+ GetEngine func() *Engine

+ GetRemoteSession func(sessionId string) concurrent.CastFuture[RemoteSession]

+ Hello func() SendFuture

+ IsClosed func() bool

+ OnClosed func(f func())

+ OnError func(f func(err error))

+ OnRead func(f func(tf *omega.TransitFrame))

+ Ping func() SendFuture

+ Send func(tf *omega.TransitFrame) SendFuture

+ SendRequest func(data omega.TransitFrameData) SendFuture

+ ServerTime func() SendFuture

+ SetMetadata func(metadata *Metadata) SendFuture

+ SetName func(name string) SendFuture

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