service

Documentation

Index

• Constants
• Variables
• func CreateInitServerFn(ps *Middle) rpc.InitServer
• type Middle
  • func NewMiddle(conf *config.AppConfig, rdb *redis.Client, repo repository.MiddleRepository, ...) *Middle
  • func (s *Middle) CloseSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Middle) CreateCredential(ctx context.Context, payload *pb.KVsRequest) (*pb.StateReply, error)
  • func (s *Middle) CreatePage(ctx context.Context, payload *pb.PageRequest) (*pb.TextReply, error)
  • func (s *Middle) CreateSetting(ctx context.Context, payload *pb.KVRequest) (*pb.StateReply, error)
  • func (s *Middle) GetApps(ctx context.Context, _ *pb.TextRequest) (*pb.AppsReply, error)
  • func (s *Middle) GetAvailableApp(ctx context.Context, payload *pb.TextRequest) (*pb.AppReply, error)
  • func (s *Middle) GetChartData(ctx context.Context, payload *pb.ChartDataRequest) (*pb.ChartDataReply, error)
  • func (s *Middle) GetChartUrl(_ context.Context, payload *pb.TextRequest) (*pb.TextReply, error)
  • func (s *Middle) GetCredential(ctx context.Context, payload *pb.CredentialRequest) (*pb.CredentialReply, error)
  • func (s *Middle) GetCredentials(ctx context.Context, _ *pb.TextRequest) (*pb.CredentialsReply, error)
  • func (s *Middle) GetCronStatus(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)
  • func (s *Middle) GetMaskingCredentials(ctx context.Context, _ *pb.TextRequest) (*pb.MaskingReply, error)
  • func (s *Middle) GetOrCreateTag(ctx context.Context, payload *pb.TagRequest) (*pb.TagReply, error)
  • func (s *Middle) GetPage(ctx context.Context, payload *pb.PageRequest) (*pb.PageReply, error)
  • func (s *Middle) GetQrUrl(_ context.Context, payload *pb.TextRequest) (*pb.TextReply, error)
  • func (s *Middle) GetSetting(ctx context.Context, payload *pb.TextRequest) (*pb.SettingReply, error)
  • func (s *Middle) GetSettings(ctx context.Context, _ *pb.TextRequest) (*pb.SettingsReply, error)
  • func (s *Middle) GetStats(ctx context.Context, _ *pb.TextRequest) (*pb.TextReply, error)
  • func (s *Middle) GetSubscribeStatus(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Middle) GetTags(ctx context.Context, _ *pb.TagRequest) (*pb.TagsReply, error)
  • func (s *Middle) ListCron(ctx context.Context, _ *pb.CronRequest) (*pb.CronReply, error)
  • func (s *Middle) ListSubscribe(ctx context.Context, _ *pb.SubscribeRequest) (*pb.SubscribeReply, error)
  • func (s *Middle) OpenSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Middle) RegisterCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)
  • func (s *Middle) RegisterSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)
  • func (s *Middle) SetChartData(ctx context.Context, payload *pb.ChartDataRequest) (*pb.ChartDataReply, error)
  • func (s *Middle) StartCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)
  • func (s *Middle) StopCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)
  • func (s *Middle) StoreAppOAuth(ctx context.Context, payload *pb.AppRequest) (*pb.StateReply, error)

Constants

const CronKey = "cron:rule"

const RuleKey = "subscribe:rule"

Variables

var ProviderSet = wire.NewSet(NewMiddle, CreateInitServerFn)

Functions

func CreateInitServerFn

func CreateInitServerFn(ps *Middle) rpc.InitServer

Types

type Middle

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

func NewMiddle

func NewMiddle(conf *config.AppConfig, rdb *redis.Client, repo repository.MiddleRepository, user pb.UserSvcClient) *Middle

func (*Middle) CloseSubscribe

func (s *Middle) CloseSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Middle) CreateCredential

func (s *Middle) CreateCredential(ctx context.Context, payload *pb.KVsRequest) (*pb.StateReply, error)

func (*Middle) CreatePage

func (s *Middle) CreatePage(ctx context.Context, payload *pb.PageRequest) (*pb.TextReply, error)

func (*Middle) CreateSetting

func (s *Middle) CreateSetting(ctx context.Context, payload *pb.KVRequest) (*pb.StateReply, error)

func (*Middle) GetApps

func (s *Middle) GetApps(ctx context.Context, _ *pb.TextRequest) (*pb.AppsReply, error)

func (*Middle) GetAvailableApp

func (s *Middle) GetAvailableApp(ctx context.Context, payload *pb.TextRequest) (*pb.AppReply, error)

func (*Middle) GetChartData

func (s *Middle) GetChartData(ctx context.Context, payload *pb.ChartDataRequest) (*pb.ChartDataReply, error)

func (*Middle) GetChartUrl

func (s *Middle) GetChartUrl(_ context.Context, payload *pb.TextRequest) (*pb.TextReply, error)

func (*Middle) GetCredential

func (s *Middle) GetCredential(ctx context.Context, payload *pb.CredentialRequest) (*pb.CredentialReply, error)

func (*Middle) GetCredentials

func (s *Middle) GetCredentials(ctx context.Context, _ *pb.TextRequest) (*pb.CredentialsReply, error)

func (*Middle) GetCronStatus

func (s *Middle) GetCronStatus(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)

func (*Middle) GetMaskingCredentials

func (s *Middle) GetMaskingCredentials(ctx context.Context, _ *pb.TextRequest) (*pb.MaskingReply, error)

func (*Middle) GetOrCreateTag

func (s *Middle) GetOrCreateTag(ctx context.Context, payload *pb.TagRequest) (*pb.TagReply, error)

func (*Middle) GetPage

func (s *Middle) GetPage(ctx context.Context, payload *pb.PageRequest) (*pb.PageReply, error)

func (*Middle) GetQrUrl

func (s *Middle) GetQrUrl(_ context.Context, payload *pb.TextRequest) (*pb.TextReply, error)

func (*Middle) GetSetting

func (s *Middle) GetSetting(ctx context.Context, payload *pb.TextRequest) (*pb.SettingReply, error)

func (*Middle) GetSettings

func (s *Middle) GetSettings(ctx context.Context, _ *pb.TextRequest) (*pb.SettingsReply, error)

func (*Middle) GetStats

func (s *Middle) GetStats(ctx context.Context, _ *pb.TextRequest) (*pb.TextReply, error)

func (*Middle) GetSubscribeStatus

func (s *Middle) GetSubscribeStatus(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Middle) GetTags

func (s *Middle) GetTags(ctx context.Context, _ *pb.TagRequest) (*pb.TagsReply, error)

func (*Middle) ListCron

func (s *Middle) ListCron(ctx context.Context, _ *pb.CronRequest) (*pb.CronReply, error)

func (*Middle) ListSubscribe

func (s *Middle) ListSubscribe(ctx context.Context, _ *pb.SubscribeRequest) (*pb.SubscribeReply, error)

func (*Middle) OpenSubscribe

func (s *Middle) OpenSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Middle) RegisterCron

func (s *Middle) RegisterCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)

func (*Middle) RegisterSubscribe

func (s *Middle) RegisterSubscribe(ctx context.Context, payload *pb.SubscribeRequest) (*pb.StateReply, error)

func (*Middle) SetChartData

func (s *Middle) SetChartData(ctx context.Context, payload *pb.ChartDataRequest) (*pb.ChartDataReply, error)

func (*Middle) StartCron

func (s *Middle) StartCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)

func (*Middle) StopCron

func (s *Middle) StopCron(ctx context.Context, payload *pb.CronRequest) (*pb.StateReply, error)

func (*Middle) StoreAppOAuth

func (s *Middle) StoreAppOAuth(ctx context.Context, payload *pb.AppRequest) (*pb.StateReply, error)