subscriptions

type ExpiredSubscriptionCb func(*Subscription)

type NewWebsocketCb func(*Subscription) (string, error)

type PeriodicSubscriptionCb func(*Subscription)

type Subscription struct {
	Cfg             *SubscriptionCfg
	JsonSubOrig     string       `json:"jsonSubOrig"`
	Mode            string       `json:"mode"`
	State           string       `json:"state"`
	PeriodicCounter int32        `json:"periodicCounter"`
	TestNotifSent   bool         `json:"testNotifSent"`
	WsCreated       bool         `json:"wsCreated"`
	HttpClient      *http.Client `json:"-"`
	Ws              *ws.Websocket
	WsTransport     *ws.Transport3gppWsNotif `json:"-"`
}

type SubscriptionCfg struct {
	Id                  string     `json:"id"`
	AppId               string     `json:"appId"`
	Type                string     `json:"subType"`
	NotifType           string     `json:"notifType"`
	Self                string     `json:"self"`
	NotifyUrl           string     `json:"notifyUrl"`
	ExpiryTime          *time.Time `json:"expiryTime"`
	PeriodicInterval    int32      `json:"periodicInterval"`
	RequestTestNotif    bool       `json:"reqTestNotif"`
	RequestWebsocketUri bool       `json:"reqWebsockUri"`
}

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

type SubscriptionMgrCfg struct {
	Module         string
	Sandbox        string
	Mep            string
	Service        string
	Basekey        string
	MetricsEnabled bool
	ExpiredSubCb   ExpiredSubscriptionCb
	PeriodicSubCb  PeriodicSubscriptionCb
	TestNotifCb    TestNotificationCb
	NewWsCb        NewWebsocketCb
}

type TestNotificationCb func(*Subscription) error