api

package
v0.0.0-...-9835270 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type InternalMsgConsumer 

type InternalMsgConsumer struct {
	apiconsumer.APIConsumer
	// contains filtered or unexported fields
}

func NewInternalMsgConsumer 

func NewInternalMsgConsumer(
	cfg config.Dendrite,
	pushDB model.PushAPIDatabase,
	redisCache service.Cache,
	rpcCli *common.RpcClient,
) *InternalMsgConsumer

func (*InternalMsgConsumer) Start 

func (c *InternalMsgConsumer) Start()

type ReqDelPushRuleByID 

type ReqDelPushRuleByID struct{}

func (ReqDelPushRuleByID) FillRequest 

func (ReqDelPushRuleByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqDelPushRuleByID) GetAPIType 

func (ReqDelPushRuleByID) GetAPIType() int8

func (ReqDelPushRuleByID) GetMethod 

func (ReqDelPushRuleByID) GetMethod() []string

func (ReqDelPushRuleByID) GetMetricsName 

func (ReqDelPushRuleByID) GetMetricsName() string

func (ReqDelPushRuleByID) GetMsgType 

func (ReqDelPushRuleByID) GetMsgType() int32

func (ReqDelPushRuleByID) GetPrefix 

func (ReqDelPushRuleByID) GetPrefix() []string

func (ReqDelPushRuleByID) GetRoute 

func (ReqDelPushRuleByID) GetRoute() string

func (ReqDelPushRuleByID) GetTopic 

func (ReqDelPushRuleByID) GetTopic(cfg *config.Dendrite) string

func (ReqDelPushRuleByID) NewRequest 

func (ReqDelPushRuleByID) NewRequest() core.Coder

func (ReqDelPushRuleByID) NewResponse 

func (ReqDelPushRuleByID) NewResponse(code int) core.Coder

func (ReqDelPushRuleByID) Process 

func (ReqDelPushRuleByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushRuleActionsByID 

type ReqGetPushRuleActionsByID struct{}

func (ReqGetPushRuleActionsByID) FillRequest 

func (ReqGetPushRuleActionsByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushRuleActionsByID) GetAPIType 

func (ReqGetPushRuleActionsByID) GetAPIType() int8

func (ReqGetPushRuleActionsByID) GetMethod 

func (ReqGetPushRuleActionsByID) GetMethod() []string

func (ReqGetPushRuleActionsByID) GetMetricsName 

func (ReqGetPushRuleActionsByID) GetMetricsName() string

func (ReqGetPushRuleActionsByID) GetMsgType 

func (ReqGetPushRuleActionsByID) GetMsgType() int32

func (ReqGetPushRuleActionsByID) GetPrefix 

func (ReqGetPushRuleActionsByID) GetPrefix() []string

func (ReqGetPushRuleActionsByID) GetRoute 

func (ReqGetPushRuleActionsByID) GetRoute() string

func (ReqGetPushRuleActionsByID) GetTopic 

func (ReqGetPushRuleActionsByID) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushRuleActionsByID) NewRequest 

func (ReqGetPushRuleActionsByID) NewRequest() core.Coder

func (ReqGetPushRuleActionsByID) NewResponse 

func (ReqGetPushRuleActionsByID) NewResponse(code int) core.Coder

func (ReqGetPushRuleActionsByID) Process 

func (ReqGetPushRuleActionsByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushRuleByID 

type ReqGetPushRuleByID struct{}

func (ReqGetPushRuleByID) FillRequest 

func (ReqGetPushRuleByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushRuleByID) GetAPIType 

func (ReqGetPushRuleByID) GetAPIType() int8

func (ReqGetPushRuleByID) GetMethod 

func (ReqGetPushRuleByID) GetMethod() []string

func (ReqGetPushRuleByID) GetMetricsName 

func (ReqGetPushRuleByID) GetMetricsName() string

func (ReqGetPushRuleByID) GetMsgType 

func (ReqGetPushRuleByID) GetMsgType() int32

func (ReqGetPushRuleByID) GetPrefix 

func (ReqGetPushRuleByID) GetPrefix() []string

func (ReqGetPushRuleByID) GetRoute 

func (ReqGetPushRuleByID) GetRoute() string

func (ReqGetPushRuleByID) GetTopic 

func (ReqGetPushRuleByID) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushRuleByID) NewRequest 

