service

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 24, 2021 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const CronKey = "cron:rule"
View Source
const RuleKey = "subscribe:rule"

Variables

Functions

func CreateInitServerFn added in v0.0.24

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 added in v0.1.1

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

func (*Middle) CreateCredential added in v0.0.9

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 added in v0.0.9

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

func (*Middle) GetApps added in v0.0.17

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

func (*Middle) GetAvailableApp added in v0.0.15

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

func (*Middle) GetChartData added in v0.1.1

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

func (*Middle) GetChartUrl added in v0.1.1

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

func (*Middle) GetCredential added in v0.0.15

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

func (*Middle) GetCredentials added in v0.0.9

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

func (*Middle) GetCronStatus added in v0.1.1

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

func (*Middle) GetMaskingCredentials added in v0.0.17

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

func (*Middle) GetOrCreateTag added in v0.1.1

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 added in v0.0.17

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

func (*Middle) GetSetting added in v0.0.9

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

func (*Middle) GetSettings added in v0.0.21

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

func (*Middle) GetStats added in v0.0.22

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

func (*Middle) GetSubscribeStatus added in v0.1.1

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

func (*Middle) GetTags added in v0.1.1

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

func (*Middle) ListCron added in v0.1.1

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

func (*Middle) ListSubscribe added in v0.1.1

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

func (*Middle) OpenSubscribe added in v0.1.1

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

func (*Middle) RegisterCron added in v0.1.1

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

func (*Middle) RegisterSubscribe added in v0.1.1

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

func (*Middle) SetChartData added in v0.1.1

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

func (*Middle) StartCron added in v0.1.1

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

func (*Middle) StopCron added in v0.1.1

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

func (*Middle) StoreAppOAuth added in v0.0.9

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL