ngsilib

package

Go to main page

Versions in this module

v0

v0.13.0

Aug 19, 2023

v0.12.0

Mar 18, 2022

v0.11.0

Jan 29, 2022

v0.10.0

Dec 12, 2021

Changes in this version

+ func GetDateTime(dateTime string) (string, error)

+ func GetTime(ngsi *NGSI, v int64) string

+ func HumanizeUptime(t int64) string

+ func NewNetLib() *netLib

+ func ReadAll(s string) (bytes []byte, err error)

+ type EntitiesRespose []map[string]interface

type FileLib

+ func GetReader(s string) (FileLib, error)

+ type GetReaderFunc func(s string) (FileLib, error)

+ type JsonBuffer struct

+ func NewJsonBuffer() *JsonBuffer

+ func (j *JsonBuffer) BufferClose()

+ func (j *JsonBuffer) BufferOpen(w io.Writer, geoJSON, pretty bool)

+ func (j *JsonBuffer) BufferWrite(b []byte)

type NGSI

+ ConfigDir *string

+ GetReader GetReaderFunc

+ NetLib NetLib

+ ReadAll ReadAllFunc

+ ServerList ServerList

+ func (ngsi *NGSI) GetAtContext(context string) (interface{}, error)

+ func (ngsi *NGSI) GetServerInfo(host string, skipRefHost bool) (*Server, error)

+ func (ngsi *NGSI) InsertAtContext(payload []byte, context string) (b []byte, err error)

+ type NetLib interface

+ InterfaceAddrs func() ([]net.Addr, error)

+ ListenAndServe func(addr string, handler http.Handler) error

+ ListenAndServeTLS func(addr, certFile, keyFile string, handler http.Handler) error

+ type NgsiEntities []NgsiEntity

+ type NgsiEntity map[string]interface

+ type Option struct

+ Description string

+ Name string

+ type ReadAllFunc func(s string) (bytes []byte, err error)

+ type V1ContextElement map[string]interface

+ type V1Request struct

+ ContextElements []V1ContextElement

+ UpdateAction string

+ type V1Response struct

+ ContextResponses []struct{ ... }

+ ErrorCode struct{ ... }

v0.9.0

Jul 27, 2021

Changes in this version

+ const CApikey

+ const CBasic

+ const CKeycloak

+ const CKeyrock

+ const CKeyrockIDM

+ const CKeyrocktokenprovider

+ const CKong

+ const CPasswordCredentials

+ const CThinkingCities

+ const CTokenproxy

+ const CWSO2

+ func GetApikeyHeader(client *Client) (string, string)

type Client

+ Path string

+ type FilePathLib interface

+ FilePathAbs func(path string) (string, error)

+ FilePathBase func(path string) string

+ FilePathJoin func(elem ...string) string

+ type IdmParams struct

+ ClientID string

+ ClientSecret string

+ HeaderEnvValue string

+ HeaderName string

+ HeaderValue string

+ IdmHost string

+ IdmType string

+ Password string

+ TokenScope string

+ Username string

+ type IoutilLib interface

+ Copy func(dst io.Writer, src io.Reader) (int64, error)

+ ReadFile func(filename string) ([]byte, error)

+ ReadFull func(r io.Reader, buf []byte) (n int, err error)

+ WriteFile func(filename string, data []byte, perm os.FileMode) error

+ type KeycloakToken struct

+ AccessToken string

+ ExpiresIn int

+ IDToken string

+ NotBeforePolicy int

+ RefreshExpiresIn int

+ RefreshToken string

+ Scope string

+ SessionState string

+ TokenType string

+ type KeyrockIDMToken struct

+ IdmAuthorizationConfig struct{ ... }

+ Token struct{ ... }

type KeyrockToken

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope []string

+ TokenType string

+ type KongToken struct

+ AccessToken string

+ ExpiresIn int64

+ TokenType string

+ type MultiPart interface

+ NewWriter func(w io.Writer) MultiPartLib

+ type MultiPartLib interface

+ Close func() error

+ CreatePart func(header textproto.MIMEHeader) (io.Writer, error)

+ FormDataContentType func() string

type NGSI

+ FilePath FilePathLib

+ InsecureSkipVerify bool

+ Ioutil IoutilLib

+ MultiPart MultiPart

+ ZipLib ZipLib

+ func (ngsi *NGSI) GetAuthHeader(client *Client) (string, string, error)

