Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pitaya

package module

Go to main page

Versions in this module

v2

v2.0.9

Sep 17, 2020

v2.0.8

Sep 17, 2020

v2.0.6

Jul 24, 2020

v2.0.5

Jul 16, 2020

v2.0.4

Jul 16, 2020

Changes in this version

type App

+ func (app *App) AddMetricsReporter(mr metrics.Reporter)

v2.0.3

Jul 15, 2020

v2.0.1

Jul 15, 2020

Changes in this version

+ func AddGRPCInfoToMetadata(metadata map[string]string, region string, host, port string, ...) map[string]string

+ func AddMetricTagsToPropagateCtx(ctx context.Context, tags map[string]string) context.Context

+ func AddToPropagateCtx(ctx context.Context, key string, val interface{}) context.Context

+ func CreatePrometheusReporter(serverType string, config metrics.PrometheusConfig, ...) (*metrics.PrometheusReporter, error)

+ func CreateStatsdReporter(serverType string, config metrics.StatsdConfig) (*metrics.StatsdReporter, error)

+ func Descriptor(protoName string) ([]byte, error)

+ func Error(err error, code string, metadata ...map[string]string) *errors.Error

+ func ExtractSpan(ctx context.Context) (opentracing.SpanContext, error)

+ func GetDefaultLoggerFromCtx(ctx context.Context) logger.Logger

+ func GetFromPropagateCtx(ctx context.Context, key string) interface

+ func NewAfterTimer(duration time.Duration, fn timer.Func) *timer.Timer

+ func NewCondTimer(condition timer.Condition, fn timer.Func) (*timer.Timer, error)

+ func NewCountTimer(interval time.Duration, count int, fn timer.Func) *timer.Timer

+ func NewTimer(interval time.Duration, fn timer.Func) *timer.Timer

+ func SetLogger(l logger.Logger)

+ func SetTimerBacklog(c int)

+ func SetTimerPrecision(precision time.Duration)

+ type App struct

+ func NewApp(serverMode ServerMode, serializer serialize.Serializer, ...) *App

+ func (app *App) AddRoute(serverType string, routingFunction router.RoutingFunc) error

+ func (app *App) Documentation(getPtrNames bool) (map[string]interface{}, error)

+ func (app *App) GetDieChan() chan bool

+ func (app *App) GetMetricsReporters() []metrics.Reporter

+ func (app *App) GetModule(name string) (interfaces.Module, error)

+ func (app *App) GetServer() *cluster.Server

+ func (app *App) GetServerByID(id string) (*cluster.Server, error)

+ func (app *App) GetServerID() string

+ func (app *App) GetServers() []*cluster.Server

+ func (app *App) GetServersByType(t string) (map[string]*cluster.Server, error)

+ func (app *App) GetSessionFromCtx(ctx context.Context) session.Session

+ func (app *App) GroupAddMember(ctx context.Context, groupName, uid string) error

+ func (app *App) GroupBroadcast(ctx context.Context, frontendType, groupName, route string, v interface{}) error

+ func (app *App) GroupContainsMember(ctx context.Context, groupName, uid string) (bool, error)

+ func (app *App) GroupCountMembers(ctx context.Context, groupName string) (int, error)

+ func (app *App) GroupCreate(ctx context.Context, groupName string) error

+ func (app *App) GroupCreateWithTTL(ctx context.Context, groupName string, ttlTime time.Duration) error

+ func (app *App) GroupDelete(ctx context.Context, groupName string) error

+ func (app *App) GroupMembers(ctx context.Context, groupName string) ([]string, error)

+ func (app *App) GroupRemoveAll(ctx context.Context, groupName string) error

+ func (app *App) GroupRemoveMember(ctx context.Context, groupName, uid string) error

+ func (app *App) GroupRenewTTL(ctx context.Context, groupName string) error

+ func (app *App) RPC(ctx context.Context, routeStr string, reply proto.Message, arg proto.Message) error

+ func (app *App) RPCTo(ctx context.Context, serverID, routeStr string, reply proto.Message, ...) error

+ func (app *App) Register(c component.Component, options ...component.Option)

+ func (app *App) RegisterModule(module interfaces.Module, name string) error

+ func (app *App) RegisterModuleAfter(module interfaces.Module, name string) error

+ func (app *App) RegisterModuleBefore(module interfaces.Module, name string) error

+ func (app *App) RegisterRPCJob(rpcJob worker.RPCJob) error

+ func (app *App) RegisterRemote(c component.Component, options ...component.Option)

+ func (app *App) ReliableRPC(routeStr string, metadata map[string]interface{}, reply, arg proto.Message) (jid string, err error)

+ func (app *App) ReliableRPCWithOptions(routeStr string, metadata map[string]interface{}, reply, arg proto.Message, ...) (jid string, err error)

+ func (app *App) SendKickToUsers(uids []string, frontendType string) ([]string, error)

+ func (app *App) SendPushToUsers(route string, v interface{}, uids []string, frontendType string) ([]string, error)

+ func (app *App) SetDebug(debug bool)

+ func (app *App) SetDictionary(dict map[string]uint16) error

+ func (app *App) SetHeartbeatTime(interval time.Duration)