func (ReqGetPushRuleByID) NewRequest() core.Coder

func (ReqGetPushRuleByID) NewResponse 

func (ReqGetPushRuleByID) NewResponse(code int) core.Coder

func (ReqGetPushRuleByID) Process 

func (ReqGetPushRuleByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushRules 

type ReqGetPushRules struct{}

func (ReqGetPushRules) FillRequest 

func (ReqGetPushRules) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushRules) GetAPIType 

func (ReqGetPushRules) GetAPIType() int8

func (ReqGetPushRules) GetMethod 

func (ReqGetPushRules) GetMethod() []string

func (ReqGetPushRules) GetMetricsName 

func (ReqGetPushRules) GetMetricsName() string

func (ReqGetPushRules) GetMsgType 

func (ReqGetPushRules) GetMsgType() int32

func (ReqGetPushRules) GetPrefix 

func (ReqGetPushRules) GetPrefix() []string

func (ReqGetPushRules) GetRoute 

func (ReqGetPushRules) GetRoute() string

func (ReqGetPushRules) GetTopic 

func (ReqGetPushRules) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushRules) NewRequest 

func (ReqGetPushRules) NewRequest() core.Coder

func (ReqGetPushRules) NewResponse 

func (ReqGetPushRules) NewResponse(code int) core.Coder

func (ReqGetPushRules) Process 

func (ReqGetPushRules) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushRulesEnabledByID 

type ReqGetPushRulesEnabledByID struct{}

func (ReqGetPushRulesEnabledByID) FillRequest 

func (ReqGetPushRulesEnabledByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushRulesEnabledByID) GetAPIType 

func (ReqGetPushRulesEnabledByID) GetAPIType() int8

func (ReqGetPushRulesEnabledByID) GetMethod 

func (ReqGetPushRulesEnabledByID) GetMethod() []string

func (ReqGetPushRulesEnabledByID) GetMetricsName 

func (ReqGetPushRulesEnabledByID) GetMetricsName() string

func (ReqGetPushRulesEnabledByID) GetMsgType 

func (ReqGetPushRulesEnabledByID) GetMsgType() int32

func (ReqGetPushRulesEnabledByID) GetPrefix 

func (ReqGetPushRulesEnabledByID) GetPrefix() []string

func (ReqGetPushRulesEnabledByID) GetRoute 

func (ReqGetPushRulesEnabledByID) GetRoute() string

func (ReqGetPushRulesEnabledByID) GetTopic 

func (ReqGetPushRulesEnabledByID) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushRulesEnabledByID) NewRequest 

func (ReqGetPushRulesEnabledByID) NewRequest() core.Coder

func (ReqGetPushRulesEnabledByID) NewResponse 

func (ReqGetPushRulesEnabledByID) NewResponse(code int) core.Coder

func (ReqGetPushRulesEnabledByID) Process 

func (ReqGetPushRulesEnabledByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushRulesGlobal 

type ReqGetPushRulesGlobal struct{}

func (ReqGetPushRulesGlobal) FillRequest 

func (ReqGetPushRulesGlobal) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushRulesGlobal) GetAPIType 

func (ReqGetPushRulesGlobal) GetAPIType() int8

func (ReqGetPushRulesGlobal) GetMethod 

func (ReqGetPushRulesGlobal) GetMethod() []string

func (ReqGetPushRulesGlobal) GetMetricsName 

func (ReqGetPushRulesGlobal) GetMetricsName() string

func (ReqGetPushRulesGlobal) GetMsgType 

func (ReqGetPushRulesGlobal) GetMsgType() int32

func (ReqGetPushRulesGlobal) GetPrefix 

func (ReqGetPushRulesGlobal) GetPrefix() []string

func (ReqGetPushRulesGlobal) GetRoute 

func (ReqGetPushRulesGlobal) GetRoute() string

func (ReqGetPushRulesGlobal) GetTopic 

func (ReqGetPushRulesGlobal) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushRulesGlobal) NewRequest 

func (ReqGetPushRulesGlobal) NewRequest() core.Coder

func (ReqGetPushRulesGlobal) NewResponse 

func (ReqGetPushRulesGlobal) NewResponse(code int) core.Coder

func (ReqGetPushRulesGlobal) Process 

func (ReqGetPushRulesGlobal) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetPushers 

type ReqGetPushers struct{}

func (ReqGetPushers) FillRequest 

func (ReqGetPushers) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetPushers) GetAPIType 

func (ReqGetPushers) GetAPIType() int8

func (ReqGetPushers) GetMethod 

func (ReqGetPushers) GetMethod() []string

func (ReqGetPushers) GetMetricsName 

func (ReqGetPushers) GetMetricsName() string

func (ReqGetPushers) GetMsgType 

func (ReqGetPushers) GetMsgType() int32

func (ReqGetPushers) GetPrefix 

func (ReqGetPushers) GetPrefix() []string

func (ReqGetPushers) GetRoute 

func (ReqGetPushers) GetRoute() string

func (ReqGetPushers) GetTopic 

func (ReqGetPushers) GetTopic(cfg *config.Dendrite) string

func (ReqGetPushers) NewRequest 

func (ReqGetPushers) NewRequest() core.Coder

func (ReqGetPushers) NewResponse 

func (ReqGetPushers) NewResponse(code int) core.Coder

func (ReqGetPushers) Process 

func (ReqGetPushers) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPostSetPushers 

type ReqPostSetPushers struct{}

func (ReqPostSetPushers) FillRequest 

func (ReqPostSetPushers) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPostSetPushers) GetAPIType 

func (ReqPostSetPushers) GetAPIType() int8

func (ReqPostSetPushers) GetMethod 

func (ReqPostSetPushers) GetMethod() []string

func (ReqPostSetPushers) GetMetricsName 

func (ReqPostSetPushers) GetMetricsName() string

func (ReqPostSetPushers) GetMsgType 

func (ReqPostSetPushers) GetMsgType() int32

func (ReqPostSetPushers) GetPrefix 

func (ReqPostSetPushers) GetPrefix() []string

func (ReqPostSetPushers) GetRoute 

func (ReqPostSetPushers) GetRoute() string

func (ReqPostSetPushers) GetTopic 

func (ReqPostSetPushers) GetTopic(cfg *config.Dendrite) string

func (ReqPostSetPushers) NewRequest 

func (ReqPostSetPushers) NewRequest() core.Coder

func (ReqPostSetPushers) NewResponse 

func (ReqPostSetPushers) NewResponse(code int) core.Coder

func (ReqPostSetPushers) Process 

func (ReqPostSetPushers) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPostUsersPushKey 

type ReqPostUsersPushKey struct{}

func (ReqPostUsersPushKey) FillRequest 

func (ReqPostUsersPushKey) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPostUsersPushKey) GetAPIType 

func (ReqPostUsersPushKey) GetAPIType() int8

func (ReqPostUsersPushKey) GetMethod 

func (ReqPostUsersPushKey) GetMethod() []string

func (ReqPostUsersPushKey) GetMetricsName 

func (ReqPostUsersPushKey) GetMetricsName() string

func (ReqPostUsersPushKey) GetMsgType 

func (ReqPostUsersPushKey) GetMsgType() int32

func (ReqPostUsersPushKey) GetPrefix 

func (ReqPostUsersPushKey) GetPrefix() []string

func (ReqPostUsersPushKey) GetRoute 

func (ReqPostUsersPushKey) GetRoute() string

func (ReqPostUsersPushKey) GetTopic 

func (ReqPostUsersPushKey) GetTopic(cfg *config.Dendrite) string

func (ReqPostUsersPushKey) NewRequest 

func (ReqPostUsersPushKey) NewRequest() core.Coder

func (ReqPostUsersPushKey) NewResponse 

func (ReqPostUsersPushKey) NewResponse(code int) core.Coder

func (ReqPostUsersPushKey) Process 

func (ReqPostUsersPushKey) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPutPushRuleByID 

type ReqPutPushRuleByID struct{}

func (ReqPutPushRuleByID) FillRequest 

func (ReqPutPushRuleByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPutPushRuleByID) GetAPIType 

func (ReqPutPushRuleByID) GetAPIType() int8