+ func (ngsi *NGSI) GetTokenInfo(tokenInfo *TokenInfo) ([]byte, error)

+ func (ngsi *NGSI) RevokeToken(client *Client) error

+ type OAuthToken struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope []string

+ TokenType string

type Server

+ HeaderEnvValue string

+ HeaderName string

+ HeaderValue string

+ TokenScope string

type TimeLib

+ Format func(layout string) string

+ Unix func(sec int64, nsec int64) time.Time

type TokenInfo

+ Keycloak *KeycloakToken

+ KeyrockIDM *KeyrockIDMToken

+ Kong *KongToken

+ OAuth *OAuthToken

+ RefreshToken string

+ TokenProvider *TokenProvider

+ TokenProxy *TokenProxy

+ Type string

+ WSO2 *WSO2Token

+ type TokenPlugin interface

+ type TokenProvider struct

+ AccessToken string

+ type TokenProxy struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope []string

+ TokenType string

+ type WSO2Token struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope interface{}

+ TokenType string

+ type ZipLib interface

+ NewReader func(r io.ReaderAt, size int64) (*zip.Reader, error)

v0.8.4

Jun 19, 2021

v0.8.3

Jun 12, 2021

v0.8.2

Jun 6, 2021

v0.8.1

Apr 22, 2021

Changes in this version

+ type KeyStoneToken struct

+ Token struct{ ... }

type TokenInfo

+ Keystone *KeyStoneToken

+ KeystoneToken *string

v0.8.0

Mar 14, 2021

Changes in this version

type Client

+ func (client *Client) SetAcceptGeoJSON()

+ func (client *Client) SetContentLdJSON()

type NGSI

+ func (ngsi *NGSI) StdoutFlush()

v0.7.0

Feb 28, 2021

Changes in this version

type Client

+ func (client *Client) SetContentJSON()

+ type KeyrockToken struct

+ IdmAuthorizationConfig struct{ ... }

+ Token struct{ ... }

type NGSI

+ func (ngsi *NGSI) BrokerTypeArgs() []string

+ type OauthToken struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope []string

+ TokenType string

type Server

+ BrokerType string

type TokenInfo

+ Keyrock *KeyrockToken

+ KeyrockToken *string

+ OauthToken *OauthToken

v0.6.0

Feb 3, 2021

Changes in this version

+ func InitServerList()

type Client

+ Server *Server

+ type LibError struct

+ Err error

+ ErrNo int

+ Function string

+ Message string

+ func (e *LibError) Error() string

+ func (e *LibError) String() string

+ func (e *LibError) Unwrap() error

type NGSI

+ func (ngsi *NGSI) AllServersList() *ServerList

+ func (ngsi *NGSI) CreateServer(name string, brokerParam map[string]string) error

+ func (ngsi *NGSI) DeleteServer(host string) error

+ func (ngsi *NGSI) ServerTypeArgs() []string

+ func (ngsi *NGSI) UpdateServer(host string, brokerParam map[string]string) error

type NgsiConfig

+ DeprecatedBrokers ServerList

+ Servers ServerList

+ Version string

+ type Server struct

+ APIPath string

+ ClientID string

+ ClientSecret string

+ Context string

+ DeprecatedBrokerHost string

+ IdmHost string

+ IdmType string

+ NgsiType string

+ Password string

+ SafeString string

+ Scope string

+ ServerHost string

+ ServerType string

+ Tenant string

+ Token string

+ Username string

+ XAuthToken string

+ type ServerList map[string]*Server

+ func (info *ServerList) BrokerInfo(name string) (*Server, error)

+ func (info *ServerList) BrokerInfoJSON(name string) (*string, error)

+ func (info *ServerList) BrokerList() ServerList

+ func (info *ServerList) List() string

+ func (info *ServerList) ServerInfo(name, filter string) (*Server, error)

+ func (info *ServerList) ServerInfoJSON(name, filter string) (*string, error)

+ func (info *ServerList) ServerList(filter string, all bool) ServerList

v0.5.0

Jan 1, 2021

Changes in this version

+ func IsJSONArray(b []byte) bool

type Client

+ func (client *Client) SetAcceptJSON()

type JSONLib

+ Indent func(dst *bytes.Buffer, src []byte, prefix, indent string) error

+ Valid func(data []byte) bool

type NGSI

+ func (ngsi *NGSI) GetContextHTTP(key string) (string, error)

v0.4.0

Dec 16, 2020

Changes in this version

