service

Documentation

Index

• type Client
  • func (c *Client) Close() error
  • func (c *Client) Context() context.Context
  • func (c *Client) GetCoapConnection() *coapTcpClient.Conn
  • func (c *Client) GetDeviceID() string
  • func (c *Client) GetServiceHandler() ServiceHandler
  • func (c *Client) OnClose()
  • func (c *Client) RemoteAddrString() string
  • func (c *Client) SetDeviceID(deviceID string)
• type CoapConnectionOpt
  • func WithCoapConnectionOpt(c *client.Conn) CoapConnectionOpt
  • func (o CoapConnectionOpt) Apply(opts *ServiceHandlerConfig)
• type Config
• type GetServiceHandler
• type OnShutdown
• type Option
• type Service
  • func New(ctx context.Context, cfg Config, getHandler GetServiceHandler) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) GetClients() []*Client
  • func (s *Service) Serve() error
• type ServiceHandler
• type ServiceHandlerConfig
  • func (s *ServiceHandlerConfig) GetCoapConnection() *client.Conn
• type TLSConfig

Types

type Client

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

Client a setup of connection

func (*Client) Close

func (c *Client) Close() error

Close closes coap connection

func (*Client) Context

func (c *Client) Context() context.Context

func (*Client) GetCoapConnection

func (c *Client) GetCoapConnection() *coapTcpClient.Conn

func (*Client) GetDeviceID

func (c *Client) GetDeviceID() string

func (*Client) GetServiceHandler

func (c *Client) GetServiceHandler() ServiceHandler

func (*Client) OnClose

func (c *Client) OnClose()

OnClose is invoked when the coap connection was closed.

func (*Client) RemoteAddrString

func (c *Client) RemoteAddrString() string

func (*Client) SetDeviceID

func (c *Client) SetDeviceID(deviceID string)

type CoapConnectionOpt

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

func WithCoapConnectionOpt

func WithCoapConnectionOpt(c *client.Conn) CoapConnectionOpt

func (CoapConnectionOpt) Apply

func (o CoapConnectionOpt) Apply(opts *ServiceHandlerConfig)

type Config

type Config struct {
	Addr string
	TLS  TLSConfig
}

type GetServiceHandler

type GetServiceHandler = func(service *Service, opts ...Option) ServiceHandler

type OnShutdown

type OnShutdown = func(ServiceHandler)

type Option

type Option interface {
	Apply(o *ServiceHandlerConfig)
}

type Service

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

Service is a configuration of coap-gateway

func New

func New(ctx context.Context, cfg Config, getHandler GetServiceHandler) (*Service, error)

New creates server.

func (*Service) Close

func (s *Service) Close() error

Close turns off the server.

func (*Service) GetClients

func (s *Service) GetClients() []*Client

func (*Service) Serve

func (s *Service) Serve() error

type ServiceHandler

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 ServiceHandlerConfig

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

func (*ServiceHandlerConfig) GetCoapConnection

func (s *ServiceHandlerConfig) GetCoapConnection() *client.Conn

type TLSConfig

type TLSConfig struct {
	Enabled bool
	*tls.Config
}