rpc

Documentation

Index

• type EventService
  • func NewEventService(cc infra.Resolver) *EventService
  • func (ms *EventService) Push(ctx context.Context, request *protocol.MessageRequest) (*protocol.IDResponse, error)
• type HeartbeatService
  • func NewHeartbeatService(cc infra.Resolver) *HeartbeatService
  • func (h *HeartbeatService) Ping(ctx context.Context, request *protocol.PingRequest) (*protocol.PongResponse, error)
• type Provider
  • func (p Provider) Boot(app infra.Resolver)
  • func (p Provider) Daemon(_ context.Context, app infra.Resolver)
  • func (p Provider) Register(app infra.Binder)

Types

type EventService

type EventService struct {
	// contains filtered or unexported fields
}

EventService is a service server for message processing

func NewEventService

func NewEventService(cc infra.Resolver) *EventService

NewEventService create a new message service

func (*EventService) Push

func (ms *EventService) Push(ctx context.Context, request *protocol.MessageRequest) (*protocol.IDResponse, error)

Push add a new message

type HeartbeatService

type HeartbeatService struct {
	// contains filtered or unexported fields
}

HeartbeatService is a service server for heartbeat

func NewHeartbeatService

func NewHeartbeatService(cc infra.Resolver) *HeartbeatService

func (*HeartbeatService) Ping

func (h *HeartbeatService) Ping(ctx context.Context, request *protocol.PingRequest) (*protocol.PongResponse, error)

type Provider

type Provider struct{}

func (Provider) Boot

func (p Provider) Boot(app infra.Resolver)

func (Provider) Daemon

func (p Provider) Daemon(_ context.Context, app infra.Resolver)

func (Provider) Register

func (p Provider) Register(app infra.Binder)