test

package
v2.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 11 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 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.