func (ReqPutPushRuleByID) GetMethod 

func (ReqPutPushRuleByID) GetMethod() []string

func (ReqPutPushRuleByID) GetMetricsName 

func (ReqPutPushRuleByID) GetMetricsName() string

func (ReqPutPushRuleByID) GetMsgType 

func (ReqPutPushRuleByID) GetMsgType() int32

func (ReqPutPushRuleByID) GetPrefix 

func (ReqPutPushRuleByID) GetPrefix() []string

func (ReqPutPushRuleByID) GetRoute 

func (ReqPutPushRuleByID) GetRoute() string

func (ReqPutPushRuleByID) GetTopic 

func (ReqPutPushRuleByID) GetTopic(cfg *config.Dendrite) string

func (ReqPutPushRuleByID) NewRequest 

func (ReqPutPushRuleByID) NewRequest() core.Coder

func (ReqPutPushRuleByID) NewResponse 

func (ReqPutPushRuleByID) NewResponse(code int) core.Coder

func (ReqPutPushRuleByID) Process 

func (ReqPutPushRuleByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPutPushRulesActionsByID 

type ReqPutPushRulesActionsByID struct{}

func (ReqPutPushRulesActionsByID) FillRequest 

func (ReqPutPushRulesActionsByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPutPushRulesActionsByID) GetAPIType 

func (ReqPutPushRulesActionsByID) GetAPIType() int8

func (ReqPutPushRulesActionsByID) GetMethod 

func (ReqPutPushRulesActionsByID) GetMethod() []string

func (ReqPutPushRulesActionsByID) GetMetricsName 

func (ReqPutPushRulesActionsByID) GetMetricsName() string

func (ReqPutPushRulesActionsByID) GetMsgType 

func (ReqPutPushRulesActionsByID) GetMsgType() int32

func (ReqPutPushRulesActionsByID) GetPrefix 

func (ReqPutPushRulesActionsByID) GetPrefix() []string

func (ReqPutPushRulesActionsByID) GetRoute 

func (ReqPutPushRulesActionsByID) GetRoute() string

func (ReqPutPushRulesActionsByID) GetTopic 

func (ReqPutPushRulesActionsByID) GetTopic(cfg *config.Dendrite) string

func (ReqPutPushRulesActionsByID) NewRequest 

func (ReqPutPushRulesActionsByID) NewRequest() core.Coder

func (ReqPutPushRulesActionsByID) NewResponse 

func (ReqPutPushRulesActionsByID) NewResponse(code int) core.Coder

func (ReqPutPushRulesActionsByID) Process 

func (ReqPutPushRulesActionsByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPutPushRulesEnabledByID 

type ReqPutPushRulesEnabledByID struct{}

func (ReqPutPushRulesEnabledByID) FillRequest 

func (ReqPutPushRulesEnabledByID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPutPushRulesEnabledByID) GetAPIType 

func (ReqPutPushRulesEnabledByID) GetAPIType() int8

func (ReqPutPushRulesEnabledByID) GetMethod 

func (ReqPutPushRulesEnabledByID) GetMethod() []string

func (ReqPutPushRulesEnabledByID) GetMetricsName 

func (ReqPutPushRulesEnabledByID) GetMetricsName() string

func (ReqPutPushRulesEnabledByID) GetMsgType 

func (ReqPutPushRulesEnabledByID) GetMsgType() int32

func (ReqPutPushRulesEnabledByID) GetPrefix 

func (ReqPutPushRulesEnabledByID) GetPrefix() []string

func (ReqPutPushRulesEnabledByID) GetRoute 

func (ReqPutPushRulesEnabledByID) GetRoute() string

func (ReqPutPushRulesEnabledByID) GetTopic 

func (ReqPutPushRulesEnabledByID) GetTopic(cfg *config.Dendrite) string

func (ReqPutPushRulesEnabledByID) NewRequest 

func (ReqPutPushRulesEnabledByID) NewRequest() core.Coder

func (ReqPutPushRulesEnabledByID) NewResponse 

func (ReqPutPushRulesEnabledByID) NewResponse(code int) core.Coder

func (ReqPutPushRulesEnabledByID) Process 

func (ReqPutPushRulesEnabledByID) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.