adaptor

Documentation

Index

• type Adaptor
  • func New(options ...Option) *Adaptor
  • func (a *Adaptor) ListSyncRecord() ([]dao.UCSyncRecord, error)
  • func (a *Adaptor) PullAudits() (*apistructs.UCAuditsListResponse, error)
  • func (a *Adaptor) PullAuditsByIDs(ucIDs []int64) (*apistructs.UCAuditsListResponse, error)
  • func (a *Adaptor) RegistryReceiver(receiver ...Receiver)
• type AuditReceiver
  • func NewAuditReceiver(bdl *bundle.Bundle) *AuditReceiver
  • func (ar *AuditReceiver) Name() string
  • func (ar *AuditReceiver) SendAudits(ucaudits *apistructs.UCAuditsListResponse) ([]int64, error)
• type MemberReceiver
  • func NewMemberReceiver(bdl *bundle.Bundle) *MemberReceiver
  • func (mr *MemberReceiver) Name() string
  • func (mr *MemberReceiver) SendAudits(ucaudits *apistructs.UCAuditsListResponse) ([]int64, error)
• type Option
  • func WithBundle(bdl *bundle.Bundle) Option
  • func WithDBClient(db *dao.DBClient) Option
  • func WithUCClient(uc *ucclient.UCClient) Option
• type Receiver

Types

type Adaptor

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

Adaptor 结构体

func New

func New(options ...Option) *Adaptor

New CDP service

func (*Adaptor) ListSyncRecord

func (a *Adaptor) ListSyncRecord() ([]dao.UCSyncRecord, error)

ListSyncRecord 查看uc同步历史记录

func (*Adaptor) PullAudits

func (a *Adaptor) PullAudits() (*apistructs.UCAuditsListResponse, error)

PullAudits 拉取uc的审计事件

func (*Adaptor) PullAuditsByIDs

func (a *Adaptor) PullAuditsByIDs(ucIDs []int64) (*apistructs.UCAuditsListResponse, error)

PullAuditsByIDs 指定uc事件id获取事件

func (*Adaptor) RegistryReceiver

func (a *Adaptor) RegistryReceiver(receiver ...Receiver)

RegistryReceiver 注册uc审计事件的接收者

type AuditReceiver

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

AuditReceiver audit接收uc审计对象

func NewAuditReceiver

func NewAuditReceiver(bdl *bundle.Bundle) *AuditReceiver

NewAuditReceiver 初始化审计事件接收者

func (*AuditReceiver) Name

func (ar *AuditReceiver) Name() string

Name ....

func (*AuditReceiver) SendAudits

func (ar *AuditReceiver) SendAudits(ucaudits *apistructs.UCAuditsListResponse) ([]int64, error)

SendAudits .....

type MemberReceiver

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

MemberReceiver member接收uc审计对象

func NewMemberReceiver

func NewMemberReceiver(bdl *bundle.Bundle) *MemberReceiver

NewMemberReceiver 初始化成员接收者

func (*MemberReceiver) Name

func (mr *MemberReceiver) Name() string

Name .....

func (*MemberReceiver) SendAudits

func (mr *MemberReceiver) SendAudits(ucaudits *apistructs.UCAuditsListResponse) ([]int64, error)

SendAudits .....

type Option

type Option func(*Adaptor)

Option CDP 配置选项

func WithBundle

func WithBundle(bdl *bundle.Bundle) Option

WithBundle 配置 bundle

func WithDBClient

func WithDBClient(db *dao.DBClient) Option

WithDBClient 配置 Issue 数据库选项

func WithUCClient

func WithUCClient(uc *ucclient.UCClient) Option

WithUCClient 配置 uc client

type Receiver

type Receiver interface {
	SendAudits(ucaudits *apistructs.UCAuditsListResponse) ([]int64, error)
	Name() string
}

Receiver 接收uc事件通知的对象