service

Documentation

Overview

Package service NOTES

Index

• type Service
  • func NewService(sd serviced.State, daoSet dao.Set, bs bedis.Client, op client.Interface) (*Service, error)
  • func (s *Service) BatchUpdateLastConsumedTime(ctx context.Context, req *pbcs.BatchUpdateLastConsumedTimeReq) (*pbcs.BatchUpdateLastConsumedTimeResp, error)
  • func (s *Service) BenchAppMeta(ctx context.Context, req *pbcs.BenchAppMetaReq) (*pbcs.BenchAppMetaResp, error)
  • func (s *Service) BenchReleasedCI(ctx context.Context, req *pbcs.BenchReleasedCIReq) (*pbcs.BenchReleasedCIResp, error)
  • func (s *Service) GetAppID(ctx context.Context, req *pbcs.GetAppIDReq) (*pbcs.GetAppIDResp, error)
  • func (s *Service) GetAppMeta(ctx context.Context, req *pbcs.GetAppMetaReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) GetCredential(ctx context.Context, req *pbcs.GetCredentialReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) GetCurrentCursorReminder(ctx context.Context, _ *pbbase.EmptyReq) (*pbcs.CurrentCursorReminderResp, error)
  • func (s *Service) GetReleasedCI(ctx context.Context, req *pbcs.GetReleasedCIReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) GetReleasedHook(ctx context.Context, req *pbcs.GetReleasedHookReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) GetReleasedKv(ctx context.Context, req *pbcs.GetReleasedKvReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) GetReleasedKvValue(ctx context.Context, req *pbcs.GetReleasedKvValueReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) Handler() (http.Handler, error)
  • func (s *Service) ListAppReleasedGroups(ctx context.Context, req *pbcs.ListAppReleasedGroupsReq) (*pbcs.JsonRawResp, error)
  • func (s *Service) ListApps(ctx context.Context, req *pbcs.ListAppsReq) (*pbcs.ListAppsResp, error)
  • func (s *Service) ListEventsMeta(ctx context.Context, req *pbcs.ListEventsReq) (*pbcs.ListEventsResp, error)
  • func (s *Service) SetClientMetric(ctx context.Context, req *pbcs.SetClientMetricReq) (*pbcs.SetClientMetricResp, error)
  • func (s *Service) SetPublishTime(ctx context.Context, req *pbcs.SetPublishTimeReq) (*pbcs.SetPublishTimeResp, error)

Types

type Service

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

Service do all the cache service's work

func NewService

func NewService(sd serviced.State, daoSet dao.Set, bs bedis.Client, op client.Interface) (*Service, error)

NewService initial the service instance.

func (*Service) BatchUpdateLastConsumedTime

func (s *Service) BatchUpdateLastConsumedTime(ctx context.Context, req *pbcs.BatchUpdateLastConsumedTimeReq) (
	*pbcs.BatchUpdateLastConsumedTimeResp, error)

BatchUpdateLastConsumedTime 批量更新服务拉取时间

func (*Service) BenchAppMeta

func (s *Service) BenchAppMeta(ctx context.Context, req *pbcs.BenchAppMetaReq) (*pbcs.BenchAppMetaResp, error)

BenchAppMeta list app meta info.

func (*Service) BenchReleasedCI

func (s *Service) BenchReleasedCI(ctx context.Context, req *pbcs.BenchReleasedCIReq) (*pbcs.BenchReleasedCIResp,
	error)

BenchReleasedCI list released config item.

func (*Service) GetAppID

func (s *Service) GetAppID(ctx context.Context, req *pbcs.GetAppIDReq) (*pbcs.GetAppIDResp, error)

GetAppID get app id by app name.

func (*Service) GetAppMeta

func (s *Service) GetAppMeta(ctx context.Context, req *pbcs.GetAppMetaReq) (*pbcs.JsonRawResp, error)

GetAppMeta get app's basic info.

func (*Service) GetCredential

func (s *Service) GetCredential(ctx context.Context, req *pbcs.GetCredentialReq) (*pbcs.JsonRawResp, error)

GetCredential get credential by credential string.

func (*Service) GetCurrentCursorReminder

func (s *Service) GetCurrentCursorReminder(ctx context.Context, _ *pbbase.EmptyReq) (*pbcs.CurrentCursorReminderResp,
	error)

GetCurrentCursorReminder get the current consumed event's id, which is the cursor reminder's resource id.

func (*Service) GetReleasedCI

func (s *Service) GetReleasedCI(ctx context.Context, req *pbcs.GetReleasedCIReq) (*pbcs.JsonRawResp, error)

GetReleasedCI get released config items from cache.

func (*Service) GetReleasedHook

func (s *Service) GetReleasedHook(ctx context.Context, req *pbcs.GetReleasedHookReq) (*pbcs.JsonRawResp, error)

GetReleasedHook get released hook from cache.

func (*Service) GetReleasedKv

func (s *Service) GetReleasedKv(ctx context.Context, req *pbcs.GetReleasedKvReq) (*pbcs.JsonRawResp, error)

GetReleasedKv get released kv from cache.

func (*Service) GetReleasedKvValue

func (s *Service) GetReleasedKvValue(ctx context.Context, req *pbcs.GetReleasedKvValueReq) (*pbcs.JsonRawResp, error)

GetReleasedKvValue GetReleasedKv get released kv from local cache.

func (*Service) Handler

func (s *Service) Handler() (http.Handler, error)

Handler return service's handler.

func (*Service) ListAppReleasedGroups

func (s *Service) ListAppReleasedGroups(ctx context.Context, req *pbcs.ListAppReleasedGroupsReq) (
	*pbcs.JsonRawResp, error)

ListAppReleasedGroups list app's released groups.

func (*Service) ListApps

func (s *Service) ListApps(ctx context.Context, req *pbcs.ListAppsReq) (*pbcs.ListAppsResp, error)

ListApps 获取服务列表

func (*Service) ListEventsMeta

func (s *Service) ListEventsMeta(ctx context.Context, req *pbcs.ListEventsReq) (*pbcs.ListEventsResp, error)

ListEventsMeta list event metas with filter

func (*Service) SetClientMetric

func (s *Service) SetClientMetric(ctx context.Context, req *pbcs.SetClientMetricReq) (*pbcs.SetClientMetricResp,
	error)

SetClientMetric set client metric

func (*Service) SetPublishTime

func (s *Service) SetPublishTime(ctx context.Context, req *pbcs.SetPublishTimeReq) (*pbcs.SetPublishTimeResp,
	error)

SetPublishTime set publish time