service

Documentation

Index

• type AllReadReq
• type AllReadResp
• type CacheZone
  • func NewCacheZone(ctx context.Context, conf *config.Config, log logr.Logger) (*CacheZone, error)
  • func (c *CacheZone) Create(ctx context.Context, obj wm.Object) error
  • func (c *CacheZone) Delete(ctx context.Context, obj wm.Object) error
  • func (c *CacheZone) Publish(ctx context.Context, req *PublishReq) (*PublishResp, error)
  • func (c *CacheZone) Renewal(ctx context.Context, obj wm.Object) error
• type CenterMsByIDReq
• type CenterMsByIDResp
• type CreateMessageReq
• type CreateMessageResp
• type CreateTemplateReq
• type CreateTemplateResp
• type DeleteByIDsReq
• type DeleteByIDsResp
• type DeleteMessageReq
• type DeleteMessageResp
• type DeleteTemplateReq
• type DeleteTemplateResp
• type GetMesByIDReq
• type GetMesByIDResp
• type GetNumberReq
• type GetNumberResp
• type GetNumberRespVO
• type ListReq
• type ListResp
• type MesVO
• type Message
  • func NewMessage(conf *config.Config, log logr.Logger) (Message, error)
• type PublishReq
• type PublishResp
• type QueryTemplateReq
• type QueryTemplateResp
• type ReadByIDsReq
• type ReadByIdsResp
• type Record
  • func NewRecord(conf *config.Config, log logr.Logger) (Record, error)
• type RecordListReq
• type RecordListResp
• type RecordVo
• type Template
  • func NewTemplate(conf *config.Config, log logr.Logger) (Template, error)
• type TemplateVo
• type UpdateTemplateReq
• type UpdateTemplateResp

Types

type AllReadReq

type AllReadReq struct {
	ReceiverID string
}

AllReadReq req

type AllReadResp

type AllReadResp struct {
}

AllReadResp resp

type CacheZone

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

func NewCacheZone

func NewCacheZone(ctx context.Context, conf *config.Config, log logr.Logger) (*CacheZone, error)

func (*CacheZone) Create

func (c *CacheZone) Create(ctx context.Context, obj wm.Object) error

func (*CacheZone) Delete

func (c *CacheZone) Delete(ctx context.Context, obj wm.Object) error

func (*CacheZone) Publish

func (c *CacheZone) Publish(ctx context.Context, req *PublishReq) (*PublishResp, error)

func (*CacheZone) Renewal

func (c *CacheZone) Renewal(ctx context.Context, obj wm.Object) error

type CenterMsByIDReq

type CenterMsByIDReq struct {
	ID   string `json:"id"`
	Read bool   `json:"read"`
}

CenterMsByIDReq req

type CenterMsByIDResp

type CenterMsByIDResp struct {
	ID          string                `json:"id"`
	Content     string                `json:"content"`
	Title       string                `json:"title"`
	CreatorName string                `json:"creatorName"`
	ReadStatus  constant.ReadStatus   `json:"readStatus"`
	CreatedAt   int64                 `json:"createdAt"`
	Files       models.Files          `json:"files"`
	Types       constant.MessageTypes `json:"types"`
}

CenterMsByIDResp resp

type CreateMessageReq

type CreateMessageReq struct {
	UserID   string `json:"userID,omitempty"`
	UserName string `json:"userName,omitempty"`
	// contains filtered or unexported fields
}

type CreateMessageResp

type CreateMessageResp struct {
	ID string `json:"id"`
}

CreateMessageResp resp

type CreateTemplateReq

type CreateTemplateReq struct {
	Name     string `json:"name"`
	Title    string `json:"title"`
	Content  string `json:"content"`
	CreateBy string `json:"create_by"`
	Status   int    `json:"status"`
}

CreateTemplateReq 创建CreateTemplateReq 结构体

type CreateTemplateResp

type CreateTemplateResp struct {
}

CreateTemplateResp resp

type DeleteByIDsReq

type DeleteByIDsReq struct {
	ArrID []string `json:"ids"`
}

DeleteByIDsReq req

type DeleteByIDsResp

type DeleteByIDsResp struct {
}

DeleteByIDsResp resp

type DeleteMessageReq

type DeleteMessageReq struct {
	ID string `json:"id"`
}

DeleteMessageReq req

type DeleteMessageResp

type DeleteMessageResp struct {
}

DeleteMessageResp resp

type DeleteTemplateReq

type DeleteTemplateReq struct {
	ID string `json:"id"`
}

DeleteTemplateReq 删除

type DeleteTemplateResp

type DeleteTemplateResp struct {
}

DeleteTemplateResp resp

type GetMesByIDReq

type GetMesByIDReq struct {
	ID string `json:"id"`
}

GetMesByIDReq by id

type GetMesByIDResp

type GetMesByIDResp struct {
	ID          string                `json:"id"`
	Title       string                `json:"title"`
	Types       constant.MessageTypes `json:"types"`
	Receivers   models.Receivers      `json:"receivers"`
	Content     string                `json:"content"`
	Files       models.Files          `json:"files"`
	CreatorName string                `json:"creatorName"`
	Success     int                   `json:"success"`
	CreatedAt   int64                 `json:"createdAt"`
	Fail        int                   `json:"fail"`
	SendNum     int                   `json:"sendNum"`
}

GetMesByIDResp by id resp

type GetNumberReq

type GetNumberReq struct {
	ReceiverID string `json:"receiverId"`
}

GetNumberReq req

type GetNumberResp

type GetNumberResp struct {
	TypeNum []*GetNumberRespVO `json:"typeNum"`
}

GetNumberResp resp

type GetNumberRespVO

type GetNumberRespVO struct {
	Total int64                 `json:"total"`
	Types constant.MessageTypes `json:"types"`
}

GetNumberRespVO vo

type ListReq

type ListReq struct {
	Status  int8   `json:"status"`
	Sort    int8   `json:"sort"`
	Page    int    `json:"page"`
	Limit   int    `json:"limit"`
	KeyWord string `json:"key"`
}

ListReq ListReq req

type ListResp

type ListResp struct {
	Messages []*MesVO `json:"messages"`
	Total    int64    `json:"total"`
}

ListResp ListResp resp

type MesVO

type MesVO struct {
	ID          string                 `json:"id"`
	Types       constant.MessageTypes  `json:"types"`
	Title       string                 `json:"title"`
	CreatorName string                 `json:"createdName"`
	CreatedAt   int64                  `json:"createdAt"`
	SendNum     int                    `json:"sendNum"`
	Success     int                    `json:"success"`
	Fail        int                    `json:"fail"`
	Files       models.Files           `json:"files"`
	Status      constant.MessageStatus `json:"status"`
}

MesVO vo

type Message

type Message interface {
	CreateMessage(ctx context.Context, req *CreateMessageReq) (*CreateMessageResp, error)

	GetMesByID(ctx context.Context, req *GetMesByIDReq) (*GetMesByIDResp, error)

	DeleteMessage(ctx context.Context, req *DeleteMessageReq) (*DeleteMessageResp, error)

	MessageList(ctx context.Context, req *ListReq) (*ListResp, error)
}

Message message

func NewMessage

func NewMessage(conf *config.Config, log logr.Logger) (Message, error)

NewMessage create

type PublishReq

type PublishReq struct {
	UserID  string   `json:"userID,omitempty"`
	UUID    []string `json:"uuid,omitempty"`
	Content []byte   `json:"content,omitempty"`
}

type PublishResp

type PublishResp struct{}

type QueryTemplateReq

type QueryTemplateReq struct {
	Title string `json:"title"`
	Page  int    `json:"page"`
	Limit int    `json:"limit"`
}

QueryTemplateReq req

type QueryTemplateResp

type QueryTemplateResp struct {
	Template []*TemplateVo `json:"template"`
	Total    int64         `josn:"total"`
}

QueryTemplateResp resp

type ReadByIDsReq

type ReadByIDsReq struct {
	ArrID []string `json:"ids"`
}

ReadByIDsReq req

type ReadByIdsResp

type ReadByIdsResp struct {
}

ReadByIdsResp resp

type Record

type Record interface {
	CenterMsByID(ctx context.Context, req *CenterMsByIDReq) (*CenterMsByIDResp, error)
	GetNumber(ctx context.Context, req *GetNumberReq) (*GetNumberResp, error)
	AllRead(ctx context.Context, req *AllReadReq) (*AllReadResp, error)
	DeleteByIDs(ctx context.Context, req *DeleteByIDsReq) (*DeleteByIDsResp, error)
	ReadByIDs(ctx context.Context, req *ReadByIDsReq) (*ReadByIdsResp, error)
	RecordList(ctx context.Context, req *RecordListReq) (*RecordListResp, error)
}

Record message send

func NewRecord

func NewRecord(conf *config.Config, log logr.Logger) (Record, error)

NewRecord create

type RecordListReq

type RecordListReq struct {
	ReadStatus int    `json:"readStatus"`
	Types      int    `json:"types"`
	ReceiverID string `json:"receiverID"`
	Page       int    `json:"page"`
	Limit      int    `json:"limit"`
}

RecordListReq req

type RecordListResp

type RecordListResp struct {
	List  []*RecordVo `json:"list"`
	Total int64       `json:"total"`
}

RecordListResp resp

type RecordVo

type RecordVo struct {
	ID         string                `json:"id"`
	Title      string                `json:"title"`
	CreatedAt  int64                 `json:"createdAt"`
	Content    string                `json:"content"`
	Types      constant.MessageTypes `json:"types"`
	ReadStatus constant.ReadStatus   `json:"readStatus"`
	Files      models.Files          `json:"files"`
}

RecordVo vo

type Template

type Template interface {
	CreateTemplate(ctx context.Context, req *CreateTemplateReq) (*CreateTemplateResp, error)

	UpdateTemplate(ctx context.Context, req *UpdateTemplateReq) (*UpdateTemplateResp, error)

	DeleteTemplate(ctx context.Context, req *DeleteTemplateReq) (*DeleteTemplateResp, error)
	QueryTemplate(ctx context.Context, req *QueryTemplateReq) (*QueryTemplateResp, error)
}

Template Template

func NewTemplate

func NewTemplate(conf *config.Config, log logr.Logger) (Template, error)

NewTemplate create

type TemplateVo

type TemplateVo struct {
	ID        string `josn:"id"`
	Title     string `json:"title"`
	Content   string `json:"content"`
	CreatedAt int64  `json:"created_at"`
	UpdatedAt int64  `json:"updated_at"`
}

TemplateVo vo

type UpdateTemplateReq

type UpdateTemplateReq struct {
	ID      string `json:"templateId"`
	Name    string `json:"name"`
	Title   string `json:"title"`
	Content string `json:"content"`
	Status  int    `json:"status"`
}

UpdateTemplateReq 修改TemplateReq 结构体

type UpdateTemplateResp

type UpdateTemplateResp struct {
}

UpdateTemplateResp resp