callback

Documentation

Index

• type Callback
  • func NewCallback(config *conf.Callback, ctx context.Context) (Callback, error)
• type Record

Types

type Callback

type Callback interface {
	OnConnect(ctx context.Context, service string, request *pb.OnConnectRequest) (*pb.OnConnectReply, error)
	OnSubscribe(ctx context.Context, service string, request *pb.OnSubscribeRequest) (*pb.OnSubscribeReply, error)
	PostSubscribe(ctx context.Context, service string, request *pb.PostSubscribeRequest) (*pb.PostSubscribeReply, error)
	OnPublish(ctx context.Context, service string, request *pb.OnPublishRequest) (*pb.OnPublishReply, error)
	OnUnsubscribe(ctx context.Context, service string, request *pb.OnUnsubscribeRequest) (*pb.OnUnsubscribeReply, error)
	OnDisconnect(ctx context.Context, service string, request *pb.OnDisconnectRequest) (*pb.OnDisconnectReply, error)
	OnACK(ctx context.Context, service string, request *pb.OnACKRequest) (*pb.OnACKReply, error)
	OnOffline(ctx context.Context, service string, request *pb.OnOfflineRequest) (*pb.OnOfflineReply, error)
	Close() error
	String() string
}

func NewCallback

func NewCallback(config *conf.Callback, ctx context.Context) (Callback, error)

type Record

type Record struct {
	Client map[string]*disConn

	OnConnect     map[string]pb.OnConnectClient
	OnPublish     map[string]pb.OnPublishClient
	OnOffline     map[string]pb.OnOfflineClient
	OnSubscribe   map[string]pb.OnSubscribeClient
	OnDisconnect  map[string]pb.OnDisconnectClient
	PostSubscribe map[string]pb.PostSubscribeClient
	OnUnsubscribe map[string]pb.OnUnsubscribeClient
	OnACK         map[string]pb.OnACKClient
}