Documentation
¶
Index ¶
- type SubscriptionManager
- func (_m *SubscriptionManager) AddStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
- func (_m *SubscriptionManager) AddSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*api.SubscriptionInfo, *util.RestError)
- func (_m *SubscriptionManager) Close()
- func (_m *SubscriptionManager) DeleteStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
- func (_m *SubscriptionManager) DeleteSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
- func (_m *SubscriptionManager) Init(mocked ...kvstore.KVStore) error
- func (_m *SubscriptionManager) ResetSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
- func (_m *SubscriptionManager) ResumeStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
- func (_m *SubscriptionManager) StreamByID(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
- func (_m *SubscriptionManager) Streams(res http.ResponseWriter, req *http.Request, params httprouter.Params) []*events.StreamInfo
- func (_m *SubscriptionManager) SubscriptionByID(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*api.SubscriptionInfo, *util.RestError)
- func (_m *SubscriptionManager) Subscriptions(res http.ResponseWriter, req *http.Request, params httprouter.Params) []*api.SubscriptionInfo
- func (_m *SubscriptionManager) SuspendStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
- func (_m *SubscriptionManager) UpdateStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SubscriptionManager ¶
SubscriptionManager is an autogenerated mock type for the SubscriptionManager type
func NewSubscriptionManager ¶ added in v0.9.18
func NewSubscriptionManager(t mockConstructorTestingTNewSubscriptionManager) *SubscriptionManager
NewSubscriptionManager creates a new instance of SubscriptionManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*SubscriptionManager) AddStream ¶
func (_m *SubscriptionManager) AddStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
AddStream provides a mock function with given fields: res, req, params
func (*SubscriptionManager) AddSubscription ¶
func (_m *SubscriptionManager) AddSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*api.SubscriptionInfo, *util.RestError)
AddSubscription provides a mock function with given fields: res, req, params
func (*SubscriptionManager) Close ¶
func (_m *SubscriptionManager) Close()
Close provides a mock function with given fields:
func (*SubscriptionManager) DeleteStream ¶
func (_m *SubscriptionManager) DeleteStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
DeleteStream provides a mock function with given fields: res, req, params
func (*SubscriptionManager) DeleteSubscription ¶
func (_m *SubscriptionManager) DeleteSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
DeleteSubscription provides a mock function with given fields: res, req, params
func (*SubscriptionManager) Init ¶
func (_m *SubscriptionManager) Init(mocked ...kvstore.KVStore) error
Init provides a mock function with given fields: mocked
func (*SubscriptionManager) ResetSubscription ¶
func (_m *SubscriptionManager) ResetSubscription(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
ResetSubscription provides a mock function with given fields: res, req, params
func (*SubscriptionManager) ResumeStream ¶
func (_m *SubscriptionManager) ResumeStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
ResumeStream provides a mock function with given fields: res, req, params
func (*SubscriptionManager) StreamByID ¶
func (_m *SubscriptionManager) StreamByID(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
StreamByID provides a mock function with given fields: res, req, params
func (*SubscriptionManager) Streams ¶
func (_m *SubscriptionManager) Streams(res http.ResponseWriter, req *http.Request, params httprouter.Params) []*events.StreamInfo
Streams provides a mock function with given fields: res, req, params
func (*SubscriptionManager) SubscriptionByID ¶
func (_m *SubscriptionManager) SubscriptionByID(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*api.SubscriptionInfo, *util.RestError)
SubscriptionByID provides a mock function with given fields: res, req, params
func (*SubscriptionManager) Subscriptions ¶
func (_m *SubscriptionManager) Subscriptions(res http.ResponseWriter, req *http.Request, params httprouter.Params) []*api.SubscriptionInfo
Subscriptions provides a mock function with given fields: res, req, params
func (*SubscriptionManager) SuspendStream ¶
func (_m *SubscriptionManager) SuspendStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*map[string]string, *util.RestError)
SuspendStream provides a mock function with given fields: res, req, params
func (*SubscriptionManager) UpdateStream ¶
func (_m *SubscriptionManager) UpdateStream(res http.ResponseWriter, req *http.Request, params httprouter.Params) (*events.StreamInfo, *util.RestError)
UpdateStream provides a mock function with given fields: res, req, params
Source Files