+ func GetJSONArray(b []byte, v interface{}) error

v0.3.0

Dec 6, 2020

v0.2.0

Nov 22, 2020

Changes in this version

+ func IsNgsiLd(s string) bool

+ func IsNgsiV2(s string) bool

v0.1.0

Nov 15, 2020

Changes in this version

+ const LogDebug

+ const LogErr

+ const LogInfo

+ const LogOff

+ const LogTrace

+ const LogWarn

+ func Contains(a []string, e string) bool

+ func GetExpirationDate(s string) (string, error)

+ func InitBrokerList()

+ func IsHTTP(url string) bool

+ func IsJSON(b []byte) bool

+ func IsNameString(s string) bool

+ func IsOrionDateTime(s string) bool

+ func JSONMarshal(v interface{}) ([]byte, error)

+ func JSONMarshalDecode(v interface{}, safeString bool) ([]byte, error)

+ func JSONMarshalEncode(v interface{}, safeString bool) ([]byte, error)

+ func JSONSafeStringDecode(data []byte) ([]byte, error)

+ func JSONSafeStringEncode(data []byte) ([]byte, error)

+ func JSONUnmarshal(data []byte, v interface{}) error

+ func JSONUnmarshalDecode(data []byte, v interface{}, safeString bool) error

+ func JSONUnmarshalEncode(data []byte, v interface{}, safeString bool) error

+ func LogLevel(s string) (int, error)

+ func Reset()

+ func SafeStringDecode(s string) string

+ func SafeStringEncode(s string) string

+ type Broker struct

+ APIPath string

+ BrokerHost string

+ ClientID string

+ ClientSecret string

+ Context string

+ IdmHost string

+ IdmType string

+ NgsiType string

+ Password string

+ SafeString string

+ Scope string

+ Tenant string

+ Token string

+ Username string

+ XAuthToken string

+ type BrokerList map[string]*Broker

+ func (info *BrokerList) BrokerInfo(name string) (*Broker, error)

+ func (info *BrokerList) BrokerInfoJSON(name string) (*string, error)

+ func (info *BrokerList) List() string

+ type Client struct

+ APIPathAfter string

+ APIPathBefore string

+ Broker *Broker

+ HTTP HTTPRequest

+ Headers map[string]string

+ Link *string

+ NgsiType int

+ SafeString bool

+ Scope string

+ Tenant string

+ Token string

+ URL *url.URL

+ XAuthToken bool

+ func (client *Client) CheckScope(scope string) error

+ func (client *Client) CheckTenant(tenant string) error

+ func (client *Client) HTTPDelete() (*http.Response, []byte, error)

+ func (client *Client) HTTPGet() (*http.Response, []byte, error)

+ func (client *Client) HTTPPatch(body interface{}) (*http.Response, []byte, error)

+ func (client *Client) HTTPPost(body interface{}) (*http.Response, []byte, error)

+ func (client *Client) HTTPPut(body interface{}) (*http.Response, []byte, error)

+ func (client *Client) InitHeader() error

+ func (client *Client) IsNgsiLd() bool

+ func (client *Client) IsNgsiV2() bool

+ func (client *Client) IsSafeString() bool

+ func (client *Client) OpUpdate(entities interface{}, actionType string, keyValues bool, safeString bool) (*http.Response, []byte, error)

+ func (client *Client) RemoveHeader(key string)

+ func (client *Client) ResultsCount(res *http.Response) (int, error)

+ func (client *Client) SetContentType()

+ func (client *Client) SetHeader(key string, value string)

+ func (client *Client) SetHeaders(headers map[string]string)

+ func (client *Client) SetPath(path string)

+ func (client *Client) SetQuery(values *url.Values)

+ type CmdFlags struct

+ Link *string

+ SafeString *string

+ Scope *string

+ Tenant *string

+ Token *string

+ XAuthToken bool

+ type ContextsInfo map[string]string

+ type FileLib interface

+ Close func() error

+ File func() io.Reader

+ FilePathAbs func(path string) (string, error)

+ Open func(path string) error

+ ReadAll func(r io.Reader) ([]byte, error)

+ ReadFile func(filename string) ([]byte, error)

+ SetReader func(r io.Reader)

+ type HTTPRequest interface

+ Request func(method string, url *url.URL, headers map[string]string, body interface{}) (*http.Response, []byte, error)

+ func NewHTTPRequet() HTTPRequest

+ type IoLib interface

