http

Documentation

Index

• Constants
• func MiddlewareBasicAuthentication(username, password string, next http.Handler) http.Handler
• func NewDevice(ctx context.Context, ID string, config cmap.CustomMap, ...) (deviceType.Plugin, error)
• type Config
• type Endpoint
  • func (ep *Endpoint) Close() error
  • func (ep *Endpoint) Name() string
  • func (ep *Endpoint) Write(message *model.Message) error
• type RequestData

Constants

const (
	HeaderKey = "Authorization"
)

const (
	PluginHTTP = "http"
)

Constants

Functions

func MiddlewareBasicAuthentication

func MiddlewareBasicAuthentication(username, password string, next http.Handler) http.Handler

func NewDevice

func NewDevice(ctx context.Context, ID string, config cmap.CustomMap, rxFunc func(msg *model.Message), statusFunc func(state *model.State)) (deviceType.Plugin, error)

New http client

Types

type Config

type Config struct {
	ListenAddress string `yaml:"listen_address"`
	IsAuthEnabled bool   `yaml:"is_auth_enabled"`
	Username      string `yaml:"username"`
	Password      string `yaml:"password" json:"-"`
}

Config details

type Endpoint

type Endpoint struct {
	ID     string
	Config *Config
	// contains filtered or unexported fields
}

Endpoint data

func (*Endpoint) Close

func (ep *Endpoint) Close() error

Close the driver

func (*Endpoint) Name

func (ep *Endpoint) Name() string

func (*Endpoint) Write

func (ep *Endpoint) Write(message *model.Message) error

type RequestData

type RequestData struct {
	Method          string              `json:"method"`
	RemoteAddress   string              `json:"remoteAddress"`
	Host            string              `json:"host"`
	Path            string              `json:"path"`
	Body            string              `json:"body"`
	QueryParameters map[string][]string `json:"queryParameters"`
	Headers         map[string][]string `json:"headers"`
	Timestamp       time.Time           `json:"timestamp"`
}