service

Documentation

Index

• Constants
• Variables
• func CreateInitServerFn(ps *Subscribe) rpc.InitServer
• type Subscribe
  • func NewSubscribe(rdb *redis.Client) *Subscribe
  • func (s *Subscribe) Close(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Subscribe) List(ctx context.Context, _ *pb.SubscribeRequest) (*pb.SubscribeReply, error)
  • func (s *Subscribe) Open(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Subscribe) Register(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Subscribe) Status(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

Constants

const RuleKey = "subscribe:rule"

Variables

var ProviderSet = wire.NewSet(NewSubscribe, CreateInitServerFn)

Functions

func CreateInitServerFn

func CreateInitServerFn(ps *Subscribe) rpc.InitServer

Types

type Subscribe

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

func NewSubscribe

func NewSubscribe(rdb *redis.Client) *Subscribe

func (*Subscribe) Close

func (s *Subscribe) Close(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Subscribe) List

func (s *Subscribe) List(ctx context.Context, _ *pb.SubscribeRequest) (*pb.SubscribeReply, error)

func (*Subscribe) Open

func (s *Subscribe) Open(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Subscribe) Register

func (s *Subscribe) Register(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Subscribe) Status

func (s *Subscribe) Status(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)