logic

package

v0.0.0-...-39337ee Latest Latest Go to latest Published: Jun 20, 2022 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func ConsumeMsgFromMQ(svc *svc.ServiceContext)

从MQ中取出消息

func ServeWs(svc *svc.ServiceContext, w http.ResponseWriter, r *http.Request) error

处理客户端连接

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

客户端在服务端的代表

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

群组

func GetInstanceGroup(groupId string) *Group

func (g *Group) Run()

type PullLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewPullLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullLogic

func (l *PullLogic) Pull(req *types.PullRequest) (*types.PullResponse, error)

type UploadLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUploadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadLogic

func (l *UploadLogic) Upload(req *types.UploadRequest) (*types.UploadResponse, error)