proxy

Documentation

Index

• type MsgConverter
• type PushProxy
  • func NewPushProxy(msgConv MsgConverter) (*PushProxy, error)
  • func (p *PushProxy) Broadcast(ctx context.Context, msg interface{}) error
  • func (p *PushProxy) Multicast(ctx context.Context, msg interface{}) error
  • func (p *PushProxy) Unicast(ctx context.Context, msg interface{}) error

Types

type MsgConverter

type MsgConverter interface {
	ToUnicast(interface{}) ([]*proto.PushToSingleReq, error)
	ToMulticast(interface{}) (*proto.CreateTaskReq, []*proto.PushToListReq, error)
	ToBroadcast(interface{}) (*proto.PushToAppReq, error)
}

type PushProxy

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

func NewPushProxy

func NewPushProxy(msgConv MsgConverter) (*PushProxy, error)

func (*PushProxy) Broadcast

func (p *PushProxy) Broadcast(ctx context.Context, msg interface{}) error

func (*PushProxy) Multicast

func (p *PushProxy) Multicast(ctx context.Context, msg interface{}) error

func (*PushProxy) Unicast

func (p *PushProxy) Unicast(ctx context.Context, msg interface{}) error