test

package
v2.4.2 Latest Latest
Warning

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

Go to latest
Published: Mar 26, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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 MakeConfig

func MakeConfig(t *testing.T) service.Config

func New

func New(t *testing.T, getHandler service.GetServiceHandler, onShutdown service.OnShutdown) func()

Types

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 (*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 (*DefaultHandler) SignOff

func (h *DefaultHandler) SignOff() error

func (*DefaultHandler) SignOut

func (h *DefaultHandler) SignOut(req cloud.CoapSignInRequest) error

func (*DefaultHandler) SignUp

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 (*DefaultHandlerWithCounter) RefreshToken

func (*DefaultHandlerWithCounter) SignIn

func (*DefaultHandlerWithCounter) SignOff

func (ch *DefaultHandlerWithCounter) SignOff() error

func (*DefaultHandlerWithCounter) SignOut

func (*DefaultHandlerWithCounter) SignUp

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL