issuestream

Documentation

Index

• type IssueStream
  • func New(options ...Option) *IssueStream
  • func (s *IssueStream) Create(req *apistructs.IssueStreamCreateRequest) (int64, error)
  • func (s *IssueStream) CreateIssueEvent(issueID int64, streamType apistructs.IssueStreamType, ...) error
  • func (s *IssueStream) Paging(req *apistructs.IssueStreamPagingRequest) (*apistructs.IssueStreamPagingResponseData, error)
• type Option
  • func WithBundle(bdl *bundle.Bundle) Option
  • func WithDBClient(db *dao.DBClient) Option

Types

type IssueStream

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

IssueStream issue stream service 对象

func New

func New(options ...Option) *IssueStream

New 新建 issue stream 对象

func (*IssueStream) Create

func (s *IssueStream) Create(req *apistructs.IssueStreamCreateRequest) (int64, error)

Create 创建事件记录

func (*IssueStream) CreateIssueEvent

func (s *IssueStream) CreateIssueEvent(issueID int64, streamType apistructs.IssueStreamType,
	streamParams apistructs.ISTParam) error

CreateIssueEvent create issue event

func (*IssueStream) Paging

func (s *IssueStream) Paging(req *apistructs.IssueStreamPagingRequest) (*apistructs.IssueStreamPagingResponseData, error)

Paging 事件流记录分页查询

type Option

type Option func(*IssueStream)

Option 定义 IssueStream 对象配置选项

func WithBundle

func WithBundle(bdl *bundle.Bundle) Option

WithBundle 配置 bundle

func WithDBClient

func WithDBClient(db *dao.DBClient) Option

WithDBClient 配置 db client