Documentation ¶
Index ¶
- Constants
- Variables
- func CheckMessage(req PushNotification) error
- func CheckPushConf() error
- func DispatchFeedback(log LogPushEntry, url string, timeout int64) error
- func GetAndroidNotification(req PushNotification) *fcm.Message
- func GetHuaweiNotification(req PushNotification) (*model.MessageRequest, error)
- func GetIOSNotification(req PushNotification) *apns2.Notification
- func GetPushClient(conf *config.Config) (*core.HMSClient, error)
- func GetVersion() string
- func InitAPNSClient() error
- func InitAppStatus() error
- func InitFCMClient(key string) (*fcm.Client, error)
- func InitHMSClient(appSecret, appID string) (*core.HMSClient, error)
- func InitLog() error
- func InitWorkers(ctx context.Context, wg *sync.WaitGroup, workerNum, queueNum int64)
- func LogPush(status, token string, req PushNotification, errPush error)
- func PrintGoRushVersion()
- func PushToAndroid(req PushNotification)
- func PushToHuawei(req PushNotification) bool
- func PushToIOS(req PushNotification)
- func RunHTTPServer(ctx context.Context, s ...*http.Server) (err error)
- func SendNotification(ctx context.Context, req PushNotification)
- func SetLogLevel(log *logrus.Logger, levelString string) error
- func SetLogOut(log *logrus.Logger, outString string) error
- func SetProxy(proxy string) error
- func SetVersion(ver string)
- func StatMiddleware() gin.HandlerFunc
- func VersionMiddleware() gin.HandlerFunc
- type Alert
- type AndroidStatus
- type D
- type HuaweiStatus
- type IosStatus
- type LogPushEntry
- type Metrics
- type PushNotification
- type RequestPush
- type Sound
- type StatusApp
Constants ¶
const ( // PlatFormIos constant is 1 for iOS PlatFormIos = iota + 1 // PlatFormAndroid constant is 2 for Android PlatFormAndroid // PlatFormHuawei constant is 3 for Huawei PlatFormHuawei )
const ( // SucceededPush is log block SucceededPush = "succeeded-push" // FailedPush is log block FailedPush = "failed-push" )
const ( TotalCountKey = "gorush-total-count" IosSuccessKey = "gorush-ios-success-count" IosErrorKey = "gorush-ios-error-count" AndroidSuccessKey = "gorush-android-success-count" AndroidErrorKey = "gorush-android-error-count" HuaweiSuccessKey = "gorush-huawei-success-count" HuaweiErrorKey = "gorush-huawei-error-count" )
Stat variable for redis
const ( // ApnsPriorityLow will tell APNs to send the push message at a time that takes // into account power considerations for the device. Notifications with this // priority might be grouped and delivered in bursts. They are throttled, and // in some cases are not delivered. ApnsPriorityLow = 5 // ApnsPriorityHigh will tell APNs to send the push message immediately. // Notifications with this priority must trigger an alert, sound, or badge on // the target device. It is an error to use this priority for a push // notification that contains only the content-available key. ApnsPriorityHigh = 10 )
Variables ¶
var ( // PushConf is gorush config PushConf config.ConfYaml // QueueNotification is chan type QueueNotification chan PushNotification // ApnsClient is apns client ApnsClient *apns2.Client // FCMClient is apns client FCMClient *fcm.Client // HMSClient is Huawei push client HMSClient *core.HMSClient // LogAccess is log server request log LogAccess *logrus.Logger // LogError is log server error log LogError *logrus.Logger // StatStorage implements the storage interface StatStorage storage.Storage // MaxConcurrentIOSPushes pool to limit the number of concurrent iOS pushes MaxConcurrentIOSPushes chan struct{} )
var DialTLS = func(cfg *tls.Config) func(network, addr string) (net.Conn, error) { return func(network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: tlsDialTimeout, KeepAlive: tcpKeepAlive, } return tls.DialWithDialer(dialer, network, addr, cfg) } }
DialTLS is the default dial function for creating TLS connections for non-proxied HTTPS requests.
var Stats = stats.New()
Stats provide response time, status code count, etc.
Functions ¶
func CheckMessage ¶
func CheckMessage(req PushNotification) error
CheckMessage for check request message
func DispatchFeedback ¶ added in v1.11.2
func DispatchFeedback(log LogPushEntry, url string, timeout int64) error
DispatchFeedback sends a feedback to the configured gateway.
func GetAndroidNotification ¶
func GetAndroidNotification(req PushNotification) *fcm.Message
GetAndroidNotification use for define Android notification. HTTP Connection Server Reference for Android https://firebase.google.com/docs/cloud-messaging/http-server-ref
func GetHuaweiNotification ¶ added in v1.14.0
func GetHuaweiNotification(req PushNotification) (*model.MessageRequest, error)
GetHuaweiNotification use for define HMS notification. HTTP Connection Server Reference for HMS https://developer.huawei.com/consumer/en/doc/development/HMS-References/push-sendapi
func GetIOSNotification ¶
func GetIOSNotification(req PushNotification) *apns2.Notification
GetIOSNotification use for define iOS notification. The iOS Notification Payload ref: https://developer.apple.com/library/content/documentation/NetworkingInternet/Conceptual/RemoteNotificationsPG/PayloadKeyReference.html#//apple_ref/doc/uid/TP40008194-CH17-SW1
func GetPushClient ¶ added in v1.14.0
GetPushClient use for create HMS Push
func InitFCMClient ¶ added in v1.11.1
InitFCMClient use for initialize FCM Client.
func InitHMSClient ¶ added in v1.14.0
InitHMSClient use for initialize HMS Client.
func InitWorkers ¶
InitWorkers for initialize all workers.
func LogPush ¶
func LogPush(status, token string, req PushNotification, errPush error)
LogPush record user push request and server response.
func PushToAndroid ¶
func PushToAndroid(req PushNotification)
PushToAndroid provide send notification to Android server.
func PushToHuawei ¶ added in v1.14.0
func PushToHuawei(req PushNotification) bool
PushToHuawei provide send notification to Android server.
func PushToIOS ¶
func PushToIOS(req PushNotification)
PushToIOS provide send notification to APNs server.
func RunHTTPServer ¶
RunHTTPServer provide run http or https protocol.
func SendNotification ¶ added in v1.11.1
func SendNotification(ctx context.Context, req PushNotification)
SendNotification is send message to iOS, Android or Huawei
func SetLogLevel ¶
SetLogLevel is define log level what you want log level: panic, fatal, error, warn, info and debug
func StatMiddleware ¶
func StatMiddleware() gin.HandlerFunc
StatMiddleware response time, status code count, etc.
func VersionMiddleware ¶
func VersionMiddleware() gin.HandlerFunc
VersionMiddleware : add version on header.
Types ¶
type Alert ¶
type Alert struct { Action string `json:"action,omitempty"` ActionLocKey string `json:"action-loc-key,omitempty"` Body string `json:"body,omitempty"` LaunchImage string `json:"launch-image,omitempty"` LocArgs []string `json:"loc-args,omitempty"` LocKey string `json:"loc-key,omitempty"` Title string `json:"title,omitempty"` Subtitle string `json:"subtitle,omitempty"` TitleLocArgs []string `json:"title-loc-args,omitempty"` TitleLocKey string `json:"title-loc-key,omitempty"` SummaryArg string `json:"summary-arg,omitempty"` SummaryArgCount int `json:"summary-arg-count,omitempty"` }
Alert is APNs payload
type AndroidStatus ¶
type AndroidStatus struct { PushSuccess int64 `json:"push_success"` PushError int64 `json:"push_error"` }
AndroidStatus is android structure
type HuaweiStatus ¶ added in v1.14.0
type HuaweiStatus struct { PushSuccess int64 `json:"push_success"` PushError int64 `json:"push_error"` }
HuaweiStatus is huawei structure
type IosStatus ¶
type IosStatus struct { PushSuccess int64 `json:"push_success"` PushError int64 `json:"push_error"` }
IosStatus is iOS structure
type LogPushEntry ¶
type LogPushEntry struct { ID string `json:"notif_id,omitempty"` Type string `json:"type"` Platform string `json:"platform"` Token string `json:"token"` Message string `json:"message"` Error string `json:"error"` }
LogPushEntry is push response log
type Metrics ¶ added in v1.7.4
type Metrics struct { TotalPushCount *prometheus.Desc IosSuccess *prometheus.Desc IosError *prometheus.Desc AndroidSuccess *prometheus.Desc AndroidError *prometheus.Desc HuaweiSuccess *prometheus.Desc HuaweiError *prometheus.Desc QueueUsage *prometheus.Desc }
Metrics implements the prometheus.Metrics interface and exposes gorush metrics for prometheus
func NewMetrics ¶ added in v1.7.4
func NewMetrics() Metrics
NewMetrics returns a new Metrics with all prometheus.Desc initialized
func (Metrics) Collect ¶ added in v1.7.4
func (c Metrics) Collect(ch chan<- prometheus.Metric)
Collect returns the metrics with values
func (Metrics) Describe ¶ added in v1.7.4
func (c Metrics) Describe(ch chan<- *prometheus.Desc)
Describe returns all possible prometheus.Desc
type PushNotification ¶
type PushNotification struct { // Common ID string `json:"notif_id,omitempty"` Tokens []string `json:"tokens" binding:"required"` Platform int `json:"platform" binding:"required"` Message string `json:"message,omitempty"` Title string `json:"title,omitempty"` Image string `json:"image,omitempty"` Priority string `json:"priority,omitempty"` ContentAvailable bool `json:"content_available,omitempty"` MutableContent bool `json:"mutable_content,omitempty"` Sound interface{} `json:"sound,omitempty"` Data D `json:"data,omitempty"` Retry int `json:"retry,omitempty"` // Android APIKey string `json:"api_key,omitempty"` To string `json:"to,omitempty"` CollapseKey string `json:"collapse_key,omitempty"` DelayWhileIdle bool `json:"delay_while_idle,omitempty"` TimeToLive *uint `json:"time_to_live,omitempty"` RestrictedPackageName string `json:"restricted_package_name,omitempty"` DryRun bool `json:"dry_run,omitempty"` Condition string `json:"condition,omitempty"` Notification *fcm.Notification `json:"notification,omitempty"` // Huawei AppID string `json:"app_id,omitempty"` AppSecret string `json:"app_secret,omitempty"` HuaweiNotification *model.AndroidNotification `json:"huawei_notification,omitempty"` HuaweiData string `json:"huawei_data,omitempty"` HuaweiCollapseKey int `json:"huawei_collapse_key,omitempty"` HuaweiTTL string `json:"huawei_ttl,omitempty"` BiTag string `json:"bi_tag,omitempty"` FastAppTarget int `json:"fast_app_target,omitempty"` // iOS Expiration *int64 `json:"expiration,omitempty"` ApnsID string `json:"apns_id,omitempty"` CollapseID string `json:"collapse_id,omitempty"` Topic string `json:"topic,omitempty"` PushType string `json:"push_type,omitempty"` Badge *int `json:"badge,omitempty"` Category string `json:"category,omitempty"` ThreadID string `json:"thread-id,omitempty"` URLArgs []string `json:"url-args,omitempty"` Alert Alert `json:"alert,omitempty"` Production bool `json:"production,omitempty"` Development bool `json:"development,omitempty"` SoundName string `json:"name,omitempty"` SoundVolume float32 `json:"volume,omitempty"` Apns D `json:"apns,omitempty"` // contains filtered or unexported fields }
PushNotification is single notification request
func (*PushNotification) AddLog ¶ added in v1.8.1
func (p *PushNotification) AddLog(log LogPushEntry)
AddLog record fail log of notification
func (*PushNotification) AddWaitCount ¶ added in v1.8.1
func (p *PushNotification) AddWaitCount()
AddWaitCount increments the WaitGroup counter.
func (*PushNotification) IsTopic ¶ added in v1.11.1
func (p *PushNotification) IsTopic() bool
IsTopic check if message format is topic for FCM ref: https://firebase.google.com/docs/cloud-messaging/send-message#topic-http-post-request
func (*PushNotification) WaitDone ¶ added in v1.8.1
func (p *PushNotification) WaitDone()
WaitDone decrements the WaitGroup counter.
type RequestPush ¶
type RequestPush struct {
Notifications []PushNotification `json:"notifications" binding:"required"`
}
RequestPush support multiple notification request.
type Sound ¶ added in v1.11.1
type Sound struct { Critical int `json:"critical,omitempty"` Name string `json:"name,omitempty"` Volume float32 `json:"volume,omitempty"` }
Sound sets the aps sound on the payload.
type StatusApp ¶
type StatusApp struct { Version string `json:"version"` QueueMax int `json:"queue_max"` QueueUsage int `json:"queue_usage"` TotalCount int64 `json:"total_count"` Ios IosStatus `json:"ios"` Android AndroidStatus `json:"android"` Huawei HuaweiStatus `json:"huawei"` }
StatusApp is app status structure