acs

package

v0.1.5 Latest Latest Go to latest Published: Dec 8, 2023 License: MIT Imports: 25 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/netdoop/cwmp

Links

Open Source Insights

Documentation ¶

Index ¶

func GetState(typ string, name string) bool
func SendHttpConnetionRequest(url string, username string, password string) (bool, error)
func SendUDPConnectionRequest(addr string, username string, password string) (bool, error)
func SetState(typ string, name string, v bool)
type AcsHanlder
type AcsServer
- func NewAcsServer(handler AcsHanlder, dataRetentionPeriod time.Duration) *AcsServer
type AuthType
type DataModel
type Device
type MethodCall
type Options
type Product

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetState ¶

func GetState(typ string, name string) bool

func SendHttpConnetionRequest ¶

func SendHttpConnetionRequest(url string, username string, password string) (bool, error)

func SendUDPConnectionRequest ¶

func SendUDPConnectionRequest(addr string, username string, password string) (bool, error)

func SetState ¶

func SetState(typ string, name string, v bool)

Types ¶

type AcsHanlder ¶

type AcsHanlder interface {
	GetProduct(schema string, oui string, productClass string) Product
	GetDevice(schema string, oui string, productClass string, serialNumber string) Device

	HandleInform(ctx context.Context, inform *proto.Inform) error
	HandleFault(device Device, id string, v *proto.SoapFault) error

	HandleTransferComplete(ctx context.Context, device Device, req *proto.TransferComplete) error
	HandleAutonomousTransferComplete(ctx context.Context, device Device, req *proto.AutonomousTransferComplete) error
	HandleGetRPCMethodsResponse(ctx context.Context, device Device, id string, resp *proto.GetRPCMethodsResponse) error
	HandleGetParameterValuesResponse(ctx context.Context, device Device, id string, resp *proto.GetParameterValuesResponse) error
	HandleSetParameterValuesResponse(ctx context.Context, device Device, id string, resp *proto.SetParameterValuesResponse) error
	HandleGetParameterNamesResponse(ctx context.Context, device Device, id string, resp *proto.GetParameterNamesResponse) error
	HandleGetParameterAttributesResponse(ctx context.Context, device Device, id string, resp *proto.GetParameterAttributesResponse) error
	HandleSetParameterAttributesResponse(ctx context.Context, device Device, id string, resp *proto.SetParameterAttributesResponse) error
	HandleAddObjectResponse(ctx context.Context, device Device, id string, resp *proto.AddObjectResponse) error
	HandleDeleteObjectResponse(ctx context.Context, device Device, id string, resp *proto.DeleteObjectResponse) error
	HandleDownloadResponse(ctx context.Context, device Device, id string, resp *proto.DownloadResponse) error
	HandleUploadResponse(ctx context.Context, device Device, id string, resp *proto.UploadResponse) error
	HandleRebootResponse(ctx context.Context, device Device, id string, resp *proto.RebootResponse) error
	HandleFactoryResetResponse(ctx context.Context, device Device, id string, resp *proto.FactoryResetResponse) error

	HandleMesureValues(device Device, filename string, values map[string]any)
}

type AcsServer ¶

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

func NewAcsServer ¶

func NewAcsServer(handler AcsHanlder, dataRetentionPeriod time.Duration) *AcsServer

func (*AcsServer) HandlePost ¶

func (s *AcsServer) HandlePost(c echo.Context) error

func (*AcsServer) HandleUpload ¶

func (s *AcsServer) HandleUpload(c echo.Context) error

func (*AcsServer) SetupPostEchoGroup ¶

func (s *AcsServer) SetupPostEchoGroup(group *echo.Group, sessionStore sessions.Store) *echo.Group

func (*AcsServer) SetupPostEchoGroupWithOptions ¶

func (s *AcsServer) SetupPostEchoGroupWithOptions(group *echo.Group, sessionStore sessions.Store, opts Options) *echo.Group

func (*AcsServer) SetupUploadEchoGroup ¶

func (s *AcsServer) SetupUploadEchoGroup(group *echo.Group) *echo.Group

type AuthType ¶

type AuthType string

const (
	AuthTypeNone  AuthType = "None"
	AuthTypeBasic AuthType = "Basic"
)

type DataModel ¶

type DataModel interface {
	GetParameterType(name string) string
}

type Device ¶

type Device interface {
	GetProduct() Product
	GetNextMethodCall() MethodCall
	GetMethodCall(commandKey string) MethodCall
	PushMethodCall(t time.Time, methodName string, values map[string]any) (MethodCall, error)
	UpdateMethodCallRequestSend(commandKey string) error
	UpdateMethodCallResponse(commandKey string, values map[string]any, faultÇode int, faultString string) error
	UpdateMethodCallUnknow(commandKey string) error
}

type MethodCall ¶

type MethodCall interface {
	GetMethodName() string
	GetCommandKey() string
	GetRequestValues() map[string]string
	GetRequestValue(n string) string
}

type Options ¶

type Options struct {
	AuthType     AuthType
	AuthUsername string
	AuthPassword string
	DumpBody     bool
}

type Product ¶

type Product interface {
	GetDataModel() DataModel
}

Source Files ¶

View all Source files

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