data

package
v0.0.0-...-47f30e4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2021 License: MIT Imports: 16 Imported by: 0

README

Data

Documentation

Index

Constants

This section is empty.

Variables

ProviderSet is data providers.

Functions

func NewJobRepoImpl

func NewJobRepoImpl(data *Data, logger log.Logger) biz.JobRepo

func NewNoticeRepoImpl

func NewNoticeRepoImpl(data *Data, logger log.Logger) biz.NoticeRepo

func NewSignInRepoImpl

func NewSignInRepoImpl(data *Data, logger log.Logger) biz.SignInRepo

func NewWxRepoImpl

func NewWxRepoImpl(logger log.Logger) biz.WxRepo

Types

type BucketName

type BucketName interface {
	TableName() string
}

type Data

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

Data .

func NewData

func NewData(c *conf.Data, logger log.Logger) (*Data, func(), error)

NewData .

type JobRepoImpl

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

func (*JobRepoImpl) DeleteJob

func (j *JobRepoImpl) DeleteJob(ctx context.Context, openid string, jobID uint64) error

func (*JobRepoImpl) GetAllJobs

func (j *JobRepoImpl) GetAllJobs(ctx context.Context, openid string) ([]*biz.Job, error)

func (*JobRepoImpl) GetJobByID

func (j *JobRepoImpl) GetJobByID(ctx context.Context, openid string, jobID uint64) (job *biz.Job, err error)

func (*JobRepoImpl) PutJob

func (j *JobRepoImpl) PutJob(ctx context.Context, job *biz.Job) (*biz.Job, error)

func (*JobRepoImpl) TableName

func (j *JobRepoImpl) TableName() string

func (*JobRepoImpl) TableNameWithOpenID

func (j *JobRepoImpl) TableNameWithOpenID(openid string) string

type NoticeRepoImpl

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

func (*NoticeRepoImpl) AddOpenID

func (n *NoticeRepoImpl) AddOpenID(ctx context.Context, openID string) error

func (*NoticeRepoImpl) CheckOpenID

func (n *NoticeRepoImpl) CheckOpenID(ctx context.Context, openID string) error

func (*NoticeRepoImpl) GetAllOpenID

func (n *NoticeRepoImpl) GetAllOpenID(ctx context.Context) ([]string, error)

func (*NoticeRepoImpl) TableName

func (n *NoticeRepoImpl) TableName() string

type SignInRepoImpl

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

func (*SignInRepoImpl) GetSignInList

func (s *SignInRepoImpl) GetSignInList(ctx context.Context, openid string) ([]time.Time, error)

func (*SignInRepoImpl) SignIn

func (s *SignInRepoImpl) SignIn(ctx context.Context, openid string, date time.Time) error

func (*SignInRepoImpl) TableName

func (s *SignInRepoImpl) TableName() string

func (*SignInRepoImpl) TableNameWithOpenID

func (s *SignInRepoImpl) TableNameWithOpenID(openid string) string

type WxRepoImpl

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

func (*WxRepoImpl) Code2Session

func (w *WxRepoImpl) Code2Session(ctx context.Context, request *pb.Code2SessionRequest) (*pb.Code2SessionReply, error)

func (*WxRepoImpl) GetAccessToken

func (w *WxRepoImpl) GetAccessToken(ctx context.Context, request *pb.GetAccessTokenRequest) (*pb.GetAccessTokenReply, error)

func (*WxRepoImpl) SubscribeSend

func (w *WxRepoImpl) SubscribeSend(ctx context.Context, request *pb.SubscribeSendRequest) (*pb.SubscribeSendReply, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