Versions in this module Expand all Collapse all v0 v0.1.0 Apr 5, 2019 Changes in this version + const BlacklistKey + const CancelModeKill + const CancelModeKillNoWait + const CancelModeSkip + const CloseGoodbyeAndOut + const CloseNormal + const CloseRealm + const CloseSystemShutdown + const ErrAuthenticationFailed + const ErrAuthorizationFailed + const ErrCanceled + const ErrCloseRealm + const ErrGoodbyeAndOut + const ErrInvalidArgument + const ErrInvalidURI + const ErrNetworkFailure + const ErrNoAuthMethod + const ErrNoEligibleCallee + const ErrNoSuchProcedure + const ErrNoSuchRealm + const ErrNoSuchRegistration + const ErrNoSuchRole + const ErrNoSuchSession + const ErrNoSuchSubscription + const ErrNotAuthorized + const ErrOptionDisallowedDiscloseMe + const ErrOptionNotAllowed + const ErrProcedureAlreadyExists + const ErrProtocolViolation + const ErrSystemShutdown + const InvokeFirst + const InvokeLast + const InvokeRandom + const InvokeRoundRobin + const InvokeSingle + const MatchExact + const MatchPrefix + const MatchWildcard + const MetaEventRegOnCreate + const MetaEventRegOnDelete + const MetaEventRegOnRegister + const MetaEventRegOnUnregister + const MetaEventSessionOnJoin + const MetaEventSessionOnLeave + const MetaEventSubOnCreate + const MetaEventSubOnDelete + const MetaEventSubOnSubscribe + const MetaEventSubOnUnsubscribe + const MetaProcRegCountCallees + const MetaProcRegGet + const MetaProcRegList + const MetaProcRegListCallees + const MetaProcRegLookup + const MetaProcRegMatch + const MetaProcSessionAddTestament + const MetaProcSessionCount + const MetaProcSessionFlushTestaments + const MetaProcSessionGet + const MetaProcSessionKill + const MetaProcSessionKillAll + const MetaProcSessionKillByAuthid + const MetaProcSessionKillByAuthrole + const MetaProcSessionList + const MetaProcSessionModifyDetails + const MetaProcSubCountSubscribers + const MetaProcSubGet + const MetaProcSubList + const MetaProcSubListSubscribers + const MetaProcSubLookup + const MetaProcSubMatch + const OptAcknowledge + const OptDiscloseCaller + const OptDiscloseMe + const OptError + const OptExcludeMe + const OptInvoke + const OptMatch + const OptMode + const OptProcedure + const OptProgress + const OptReason + const OptReceiveProgress + const OptTimeout + const WhitelistKey + func AsBool(v interface{}) (bool, bool) + func AsFloat64(v interface{}) (float64, bool) + func AsInt64(v interface{}) (int64, bool) + func AsString(v interface{}) (string, bool) + func DictFlag(dict Dict, path []string) (bool, error) + func DictValue(dict Dict, path []string) (interface{}, error) + func ISO8601(t time.Time) string + func IsGoodbyeAck(msg Message) bool + func NowISO8601() string + func OptionFlag(opts Dict, optionName string) bool + func OptionInt64(opts Dict, optionName string) int64 + func OptionString(opts Dict, optionName string) string + type Abort struct + Details Dict + Reason URI + func (msg *Abort) MessageType() MessageType + type Authenticate struct + Extra Dict + Signature string + func (msg *Authenticate) MessageType() MessageType + type Call struct + Arguments List + ArgumentsKw Dict + Options Dict + Procedure URI + Request ID + func (msg *Call) MessageType() MessageType + type Cancel struct + Options Dict + Request ID + func (msg *Cancel) MessageType() MessageType + type Challenge struct + AuthMethod string + Extra Dict + func (msg *Challenge) MessageType() MessageType + type Dict map[string]interface + func AsDict(v interface{}) (Dict, bool) + func DictChild(dict Dict, key string) Dict + func NormalizeDict(v interface{}) Dict + func SetOption(dict Dict, name string, value interface{}) Dict + type Error struct + Arguments List + ArgumentsKw Dict + Details Dict + Error URI + Request ID + Type MessageType + func (msg *Error) MessageType() MessageType + type Event struct + Arguments List + ArgumentsKw Dict + Details Dict + Publication ID + Subscription ID + func (msg *Event) MessageType() MessageType + type Goodbye struct + Details Dict + Reason URI + func (msg *Goodbye) MessageType() MessageType + type Hello struct + Details Dict + Realm URI + func (msg *Hello) MessageType() MessageType + type ID uint64 + func AsID(v interface{}) (ID, bool) + func GlobalID() ID + func OptionID(opts Dict, optionName string) ID + type IDGen struct + func (g *IDGen) Next() ID + type Interrupt struct + Options Dict + Request ID + func (msg *Interrupt) MessageType() MessageType + type Invocation struct + Arguments List + ArgumentsKw Dict + Details Dict + Registration ID + Request ID + func (msg *Invocation) MessageType() MessageType + type List []interface + func AsList(v interface{}) (List, bool) + type Message interface + MessageType func() MessageType + func NewMessage(t MessageType) Message + func RecvTimeout(p Peer, t time.Duration) (Message, error) + type MessageType int + const ABORT + const AUTHENTICATE + const CALL + const CANCEL + const CHALLENGE + const ERROR + const EVENT + const GOODBYE + const HELLO + const INTERRUPT + const INVOCATION + const PUBLISH + const PUBLISHED + const REGISTER + const REGISTERED + const RESULT + const SUBSCRIBE + const SUBSCRIBED + const UNREGISTER + const UNREGISTERED + const UNSUBSCRIBE + const UNSUBSCRIBED + const WELCOME + const YIELD + func (mt MessageType) String() string + type Peer interface + Close func() + Recv func() <-chan Message + Send func(Message) error + TrySend func(Message) error + type Publish struct + Arguments List + ArgumentsKw Dict + Options Dict + Request ID + Topic URI + func (msg *Publish) MessageType() MessageType + type Published struct + Publication ID + Request ID + func (msg *Published) MessageType() MessageType + type Register struct + Options Dict + Procedure URI + Request ID + func (msg *Register) MessageType() MessageType + type Registered struct + Registration ID + Request ID + func (msg *Registered) MessageType() MessageType + type Result struct + Arguments List + ArgumentsKw Dict + Details Dict + Request ID + func (msg *Result) MessageType() MessageType + type Session struct + Details Dict + ID ID + func (s Session) HasFeature(role, feature string) bool + func (s Session) HasRole(role string) bool + func (s Session) String() string + type Subscribe struct + Options Dict + Request ID + Topic URI + func (msg *Subscribe) MessageType() MessageType + type Subscribed struct + Request ID + Subscription ID + func (msg *Subscribed) MessageType() MessageType + type SyncIDGen struct + func (g *SyncIDGen) Next() ID + type URI string + func AsURI(v interface{}) (URI, bool) + func OptionURI(opts Dict, optionName string) URI + func (u URI) PrefixMatch(prefix URI) bool + func (u URI) ValidURI(strict bool, match string) bool + func (u URI) WildcardMatch(wildcard URI) bool + type Unregister struct + Registration ID + Request ID + func (msg *Unregister) MessageType() MessageType + type Unregistered struct + Request ID + func (msg *Unregistered) MessageType() MessageType + type Unsubscribe struct + Request ID + Subscription ID + func (msg *Unsubscribe) MessageType() MessageType + type Unsubscribed struct + Request ID + func (msg *Unsubscribed) MessageType() MessageType + type Welcome struct + Details Dict + ID ID + func (msg *Welcome) MessageType() MessageType + type Yield struct + Arguments List + ArgumentsKw Dict + Options Dict + Request ID + func (msg *Yield) MessageType() MessageType
Go to main page