service

Nov 13, 2018

Changes in this version

+ func FunctionTimeout(fn func() error, timeout time.Duration) error

Oct 19, 2018

Changes in this version

type CallerID

+ func ParsePublisherID(details wamp.Dict) (*CallerID, error)

Sep 25, 2018

Changes in this version

+ const EnvPingEnabled

+ const EnvPingEndpoint

+ const EnvPingInterval

+ type CallerID struct

+ Role []string

+ Session wamp.ID

+ Username string

+ func ParseCallerID(details wamp.Dict) (*CallerID, error)

+ func (c *CallerID) HasAnyRole(test []string) bool

Jul 23, 2018

Changes in this version

+ const EnvConnectTimeout

type Config

+ Timeout time.Duration

Jul 4, 2018

Changes in this version

+ const BinaryDataExtension

+ func IsRPCError(err error) bool

+ func IsSpecificRPCError(err error, uri wamp.URI) bool

Apr 30, 2018

Changes in this version

+ const EnvTLSClientCertFile

+ const EnvTLSClientKeyFile

+ const EnvTLSServerCertFile

+ func ReturnEmpty() *client.InvokeResult

+ func ReturnError(uri string) *client.InvokeResult

+ func ReturnValue(value interface{}) *client.InvokeResult

Apr 29, 2018

Changes in this version

+ const EnvRealm

+ const EnvSerialization

+ const EnvTlsClientCertFile

+ const EnvTlsClientKeyFile

+ const EnvTlsServerCertFile

type Config

+ TLSClientCertFile string

+ TLSClientKeyFile string

+ TLSServerCertFile string

Apr 29, 2018

Changes in this version

+ const Version

Apr 26, 2018

Changes in this version

+ const EnvBrokerURL

+ const EnvLogFormat

+ const EnvPassword

+ const EnvUsername

+ const ExitArgument

+ const ExitConnect

+ const ExitRegistration

+ const ExitService

+ const ExitSuccess

type Config

+ URL string

+ type EventSubscription struct

+ Handler turnpike.EventHandler

+ Options map[string]interface{}

+ type SubscriptionError struct

+ Inner error

+ Topic string

Apr 24, 2018

Changes in this version

+ type EventSubscribtion struct

+ Handler turnpike.EventHandler

+ Options map[string]interface{}

+ type HandlerRegistration struct

+ Handler turnpike.MethodHandler

+ Options map[string]interface{}

+ type RegistrationError struct

+ Inner error

+ ProcedureName string

type Service

+ func (self *Service) RegisterAll(procedures map[string]HandlerRegistration) *RegistrationError

+ func (self *Service) SubscribeAll(procedures map[string]EventSubscribtion) *SubscribtionError

+ type SubscribtionError struct

+ Inner error

+ Topic string

Apr 24, 2018

Changes in this version

+ const BROKER_URL_ENV

+ const EXIT_ARGUMENT

+ const EXIT_CONNECT

+ const EXIT_REGISTRATION

+ const EXIT_SERVICE

+ const EXIT_SUCCESS

+ const LOG_FORMAT_ENV

+ const PASSWORD_ENV

+ const USERNAME_ENV

+ type Config struct

+ Description string

+ Name string

+ Password string

+ Realm string

+ Serialization turnpike.Serialization

+ Url string

+ User string

+ Version string

+ type Error struct

+ func NewError(kind ErrorKind) *Error

+ func NewErrorFrom(kind ErrorKind, inner error) *Error

+ func (e *Error) Error() string

+ type ErrorKind int

+ const ErrorAKittenDies

+ const ErrorBadArgument

+ const ErrorItsNotABugItsAFeature

+ const ErrorNotAvailable

+ const ErrorNotEnoughData

+ const ErrorNotFound

+ const ErrorOutOfRange

+ const ErrorPermissionDenied

+ const ErrorThisWorksOnMyMachine

+ const ErrorTimedOut

+ const ErrorTooMuchData

+ const ErrorUnexpectedData

+ const ErrorUnreachableLineReached

+ type Service struct

+ Client *turnpike.Client

+ Logger *logging.Logger

+ func New(default_config Config) *Service

+ func (self *Service) Connect()

+ func (self *Service) Run()