Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bytemode/pitaya-notes
/ types & classes
Types & classes
272 in github.com/bytemode/pitaya-notes
⨍
Functions
1,948
◇
Types & classes
272
↓ 2 callers
TypeAlias
Type
定义网络包的类型 Packet Type represents the network packet's type such as: handshake and so on.
conn/packet/constants.go:27
↓ 1 callers
TypeAlias
Type
Type represents the type of message, which could be Request/Notify/Response/Push
conn/message/message.go:30
Struct
APIDocsGen
APIDocsGen is a pitaya module that generates api docs for pitaya servers
modules/api_docs_gen.go:29
Interface
Acceptor
Acceptor 前端服务器必须制定一个多个接收器来处理传入的客户端连接,pitaya已经实现TCP和WebSocket的接收器 通过实现Acceptor接口添加新的接收器 intercace 的实现方法时有一个变量实现了接口中所有方法即实现了接口 interface{}空接口没有任何方法所有类型都
acceptor/acceptor.go:29
TypeAlias
Action
Action type for enum
cluster/cluster.go:72
FuncType
AfterHandlerTempl
AfterHandlerTempl is a function for the after handler, receives both the handler response and the error returned
pipeline/pipeline.go:39
Struct
Agent
Agent corresponds to a user and is used for storing raw Conn information
agent/agent.go:65
Struct
AllMembers
AllMembers contains all members uid
examples/demo/cluster_grpc/services/room.go:52
Struct
AllMembers
AllMembers contains all members uid
examples/demo/chat/main.go:44
Struct
AllMembers
AllMembers contains all members uid
examples/demo/cluster_protobuf/protos/cluster.pb.go:201
Struct
AllMembers
AllMembers contains all members uid
examples/demo/cluster/services/room.go:55
Struct
App
App is the base app struct
app.go:73
Struct
Arg
please upgrade the proto package
examples/demo/worker/protos/arg.pb.go:21
Struct
Base
Base implements a default component for Component.
modules/base.go:24
Struct
Base
Base implements a default component for Component. 实现一个默认的组件
component/base.go:24
Struct
BaseWrapper
接收器包装器 包装器可以包装接收器,以执行消息转发之前读取和更改传入的数据 创建包装器需要从BaseWrapper继承或者实现Wrapper接口然后使用WithWrappers将其添加到接收器中 BaseWrapper implements Wrapper by saving the accepto
acceptorwrapper/base.go:36
Struct
Binary
Binary is a pitaya module that starts a binary as a child process and pipes its stdout
modules/binary.go:35
Struct
BindMsg
please upgrade the proto package
protos/bind.pb.go:21
Interface
BindingStorage
BindingStorage interface
interfaces/interfaces.go:32
Interface
Client
Client is the interface to required dogstatsd functions
metrics/statsd_reporter.go:33
Struct
Client
Client struct
client/client.go:78
Struct
Command
Command struct. Save the input and output type and proto descriptor for each one.
client/protoclient.go:44
Interface
Component
Component is the interface that represent a component. 组件接口
component/component.go:24
Interface
Condition
Condition represents a checker that returns true when cron job needs to execute
timer/timer.go:62
Struct
Config
使用viper作为配置 并且做封装 Config is a wrapper around a viper config
config/config.go:32
Struct
ConfigInfoRetriever
ConfigInfoRetriever gets cluster info from config Implements InfoRetriever interface
cluster/config_info_retriever.go:7
Struct
Connector
Connector struct
examples/demo/cluster_grpc/services/connector.go:18
Struct
Connector
Connector struct
examples/demo/cluster_protobuf/services/connector.go:17
Struct
Connector
Connector struct
examples/demo/cluster/services/connector.go:19
Struct
ConnectorRemote
ConnectorRemote is a remote that will receive rpc's
examples/demo/cluster_grpc/services/connector.go:13
Struct
ConnectorRemote
ConnectorRemote is a remote that will receive rpc's
examples/demo/cluster_protobuf/services/connector.go:12
Struct
ConnectorRemote
ConnectorRemote is a remote that will receive rpc's
examples/demo/cluster/services/connector.go:14
Struct
Counter
Counter defines a counter metric
metrics/models.go:25
Struct
CreatePlayerCheatArgs
CreatePlayerCheatArgs is the struct used as parameter for the CreatePlayerCheat handler Using the 'validate' tag it's possible to add validations on a
examples/demo/pipeline/main.go:29
Struct
CreatePlayerCheatResponse
CreatePlayerCheatResponse ...
examples/demo/pipeline/main.go:37
Struct
CustomMetricsSpec
CustomMetricsSpec has all metrics specs
metrics/models.go:33
Struct
DefaultValidator
DefaultValidator is the default arguments validator for handlers in pitaya
defaultpipelines/default_struct_validator.go:12
Struct
Doc
please upgrade the proto package
protos/doc.pb.go:21
Struct
Doc
examples/demo/protos/cluster.pb.go:99
Struct
DocMsg
please upgrade the proto package
protos/docmsg.pb.go:21
Struct
ETCDBindingStorage
ETCDBindingStorage module that uses etcd to keep in which frontend server each user is bound ETCD上存储了 bings/frontype/uid: frontserverid etcd上存储用户连接的前端
modules/binding_storage.go:39
Interface
Encoder
Encoder interface
conn/message/message_encoder.go:30
Struct
EnqueueOpts
EnqueueOpts has retry options for worker
worker/enqueue_opts.go:26
Struct
Error
please upgrade the proto package
protos/error.pb.go:21
Struct
Error
Error is an error with a code, message and metadata
errors/errors.go:40
Struct
EtcdGroupService
EtcdGroupService base ETCD struct solution
groups/etcd_group_service.go:24
Struct
ExportedTypeWithNoHandlerAndNoRemote
component/service_test.go:36
FuncType
Func
Func represents a function which will be called periodically in main logic gorontine.
timer/timer.go:58
Struct
GRPCClient
GRPCClient rpc server struct GRPCClient 管理本机上连接到的所有的服务器的grpcClient
cluster/grpc_rpc_client.go:47
Struct
GRPCServer
GRPCServer rpc server struct
cluster/grpc_rpc_server.go:35
Struct
Gauge
Gauge defines a gauge metric
metrics/models.go:17
Interface
GroupService
GroupService has ranking methods
groups/group_service.go:10
Struct
Handler
Handler represents a message.Message's handler's meta information. Component中Handler方法的反射信息
component/service.go:34
Struct
HandlerNoArgResponse
HandlerNoArgResponse ...
examples/demo/pipeline/main.go:52
Struct
HandlerService
HandlerService service 管理所有组件生成的Service 同时处理连接上的消息使用hander进行处理分发 也处理定时任务更新
service/handler.go:59
FuncType
HandlerTempl
HandlerTempl is a function that has the same signature as a handler and will be called before or after handler methods
pipeline/pipeline.go:35
Struct
HandshakeClientData
HandshakeClientData represents information about the client sent on the handshake.
session/session.go:62
Struct
HandshakeData
HandshakeData struct
client/client.go:67
Struct
HandshakeData
HandshakeData 客户端发送的握手数据 HandshakeData represents information about the handshake sent by the client. `sys` corresponds to information independent fro
session/session.go:73
Struct
HandshakeSys
HandshakeSys struct
client/client.go:60
Interface
InfoRetriever
InfoRetriever gets cluster info It can be implemented, for exemple, by reading env var, config or by accessing the cluster API
cluster/cluster.go:67
Struct
JoinResponse
JoinResponse represents the result of joining room
examples/demo/cluster_grpc/services/room.go:57
Struct
JoinResponse
JoinResponse represents the result of joining room
examples/demo/chat/main.go:49
Struct
JoinResponse
JoinResponse represents the result of joining room
examples/demo/cluster/services/room.go:60
Struct
KickAnswer
protos/kick.pb.go:59
Struct
KickMsg
please upgrade the proto package
protos/kick.pb.go:21
Interface
Logger
Logger represents the log interface
logger/logger.go:28
Interface
Marshaler
Marshaler represents a marshal interface
serialize/serializer.go:28
Struct
MemoryGroup
MemoryGroup is the struct stored in each group key(which is the name of the group)
groups/memory_group_service.go:23
Struct
MemoryGroupService
MemoryGroupService base in server memory solution
groups/memory_group_service.go:19
Struct
Message
message协议的主要作用是封装消息头,包括route和消息类型两部分, 不同的消息类型有着不同的消息头,在消息头里面可能要打入message id(即requestId)和route信息。 由于可能会有route压缩,而且对于服务端push的消息,message id为空,对于客户端请求的响应,
conn/message/message.go:102
Struct
MessagesEncoder
MessagesEncoder implements MessageEncoder interface
conn/message/message_encoder.go:36
Struct
Metagame
Metagame server
examples/demo/worker/services/metagame.go:12
Struct
MetagameServer
MetagameServer ...
examples/demo/pipeline/main.go:16
Struct
MockAcceptor
MockAcceptor is a mock of Acceptor interface
mocks/acceptor.go:14
Struct
MockAcceptorMockRecorder
MockAcceptorMockRecorder is the mock recorder for MockAcceptor
mocks/acceptor.go:20
Struct
MockAddr
MockAddr is a mock of Addr interface
mocks/net.go:16
Struct
MockAddrMockRecorder
MockAddrMockRecorder is the mock recorder for MockAddr
mocks/net.go:22
Struct
MockBindingStorage
MockBindingStorage is a mock of BindingStorage interface
interfaces/mocks/interfaces.go:80
Struct
MockBindingStorageMockRecorder
MockBindingStorageMockRecorder is the mock recorder for MockBindingStorage
interfaces/mocks/interfaces.go:86
Struct
MockClient
MockClient is a mock of Client interface
metrics/mocks/statsd_reporter.go:14
Struct
MockClientMockRecorder
MockClientMockRecorder is the mock recorder for MockClient
metrics/mocks/statsd_reporter.go:20
Struct
MockConn
MockConn is a mock of Conn interface
mocks/net.go:63
Struct
MockConnMockRecorder
MockConnMockRecorder is the mock recorder for MockConn
mocks/net.go:69
Struct
MockEncoder
MockEncoder is a mock of Encoder interface
conn/message/mocks/message_encoder.go:14
Struct
MockEncoderMockRecorder
MockEncoderMockRecorder is the mock recorder for MockEncoder
conn/message/mocks/message_encoder.go:20
Struct
MockModule
MockModule is a mock of Module interface
interfaces/mocks/interfaces.go:13
Struct
MockModuleMockRecorder
MockModuleMockRecorder is the mock recorder for MockModule
interfaces/mocks/interfaces.go:19
Struct
MockNetworkEntity
MockNetworkEntity is a mock of NetworkEntity interface
session/mocks/session.go:16
Struct
MockNetworkEntityMockRecorder
MockNetworkEntityMockRecorder is the mock recorder for MockNetworkEntity
session/mocks/session.go:22
Struct
MockPacketDecoder
MockPacketDecoder is a mock of PacketDecoder interface
conn/codec/mocks/packet_decoder.go:14
Struct
MockPacketDecoderMockRecorder
MockPacketDecoderMockRecorder is the mock recorder for MockPacketDecoder
conn/codec/mocks/packet_decoder.go:20
Struct
MockPacketEncoder
MockPacketEncoder is a mock of PacketEncoder interface
conn/codec/mocks/packet_encoder.go:14
Struct
MockPacketEncoderMockRecorder
MockPacketEncoderMockRecorder is the mock recorder for MockPacketEncoder
conn/codec/mocks/packet_encoder.go:20
Struct
MockPitayaClient
MockPitayaClient is a mock of PitayaClient interface
protos/mocks/pitaya.go:16
Struct
MockPitayaClientMockRecorder
MockPitayaClientMockRecorder is the mock recorder for MockPitayaClient
protos/mocks/pitaya.go:22
Struct
MockPitayaServer
MockPitayaServer is a mock of PitayaServer interface
protos/mocks/pitaya.go:111
Struct
MockPitayaServerMockRecorder
MockPitayaServerMockRecorder is the mock recorder for MockPitayaServer
protos/mocks/pitaya.go:117
Struct
MockRPCClient
MockRPCClient is a mock of RPCClient interface
cluster/mocks/cluster.go:96
Struct
MockRPCClientMockRecorder
MockRPCClientMockRecorder is the mock recorder for MockRPCClient
cluster/mocks/cluster.go:102
next →
1–100 of 272, ranked by callers