manager

Documentation

Index

• type Manager
  • func NewManager(logger logs.Logger, cache interfaces.KvCache) *Manager
  • func (m *Manager) GetAccessToken(appKey string) (string, error)
  • func (m *Manager) GetClient(appKey, appSecret string, agentId int64) interfaces.DingtalkApiClient
  • func (m *Manager) GetUserIdsByPhones(accessToken string, agentId int64, phones []string) (userIds []string, err error)
  • func (m *Manager) RegisterApp(appKey, appSecret string) interfaces.DingtalkAccessTokenManager
• type TaskContext
  • func NewTaskContext(concurrency int, result interface{}) *TaskContext
  • func (t *TaskContext) Add()
  • func (t *TaskContext) Done()
  • func (t *TaskContext) Wait()

Types

type Manager

type Manager struct {
	Log   logs.Logger
	Cache interfaces.KvCache
	// contains filtered or unexported fields
}

func NewManager

func NewManager(logger logs.Logger, cache interfaces.KvCache) *Manager

func (*Manager) GetAccessToken

func (m *Manager) GetAccessToken(appKey string) (string, error)

func (*Manager) GetClient

func (m *Manager) GetClient(appKey, appSecret string, agentId int64) interfaces.DingtalkApiClient

func (*Manager) GetUserIdsByPhones

func (m *Manager) GetUserIdsByPhones(accessToken string, agentId int64, phones []string) (userIds []string, err error)

func (*Manager) RegisterApp

func (m *Manager) RegisterApp(appKey, appSecret string) interfaces.DingtalkAccessTokenManager

type TaskContext

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

func NewTaskContext

func NewTaskContext(concurrency int, result interface{}) *TaskContext

func (*TaskContext) Add

func (t *TaskContext) Add()

func (*TaskContext) Done

func (t *TaskContext) Done()

func (*TaskContext) Wait

func (t *TaskContext) Wait()