rpc

Documentation

Index

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

Types

type EventService

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

EventService is a service server for message processing

func NewEventService

func NewEventService(cc container.Container) *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 container.Container) *HeartbeatService

func (*HeartbeatService) Ping

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

type ServiceProvider

type ServiceProvider struct{}

func (ServiceProvider) Boot

func (p ServiceProvider) Boot(app infra.Glacier)

func (ServiceProvider) Daemon

func (p ServiceProvider) Daemon(_ context.Context, app infra.Glacier)

func (ServiceProvider) Register

func (p ServiceProvider) Register(app container.Container)