signal

Documentation

Index

• Variables
• type RedisSignalService
  • func (s *RedisSignalService) SignalClear(ctx context.Context, in *pb.SignalClearRequest) (*pb.SignalClearResponse, error)
  • func (s *RedisSignalService) SignalMonitor(req *pb.SignalMonitorRequest, stream pb.SignalService_SignalMonitorServer) error
  • func (s *RedisSignalService) SignalSet(ctx context.Context, in *pb.SignalSetRequest) (*pb.SignalSetResponse, error)
• type SignalService
  • func NewRedisSignalService(rdb *common.RedisClient) (SignalService, error)

Variables

var Keys = &keys{}

Types

type RedisSignalService

type RedisSignalService struct {
	pb.UnimplementedSignalServiceServer
	// contains filtered or unexported fields
}

func (*RedisSignalService) SignalClear

func (s *RedisSignalService) SignalClear(ctx context.Context, in *pb.SignalClearRequest) (*pb.SignalClearResponse, error)

func (*RedisSignalService) SignalMonitor

func (s *RedisSignalService) SignalMonitor(req *pb.SignalMonitorRequest, stream pb.SignalService_SignalMonitorServer) error

func (*RedisSignalService) SignalSet

func (s *RedisSignalService) SignalSet(ctx context.Context, in *pb.SignalSetRequest) (*pb.SignalSetResponse, error)

type SignalService

type SignalService interface {
	pb.SignalServiceServer
	SignalSet(ctx context.Context, in *pb.SignalSetRequest) (*pb.SignalSetResponse, error)
	SignalClear(ctx context.Context, in *pb.SignalClearRequest) (*pb.SignalClearResponse, error)
	SignalMonitor(req *pb.SignalMonitorRequest, stream pb.SignalService_SignalMonitorServer) error
}

func NewRedisSignalService

func NewRedisSignalService(rdb *common.RedisClient) (SignalService, error)