heartbeat

Documentation

Index

• type HeartbeatService
  • func NewHeartbeatServiceServer(consumerMgr consumer.ConsumerManager) (*HeartbeatService, error)
  • func (h *HeartbeatService) Heartbeat(ctx context.Context, hb *pb.Heartbeat) (*pb.Response, error)
• type Processor

Types

type HeartbeatService

type HeartbeatService struct {
	pb.UnimplementedHeartbeatServiceServer
	// contains filtered or unexported fields
}

func NewHeartbeatServiceServer

func NewHeartbeatServiceServer(consumerMgr consumer.ConsumerManager) (*HeartbeatService, error)

func (*HeartbeatService) Heartbeat

func (h *HeartbeatService) Heartbeat(ctx context.Context, hb *pb.Heartbeat) (*pb.Response, error)

type Processor

type Processor interface {
	Heartbeat(consumerMgr consumer.ConsumerManager, msg *pb.Heartbeat) (*pb.Response, error)
}