Documentation ¶
Index ¶
- type Checker
- type DB
- type Exec
- type Service
- func (s *Service) DealOpSendMsg(ctx context.Context, m *logic.BizMsg) error
- func (s *Service) InnerPush(ctx context.Context, key, from, target string, pushType imparse.Channel, ...) (int64, error)
- func (s *Service) ListenMQ()
- func (s *Service) Push(ctx context.Context, key, from string, body []byte) (int64, uint64, error)
- func (s *Service) Shutdown(ctx context.Context)
- type Trace
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Exec ¶
type Exec struct {
// contains filtered or unexported fields
}
send msg callback
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) DealOpSendMsg ¶
func (*Service) InnerPush ¶
func (s *Service) InnerPush(ctx context.Context, key, from, target string, pushType imparse.Channel, body []byte) (int64, error)
gRPC调用的内部推送通道,不经过check
Click to show internal directories.
Click to hide internal directories.