Documentation ¶
Index ¶
- Constants
- func MakeConfig(t *testing.T) service.Config
- func New(t *testing.T, getHandler service.GetServiceHandler, ...) func()
- type CustomHandler
- func (h *CustomHandler) CloseOnError() bool
- func (h *CustomHandler) PublishResources(req ocfCloud.PublishResourcesRequest) error
- func (h *CustomHandler) RefreshToken(req ocfCloud.CoapRefreshTokenRequest) (ocfCloud.CoapRefreshTokenResponse, error)
- func (h *CustomHandler) SetPublishResources(f PublishResourcesFunc)
- func (h *CustomHandler) SetRefreshToken(f RefreshTokenFunc)
- func (h *CustomHandler) SetSignIn(f SignInFunc)
- func (h *CustomHandler) SetSignOff(f SignOffFunc)
- func (h *CustomHandler) SetSignOut(f SignOutFunc)
- func (h *CustomHandler) SetSignUp(f SignUpFunc)
- func (h *CustomHandler) SetUnpublishResources(f UnpublishResourcesFunc)
- func (h *CustomHandler) SignIn(req ocfCloud.CoapSignInRequest) (ocfCloud.CoapSignInResponse, error)
- func (h *CustomHandler) SignOff() error
- func (h *CustomHandler) SignOut(req ocfCloud.CoapSignInRequest) error
- func (h *CustomHandler) SignUp(req ocfCloud.CoapSignUpRequest) (ocfCloud.CoapSignUpResponse, error)
- func (h *CustomHandler) UnpublishResources(req ocfCloud.UnpublishResourcesRequest) error
- type DefaultHandler
- func (h *DefaultHandler) CloseOnError() bool
- func (h *DefaultHandler) GetDeviceID() string
- func (h *DefaultHandler) PublishResources(req cloud.PublishResourcesRequest) error
- func (h *DefaultHandler) RefreshToken(req cloud.CoapRefreshTokenRequest) (cloud.CoapRefreshTokenResponse, error)
- func (h *DefaultHandler) SetAccessToken(accessToken string)
- func (h *DefaultHandler) SetDeviceID(deviceID string)
- func (h *DefaultHandler) SetRefreshToken(refreshToken string)
- func (h *DefaultHandler) SignIn(req cloud.CoapSignInRequest) (cloud.CoapSignInResponse, error)
- func (h *DefaultHandler) SignOff() error
- func (h *DefaultHandler) SignOut(req cloud.CoapSignInRequest) error
- func (h *DefaultHandler) SignUp(req cloud.CoapSignUpRequest) (cloud.CoapSignUpResponse, error)
- func (h *DefaultHandler) UnpublishResources(req cloud.UnpublishResourcesRequest) error
- type DefaultHandlerWithCounter
- func (ch *DefaultHandlerWithCounter) PublishResources(req cloud.PublishResourcesRequest) error
- func (ch *DefaultHandlerWithCounter) RefreshToken(req cloud.CoapRefreshTokenRequest) (cloud.CoapRefreshTokenResponse, error)
- func (ch *DefaultHandlerWithCounter) SignIn(req cloud.CoapSignInRequest) (cloud.CoapSignInResponse, error)
- func (ch *DefaultHandlerWithCounter) SignOff() error
- func (ch *DefaultHandlerWithCounter) SignOut(req cloud.CoapSignInRequest) error
- func (ch *DefaultHandlerWithCounter) SignUp(req cloud.CoapSignUpRequest) (cloud.CoapSignUpResponse, error)
- func (ch *DefaultHandlerWithCounter) UnpublishResources(req cloud.UnpublishResourcesRequest) error
- func (ch *DefaultHandlerWithCounter) WaitForPublish(timeout time.Duration) int
- func (ch *DefaultHandlerWithCounter) WaitForSignIn(timeout time.Duration) int
- func (ch *DefaultHandlerWithCounter) WaitForSignOff(timeout time.Duration) int
- func (ch *DefaultHandlerWithCounter) WaitForUnpublish(timeout time.Duration) int
- type PublishResourcesFunc
- type RefreshTokenFunc
- type ServiceHandler
- type SignInFunc
- type SignOffFunc
- type SignOutFunc
- type SignUpFunc
- type UnpublishResourcesFunc
Constants ¶
View Source
const ( SignUpKey = "SignUp" // register SignOffKey = "SignOff" // deregister SignInKey = "SignIn" // log in SignOutKey = "SignOut" // log out PublishKey = "Publish" UnpublishKey = "Unpublish" RefreshTokenKey = "RefreshToken" )
View Source
const (
COAP_GW_HOST = "localhost:21002"
)
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(t *testing.T, getHandler service.GetServiceHandler, onShutdown service.OnShutdown) func()
Types ¶
type CustomHandler ¶ added in v2.4.3
type CustomHandler struct {
// contains filtered or unexported fields
}
func NewCustomHandler ¶ added in v2.4.3
func NewCustomHandler(s ServiceHandler) *CustomHandler
func (*CustomHandler) CloseOnError ¶ added in v2.4.3
func (h *CustomHandler) CloseOnError() bool
func (*CustomHandler) PublishResources ¶ added in v2.4.3
func (h *CustomHandler) PublishResources(req ocfCloud.PublishResourcesRequest) error
func (*CustomHandler) RefreshToken ¶ added in v2.4.3
func (h *CustomHandler) RefreshToken(req ocfCloud.CoapRefreshTokenRequest) (ocfCloud.CoapRefreshTokenResponse, error)
func (*CustomHandler) SetPublishResources ¶ added in v2.4.3
func (h *CustomHandler) SetPublishResources(f PublishResourcesFunc)
func (*CustomHandler) SetRefreshToken ¶ added in v2.4.3
func (h *CustomHandler) SetRefreshToken(f RefreshTokenFunc)
func (*CustomHandler) SetSignIn ¶ added in v2.4.3
func (h *CustomHandler) SetSignIn(f SignInFunc)
func (*CustomHandler) SetSignOff ¶ added in v2.4.3
func (h *CustomHandler) SetSignOff(f SignOffFunc)
func (*CustomHandler) SetSignOut ¶ added in v2.4.3
func (h *CustomHandler) SetSignOut(f SignOutFunc)
func (*CustomHandler) SetSignUp ¶ added in v2.4.3
func (h *CustomHandler) SetSignUp(f SignUpFunc)
func (*CustomHandler) SetUnpublishResources ¶ added in v2.4.3
func (h *CustomHandler) SetUnpublishResources(f UnpublishResourcesFunc)
func (*CustomHandler) SignIn ¶ added in v2.4.3
func (h *CustomHandler) SignIn(req ocfCloud.CoapSignInRequest) (ocfCloud.CoapSignInResponse, error)
func (*CustomHandler) SignOff ¶ added in v2.4.3
func (h *CustomHandler) SignOff() error
func (*CustomHandler) SignOut ¶ added in v2.4.3
func (h *CustomHandler) SignOut(req ocfCloud.CoapSignInRequest) error
func (*CustomHandler) SignUp ¶ added in v2.4.3
func (h *CustomHandler) SignUp(req ocfCloud.CoapSignUpRequest) (ocfCloud.CoapSignUpResponse, error)
func (*CustomHandler) UnpublishResources ¶ added in v2.4.3
func (h *CustomHandler) UnpublishResources(req ocfCloud.UnpublishResourcesRequest) error
type DefaultHandler ¶
type DefaultHandler struct {
// contains filtered or unexported fields
}
DefaultHandler is the default handler for tests
It implements ServiceHandler interface by just logging the called method and returning default response and no error (if required).
func MakeDefaultHandler ¶
func MakeDefaultHandler(accessTokenLifetime int64) DefaultHandler
func (*DefaultHandler) CloseOnError ¶
func (h *DefaultHandler) CloseOnError() bool
func (*DefaultHandler) GetDeviceID ¶
func (h *DefaultHandler) GetDeviceID() string
func (*DefaultHandler) PublishResources ¶
func (h *DefaultHandler) PublishResources(req cloud.PublishResourcesRequest) error
func (*DefaultHandler) RefreshToken ¶
func (h *DefaultHandler) RefreshToken(req cloud.CoapRefreshTokenRequest) (cloud.CoapRefreshTokenResponse, error)
func (*DefaultHandler) SetAccessToken ¶
func (h *DefaultHandler) SetAccessToken(accessToken string)
func (*DefaultHandler) SetDeviceID ¶
func (h *DefaultHandler) SetDeviceID(deviceID string)
func (*DefaultHandler) SetRefreshToken ¶
func (h *DefaultHandler) SetRefreshToken(refreshToken string)
func (*DefaultHandler) SignIn ¶
func (h *DefaultHandler) SignIn(req cloud.CoapSignInRequest) (cloud.CoapSignInResponse, error)
func (*DefaultHandler) SignOff ¶
func (h *DefaultHandler) SignOff() error
func (*DefaultHandler) SignOut ¶
func (h *DefaultHandler) SignOut(req cloud.CoapSignInRequest) error
func (*DefaultHandler) SignUp ¶
func (h *DefaultHandler) SignUp(req cloud.CoapSignUpRequest) (cloud.CoapSignUpResponse, error)
func (*DefaultHandler) UnpublishResources ¶
func (h *DefaultHandler) UnpublishResources(req cloud.UnpublishResourcesRequest) error
type DefaultHandlerWithCounter ¶
type DefaultHandlerWithCounter struct { *DefaultHandler CallCounter struct { Data map[string]int Lock sync.Mutex } // contains filtered or unexported fields }
func NewCoapHandlerWithCounter ¶
func NewCoapHandlerWithCounter(atLifetime int64) *DefaultHandlerWithCounter
func (*DefaultHandlerWithCounter) PublishResources ¶
func (ch *DefaultHandlerWithCounter) PublishResources(req cloud.PublishResourcesRequest) error
func (*DefaultHandlerWithCounter) RefreshToken ¶
func (ch *DefaultHandlerWithCounter) RefreshToken(req cloud.CoapRefreshTokenRequest) (cloud.CoapRefreshTokenResponse, error)
func (*DefaultHandlerWithCounter) SignIn ¶
func (ch *DefaultHandlerWithCounter) SignIn(req cloud.CoapSignInRequest) (cloud.CoapSignInResponse, error)
func (*DefaultHandlerWithCounter) SignOff ¶
func (ch *DefaultHandlerWithCounter) SignOff() error
func (*DefaultHandlerWithCounter) SignOut ¶
func (ch *DefaultHandlerWithCounter) SignOut(req cloud.CoapSignInRequest) error
func (*DefaultHandlerWithCounter) SignUp ¶
func (ch *DefaultHandlerWithCounter) SignUp(req cloud.CoapSignUpRequest) (cloud.CoapSignUpResponse, error)
func (*DefaultHandlerWithCounter) UnpublishResources ¶
func (ch *DefaultHandlerWithCounter) UnpublishResources(req cloud.UnpublishResourcesRequest) error
func (*DefaultHandlerWithCounter) WaitForPublish ¶ added in v2.4.1
func (ch *DefaultHandlerWithCounter) WaitForPublish(timeout time.Duration) int
func (*DefaultHandlerWithCounter) WaitForSignIn ¶
func (ch *DefaultHandlerWithCounter) WaitForSignIn(timeout time.Duration) int
func (*DefaultHandlerWithCounter) WaitForSignOff ¶
func (ch *DefaultHandlerWithCounter) WaitForSignOff(timeout time.Duration) int
func (*DefaultHandlerWithCounter) WaitForUnpublish ¶ added in v2.4.1
func (ch *DefaultHandlerWithCounter) WaitForUnpublish(timeout time.Duration) int
type PublishResourcesFunc ¶ added in v2.4.3
type PublishResourcesFunc func(req ocfCloud.PublishResourcesRequest) error
type RefreshTokenFunc ¶ added in v2.4.3
type RefreshTokenFunc func(req ocfCloud.CoapRefreshTokenRequest) (ocfCloud.CoapRefreshTokenResponse, error)
type ServiceHandler ¶ added in v2.4.3
type ServiceHandler = interface { CloseOnError() bool SignUp(req ocfCloud.CoapSignUpRequest) (ocfCloud.CoapSignUpResponse, error) SignOff() error SignIn(req ocfCloud.CoapSignInRequest) (ocfCloud.CoapSignInResponse, error) SignOut(req ocfCloud.CoapSignInRequest) error PublishResources(req ocfCloud.PublishResourcesRequest) error UnpublishResources(req ocfCloud.UnpublishResourcesRequest) error RefreshToken(req ocfCloud.CoapRefreshTokenRequest) (ocfCloud.CoapRefreshTokenResponse, error) }
type SignInFunc ¶ added in v2.4.3
type SignInFunc func(req ocfCloud.CoapSignInRequest) (ocfCloud.CoapSignInResponse, error)
type SignOffFunc ¶ added in v2.4.3
type SignOffFunc func() error
type SignOutFunc ¶ added in v2.4.3
type SignOutFunc func(req ocfCloud.CoapSignInRequest) error
type SignUpFunc ¶ added in v2.4.3
type SignUpFunc func(req ocfCloud.CoapSignUpRequest) (ocfCloud.CoapSignUpResponse, error)
type UnpublishResourcesFunc ¶ added in v2.4.3
type UnpublishResourcesFunc func(req ocfCloud.UnpublishResourcesRequest) error
Click to show internal directories.
Click to hide internal directories.