+ Close func() error

+ Decode func(v interface{}) error

+ Encode func(v interface{}) error

+ FileName func() *string

+ FilePathAbs func(path string) (string, error)

+ FilePathJoin func(elem ...string) string

+ Getenv func(key string) string

+ MkdirAll func(path string, perm os.FileMode) error

+ Open func() error

+ OpenFile func(flag int, perm os.FileMode) error

+ SetFileName func(filename *string)

+ Stat func(name string) (os.FileInfo, error)

+ Truncate func(size int64) error

+ UserConfigDir func() (string, error)

+ UserHomeDir func() (string, error)

+ type JSONLib interface

+ Decode func(r io.Reader, v interface{}) error

+ Encode func(w io.Writer, v interface{}) error

+ type LogWriter struct

+ LogLevel int

+ Writer io.Writer

+ func (w *LogWriter) Write(p []byte) (n int, err error)

+ type NGSI struct

+ BatchFlag *bool

+ CacheFile IoLib

+ ConfigFile IoLib

+ Destination string

+ FileReader FileLib

+ HTTP HTTPRequest

+ Host string

+ JSONConverter JSONLib

+ LogLevel int

+ LogWriter io.Writer

+ Margin int64

+ Maxsize int

+ OsType string

+ PreviousArgs *Settings

+ StdReader io.Reader

+ StdWriter io.Writer

+ Stderr *os.File

+ SyslogLib SyslogLib

+ TimeLib TimeLib

+ Timeout time.Duration

+ Updated bool

+ func NewNGSI() *NGSI

+ func (ngsi *NGSI) AddContext(key string, value string) error

+ func (ngsi *NGSI) BoolFlag(s string) (bool, error)

+ func (ngsi *NGSI) BrokerList() *BrokerList

+ func (ngsi *NGSI) Close()

+ func (ngsi *NGSI) CreateBroker(name string, brokerParam map[string]string) error

+ func (ngsi *NGSI) DeleteBroker(host string) error

+ func (ngsi *NGSI) DeleteContext(key string) error

+ func (ngsi *NGSI) DeleteItem(host string, item string) error

+ func (ngsi *NGSI) ExistsBrokerHost(host string) bool

+ func (ngsi *NGSI) GetContext(key string) (string, error)

+ func (ngsi *NGSI) GetContextList() ContextsInfo

+ func (ngsi *NGSI) GetPreviousArgs() *Settings

+ func (ngsi *NGSI) GetToken(client *Client) (string, error)

+ func (ngsi *NGSI) InitConfig(file *string) error

+ func (ngsi *NGSI) InitLog(stdin io.Reader, stdout, stderr io.Writer) *NGSI

+ func (ngsi *NGSI) InitTokenMgr(file *string) error

+ func (ngsi *NGSI) IsContextReferenced(context string) error

+ func (ngsi *NGSI) IsHostReferenced(host string) error

+ func (ngsi *NGSI) Logging(level int, s string) (n int, err error)

+ func (ngsi *NGSI) NewClient(name string, cmdFlags *CmdFlags, isHTTPVerb bool) (client *Client, err error)

+ func (ngsi *NGSI) SavePreviousArgs() error

+ func (ngsi *NGSI) ServerInfoArgs() []string

+ func (ngsi *NGSI) TokenInfo(client *Client) (*TokenInfo, error)

+ func (ngsi *NGSI) TokenList() string

+ func (ngsi *NGSI) UpdateBroker(host string, brokerParam map[string]string) error

+ func (ngsi *NGSI) UpdateContext(key string, value string) error

+ type NgsiConfig struct

+ Brokers BrokerList

+ Contexts ContextsInfo

+ DefaultValues Settings

+ type NgsiLibError struct

+ Err error

+ ErrNo int

+ Function string

+ Message string

+ func (e *NgsiLibError) Error() string

+ func (e *NgsiLibError) String() string

+ func (e *NgsiLibError) Unwrap() error

+ type Settings struct

+ CacheFile string

+ Host string

+ Logfile string

+ Loglevel string

+ Scope string

+ Stderr string

+ Syslog string

+ Tenant string

+ Token string

+ UsePreviousArgs bool

+ type SyslogLib interface

+ New func() (io.Writer, error)

+ type TimeLib interface

+ Now func() time.Time

+ NowUnix func() int64

+ type Token struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope []string

+ TokenType string

+ type TokenInfo struct

+ Expires int64

+ Token Token

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