+ func (app *App) Shutdown()

+ func (app *App) Start()

+ func (app *App) StartWorker()

+ type Builder struct

+ Config BuilderConfig

+ DieChan chan bool

+ Groups groups.GroupService

+ HandlerHooks *pipeline.HandlerHooks

+ MessageEncoder *message.MessagesEncoder

+ MetricsReporters []metrics.Reporter

+ PacketDecoder codec.PacketDecoder

+ PacketEncoder codec.PacketEncoder

+ RPCClient cluster.RPCClient

+ RPCServer cluster.RPCServer

+ Router *router.Router

+ Serializer serialize.Serializer

+ Server *cluster.Server

+ ServerMode ServerMode

+ ServiceDiscovery cluster.ServiceDiscovery

+ SessionPool session.SessionPool

+ Worker *worker.Worker

+ func NewBuilder(isFrontend bool, serverType string, serverMode ServerMode, ...) *Builder

+ func NewBuilderWithConfigs(isFrontend bool, serverType string, serverMode ServerMode, ...) *Builder

+ func NewDefaultBuilder(isFrontend bool, serverType string, serverMode ServerMode, ...) *Builder

+ func (builder *Builder) AddAcceptor(ac acceptor.Acceptor)

+ func (builder *Builder) Build() Pitaya

+ type BuilderConfig struct

+ IsDefaultPipelineEnabled bool

+ IsPrometheusEnabled bool

+ IsStatsdEnabled bool

+ PitayaConfig PitayaConfig

+ func NewBuilderConfig(config *config.Config) BuilderConfig

+ func NewDefaultBuilderConfig() BuilderConfig

+ type Pitaya interface

+ AddRoute func(serverType string, routingFunction router.RoutingFunc) error

+ Documentation func(getPtrNames bool) (map[string]interface{}, error)

+ GetDieChan func() chan bool

+ GetMetricsReporters func() []metrics.Reporter

+ GetModule func(name string) (interfaces.Module, error)

+ GetServer func() *cluster.Server

+ GetServerByID func(id string) (*cluster.Server, error)

+ GetServerID func() string

+ GetServers func() []*cluster.Server

+ GetServersByType func(t string) (map[string]*cluster.Server, error)

+ GetSessionFromCtx func(ctx context.Context) session.Session

+ GroupAddMember func(ctx context.Context, groupName, uid string) error

+ GroupBroadcast func(ctx context.Context, frontendType, groupName, route string, v interface{}) error

+ GroupContainsMember func(ctx context.Context, groupName, uid string) (bool, error)

+ GroupCountMembers func(ctx context.Context, groupName string) (int, error)

+ GroupCreate func(ctx context.Context, groupName string) error

+ GroupCreateWithTTL func(ctx context.Context, groupName string, ttlTime time.Duration) error

+ GroupDelete func(ctx context.Context, groupName string) error

+ GroupMembers func(ctx context.Context, groupName string) ([]string, error)

+ GroupRemoveAll func(ctx context.Context, groupName string) error

+ GroupRemoveMember func(ctx context.Context, groupName, uid string) error

+ GroupRenewTTL func(ctx context.Context, groupName string) error

+ RPC func(ctx context.Context, routeStr string, reply proto.Message, arg proto.Message) error

+ RPCTo func(ctx context.Context, serverID, routeStr string, reply proto.Message, ...) error

+ Register func(c component.Component, options ...component.Option)

+ RegisterModule func(module interfaces.Module, name string) error

+ RegisterModuleAfter func(module interfaces.Module, name string) error

+ RegisterModuleBefore func(module interfaces.Module, name string) error

+ RegisterRPCJob func(rpcJob worker.RPCJob) error

+ RegisterRemote func(c component.Component, options ...component.Option)

+ ReliableRPC func(routeStr string, metadata map[string]interface{}, reply, arg proto.Message) (jid string, err error)

+ ReliableRPCWithOptions func(routeStr string, metadata map[string]interface{}, reply, arg proto.Message, ...) (jid string, err error)

+ SendKickToUsers func(uids []string, frontendType string) ([]string, error)

+ SendPushToUsers func(route string, v interface{}, uids []string, frontendType string) ([]string, error)

+ SetDebug func(debug bool)

+ SetDictionary func(dict map[string]uint16) error

+ SetHeartbeatTime func(interval time.Duration)

+ Shutdown func()

+ Start func()

+ StartWorker func()

+ func NewDefaultApp(isFrontend bool, serverType string, serverMode ServerMode, ...) Pitaya

+ type PitayaBuilder interface

+ Build func() Pitaya

+ type PitayaConfig struct

+ BufferAgentMessages int

+ BufferHandlerLocalProcess int

+ BufferHandlerRemoteProcess int

+ ConcurrencyHandlerDispatch int

+ HearbeatInterval time.Duration

+ MessageCompression bool

+ MetricsPeriod time.Duration

+ SessionUnique bool

+ func NewDefaultPitayaConfig() PitayaConfig

+ func NewPitayaConfig(config *config.Config) PitayaConfig

+ type ServerMode byte

+ const Cluster

+ const Standalone

Other modules containing this package

github.com/felippeduran/pitaya