Documentation ¶
Index ¶
- Constants
- func Contains(a []string, e string) bool
- func GetApikeyHeader(client *Client) (string, string)
- func GetDateTime(dateTime string) (string, error)
- func GetExpirationDate(s string) (string, error)
- func GetJSONArray(b []byte, v interface{}) error
- func GetTime(ngsi *NGSI, v int64) string
- func HumanizeUptime(t int64) string
- func InitServerList()
- func IsHTTP(url string) bool
- func IsJSON(b []byte) bool
- func IsJSONArray(b []byte) bool
- func IsNameString(s string) bool
- func IsNgsiLd(s string) bool
- func IsNgsiV2(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 NewNetLib() *netLib
- func ReadAll(s string) (bytes []byte, err error)
- func Reset()
- func SafeStringDecode(s string) string
- func SafeStringEncode(s string) string
- type Client
- func (client *Client) CheckScope(scope string) error
- func (client *Client) CheckTenant(tenant string) error
- func (client *Client) HTTPDelete(body interface{}) (*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) SetAcceptGeoJSON()
- func (client *Client) SetAcceptJSON()
- func (client *Client) SetContentJSON()
- func (client *Client) SetContentLdJSON()
- func (client *Client) SetContentType()
- func (client *Client) SetHeader(key string, value string)
- func (client *Client) SetHeaders(headers map[string]string)
- func (client *Client) SetPath(urlPath string)
- func (client *Client) SetQuery(values *url.Values)
- type CmdFlags
- type ContextsInfo
- type EntitiesRespose
- type FileLib
- type FilePathLib
- type GetReaderFunc
- type HTTPRequest
- type IdmParams
- type IoLib
- type IoutilLib
- type JSONLib
- type JsonBuffer
- type KeyStoneToken
- type KeycloakToken
- type KeyrockIDMToken
- type KeyrockToken
- type KongToken
- type LogWriter
- type MultiPart
- type MultiPartLib
- type NGSI
- func (ngsi *NGSI) AddContext(key string, value string) error
- func (ngsi *NGSI) AllServersList() *ServerList
- func (ngsi *NGSI) BoolFlag(s string) (bool, error)
- func (ngsi *NGSI) BrokerTypeArgs() []string
- func (ngsi *NGSI) Close()
- func (ngsi *NGSI) CreateServer(name string, brokerParam map[string]string) error
- func (ngsi *NGSI) DeleteContext(key string) error
- func (ngsi *NGSI) DeleteItem(host string, item string) error
- func (ngsi *NGSI) DeleteServer(host string) error
- func (ngsi *NGSI) ExistsBrokerHost(host string) bool
- func (ngsi *NGSI) GetAtContext(context string) (interface{}, error)
- func (ngsi *NGSI) GetAuthHeader(client *Client) (string, string, error)
- func (ngsi *NGSI) GetContext(key string) (string, error)
- func (ngsi *NGSI) GetContextHTTP(key string) (string, error)
- func (ngsi *NGSI) GetContextList() ContextsInfo
- func (ngsi *NGSI) GetPreviousArgs() *Settings
- func (ngsi *NGSI) GetServerInfo(host string, skipRefHost bool) (*Server, error)
- func (ngsi *NGSI) GetToken(client *Client) (string, error)
- func (ngsi *NGSI) GetTokenInfo(tokenInfo *TokenInfo) ([]byte, 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) InsertAtContext(payload []byte, context string) (b []byte, err error)
- func (ngsi *NGSI) IsContextReferenced(context string) error
- func (ngsi *NGSI) IsHostReferenced(host string) error
- func (ngsi *NGSI) Logging(level int, s string)
- func (ngsi *NGSI) NewClient(name string, cmdFlags *CmdFlags, isHTTPVerb bool, skipGetToken bool) (client *Client, err error)
- func (ngsi *NGSI) RevokeToken(client *Client) error
- func (ngsi *NGSI) SavePreviousArgs() error
- func (ngsi *NGSI) ServerInfoArgs() []string
- func (ngsi *NGSI) ServerTypeArgs() []string
- func (ngsi *NGSI) StdoutFlush()
- func (ngsi *NGSI) TokenInfo(client *Client) (*TokenInfo, error)
- func (ngsi *NGSI) TokenList() string
- func (ngsi *NGSI) UpdateContext(key string, value string) error
- func (ngsi *NGSI) UpdateServer(host string, brokerParam map[string]string) error
- type NetLib
- type NgsiConfig
- type NgsiEntities
- type NgsiEntity
- type OAuthToken
- type Option
- type ReadAllFunc
- type Server
- type ServerList
- 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(singleLine bool) 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
- type Settings
- type SyslogLib
- type TimeLib
- type TokenInfo
- type TokenPlugin
- type TokenProvider
- type TokenProxy
- type V1ContextElement
- type V1Request
- type V1Response
- type WSO2Token
- type ZipLib
Constants ¶
const ( // LogOff is ... LogOff = iota // LogErr is ... LogErr // LogWarn is ... LogWarn // LogInfo is ... LogInfo // LogDebug is ... LogDebug // LogTrace is ... LogTrace )
const ( CPasswordCredentials = "password" CKeyrock = "keyrock" CKeyrocktokenprovider = "keyrocktokenprovider" CTokenproxy = "tokenproxy" CKeyrockIDM = "idm" CThinkingCities = "thinkingcities" CBasic = "basic" CKeycloak = "keycloak" CWSO2 = "wso2" CKong = "kong" CApikey = "apikey" )
Variables ¶
This section is empty.
Functions ¶
func GetApikeyHeader ¶ added in v0.9.0
func GetJSONArray ¶ added in v0.4.0
GetJSONArray is ...
func JSONMarshalDecode ¶
JSONMarshalDecode is ...
func JSONMarshalEncode ¶
JSONMarshalEncode is ...
func JSONSafeStringDecode ¶
JSONSafeStringDecode is ...
func JSONSafeStringEncode ¶
JSONSafeStringEncode is ...
func JSONUnmarshalDecode ¶
JSONUnmarshalDecode is ...
func JSONUnmarshalEncode ¶
JSONUnmarshalEncode is ...
Types ¶
type Client ¶
type Client struct { Server *Server URL *url.URL Headers map[string]string Token string Tenant string Scope string APIPathBefore string APIPathAfter string NgsiType int SafeString bool XAuthToken bool Link *string HTTP HTTPRequest Path string }
Client is
func (*Client) CheckTenant ¶
CheckTenant is ...
func (*Client) HTTPDelete ¶
HTTPDelete is
func (*Client) OpUpdate ¶
func (client *Client) OpUpdate(entities interface{}, actionType string, keyValues bool, safeString bool) (*http.Response, []byte, error)
OpUpdate is ...
func (*Client) ResultsCount ¶
ResultsCount is ...
func (*Client) SetAcceptGeoJSON ¶ added in v0.8.0
func (client *Client) SetAcceptGeoJSON()
SetAcceptGeoJSON is ...
func (*Client) SetAcceptJSON ¶ added in v0.5.0
func (client *Client) SetAcceptJSON()
SetAcceptJSON is ...
func (*Client) SetContentJSON ¶ added in v0.7.0
func (client *Client) SetContentJSON()
SetContentJSON is ...
func (*Client) SetContentLdJSON ¶ added in v0.8.0
func (client *Client) SetContentLdJSON()
SetContentLdJSON is ...
func (*Client) SetHeaders ¶
SetHeaders is ...
type CmdFlags ¶
type CmdFlags struct { Token *string Tenant *string Scope *string SafeString *string XAuthToken bool Link *string }
CmdFlags is ...
type EntitiesRespose ¶ added in v0.10.0
type EntitiesRespose []map[string]interface{}
type FileLib ¶
type FileLib interface { Open(path string) error Close() error FilePathAbs(path string) (string, error) ReadAll(r io.Reader) ([]byte, error) ReadFile(filename string) ([]byte, error) SetReader(r io.Reader) File() bufio.Reader }
FileLib is ...
type FilePathLib ¶ added in v0.9.0
type FilePathLib interface { FilePathAbs(path string) (string, error) FilePathJoin(elem ...string) string FilePathBase(path string) string }
FilePathLib is ...
type GetReaderFunc ¶ added in v0.10.0
type HTTPRequest ¶
type HTTPRequest interface {
Request(method string, url *url.URL, headers map[string]string, body interface{}) (*http.Response, []byte, error)
}
HTTPRequest is ...
type IdmParams ¶ added in v0.9.0
type IdmParams struct { IdmType string IdmHost string Username string Password string ClientID string ClientSecret string HeaderName string HeaderValue string HeaderEnvValue string TokenScope string }
IdmParam is ...
type IoLib ¶
type IoLib interface { Open() error OpenFile(flag int, perm os.FileMode) error Truncate(size int64) error Close() error Decode(v interface{}) error Encode(v interface{}) error MkdirAll(path string, perm os.FileMode) error Stat(name string) (os.FileInfo, error) UserConfigDir() (string, error) UserHomeDir() (string, error) SetFileName(filename *string) FileName() *string Getenv(key string) string FilePathAbs(path string) (string, error) FilePathJoin(elem ...string) string }
IoLib is ...
type IoutilLib ¶ added in v0.9.0
type IoutilLib interface { Copy(dst io.Writer, src io.Reader) (int64, error) ReadFull(r io.Reader, buf []byte) (n int, err error) WriteFile(filename string, data []byte, perm os.FileMode) error ReadFile(filename string) ([]byte, error) }
IoutilLib is ...
type JSONLib ¶
type JSONLib interface { Decode(r io.Reader, v interface{}) error Encode(w io.Writer, v interface{}) error Indent(dst *bytes.Buffer, src []byte, prefix, indent string) error Valid(data []byte) bool }
JSONLib is
type JsonBuffer ¶ added in v0.10.0
type JsonBuffer struct {
// contains filtered or unexported fields
}
func NewJsonBuffer ¶ added in v0.10.0
func NewJsonBuffer() *JsonBuffer
func (*JsonBuffer) BufferClose ¶ added in v0.10.0
func (j *JsonBuffer) BufferClose()
func (*JsonBuffer) BufferOpen ¶ added in v0.10.0
func (j *JsonBuffer) BufferOpen(w io.Writer, geoJSON, pretty bool)
func (*JsonBuffer) BufferWrite ¶ added in v0.10.0
func (j *JsonBuffer) BufferWrite(b []byte)
type KeyStoneToken ¶ added in v0.8.1
type KeyStoneToken struct { Token struct { Domain struct { ID string `json:"id"` Name string `json:"name"` } `json:"domain"` Methods []string `json:"methods"` Roles []keyStoneRole `json:"roles"` ExpiresAt string `json:"expires_at"` Catalog []keyStoneCatalog `json:"catalog"` Extras struct { PasswordCreationTime string `json:"password_creation_time"` LastLoginAttemptTime string `json:"last_login_attempt_time"` PwdUserInBlacklist bool `json:"pwd_user_in_blacklist"` PasswordExpirationTime string `json:"password_expiration_time"` } `json:"extras"` User struct { PasswordExpiresAt string `json:"password_expires_at"` Domain struct { ID string `json:"id"` Name string `json:"name"` } `json:"domain"` ID string `json:"id"` Name string `json:"name"` } `json:"user"` AuditIds []string `json:"audit_ids"` IssuedAt string `json:"issued_at"` } `json:"token"` }
KeyStoneToken is ...
type KeycloakToken ¶ added in v0.9.0
type KeycloakToken struct { AccessToken string `json:"access_token"` ExpiresIn int `json:"expires_in"` RefreshExpiresIn int `json:"refresh_expires_in"` RefreshToken string `json:"refresh_token"` TokenType string `json:"token_type"` IDToken string `json:"id_token"` NotBeforePolicy int `json:"not-before-policy"` SessionState string `json:"session_state"` Scope string `json:"scope"` }
type KeyrockIDMToken ¶ added in v0.9.0
type KeyrockIDMToken struct { Token struct { Methods []string `json:"methods"` ExpiresAt string `json:"expires_at"` } `json:"token"` IdmAuthorizationConfig struct { Level string `json:"level"` Authzforce bool `json:"authzforce"` } `json:"idm_authorization_config"` }
KeyrockToken is ...
type KeyrockToken ¶ added in v0.7.0
type KeyrockToken struct { AccessToken string `json:"access_token"` ExpiresIn int64 `json:"expires_in"` RefreshToken string `json:"refresh_token"` Scope []string `json:"scope"` TokenType string `json:"token_type"` }
KeyrockToken is ...
type KongToken ¶ added in v0.9.0
type KongToken struct { ExpiresIn int64 `json:"expires_in"` AccessToken string `json:"access_token"` TokenType string `json:"token_type"` }
KongToken is ...
type MultiPart ¶ added in v0.9.0
type MultiPart interface {
NewWriter(w io.Writer) MultiPartLib
}
MultiPart is ...
type MultiPartLib ¶ added in v0.9.0
type MultiPartLib interface { CreatePart(header textproto.MIMEHeader) (io.Writer, error) FormDataContentType() string Close() error }
MultiPartLib is ...
type NGSI ¶
type NGSI struct { ServerList ServerList ConfigDir *string ConfigFile IoLib CacheFile IoLib StdReader io.Reader StdWriter io.Writer LogWriter io.Writer FileReader FileLib JSONConverter JSONLib FilePath FilePathLib Ioutil IoutilLib ZipLib ZipLib SyslogLib SyslogLib TimeLib TimeLib MultiPart MultiPart ReadAll ReadAllFunc GetReader GetReaderFunc HTTP HTTPRequest NetLib NetLib Host string Destination string LogLevel int Margin int64 Maxsize int64 Timeout time.Duration PreviousArgs *Settings Updated bool Stderr io.Writer OsType string BatchFlag *bool InsecureSkipVerify bool // contains filtered or unexported fields }
NGSI is ...
func (*NGSI) AddContext ¶
AddContext is ...
func (*NGSI) AllServersList ¶ added in v0.6.0
func (ngsi *NGSI) AllServersList() *ServerList
AllServersList is ...
func (*NGSI) BrokerTypeArgs ¶ added in v0.7.0
BrokerTypeArgs is ...
func (*NGSI) CreateServer ¶ added in v0.6.0
CreateServer is ...
func (*NGSI) DeleteItem ¶
DeleteItem is ...
func (*NGSI) DeleteServer ¶ added in v0.6.0
DeleteServer is ...
func (*NGSI) ExistsBrokerHost ¶
ExistsBrokerHost is ...
func (*NGSI) GetAtContext ¶ added in v0.10.0
func (*NGSI) GetAuthHeader ¶ added in v0.9.0
GetAuthHeader is ...
func (*NGSI) GetContext ¶
GetContext is ...
func (*NGSI) GetContextHTTP ¶ added in v0.5.0
GetContextHTTP is ...
func (*NGSI) GetServerInfo ¶ added in v0.10.0
func (*NGSI) GetTokenInfo ¶ added in v0.9.0
func (*NGSI) InsertAtContext ¶ added in v0.10.0
func (*NGSI) IsContextReferenced ¶
IsContextReferenced is ...
func (*NGSI) IsHostReferenced ¶
IsHostReferenced is ...
func (*NGSI) NewClient ¶
func (ngsi *NGSI) NewClient(name string, cmdFlags *CmdFlags, isHTTPVerb bool, skipGetToken bool) (client *Client, err error)
NewClient is ...
func (*NGSI) RevokeToken ¶ added in v0.9.0
RevokeToken is ...
func (*NGSI) ServerTypeArgs ¶ added in v0.6.0
ServerTypeArgs is ...
func (*NGSI) UpdateContext ¶
UpdateContext is ...
type NetLib ¶ added in v0.10.0
type NetLib interface { InterfaceAddrs() ([]net.Addr, error) ListenAndServe(addr string, handler http.Handler) error ListenAndServeTLS(addr, certFile, keyFile string, handler http.Handler) error }
NetLib is ...
type NgsiConfig ¶
type NgsiConfig struct { Version string `json:"version"` DefaultValues Settings `json:"settings"` DeprecatedBrokers ServerList `json:"brokers,omitempty"` Servers ServerList `json:"servers"` Contexts ContextsInfo `json:"contexts"` }
NgsiConfig is ...
type NgsiEntities ¶ added in v0.10.0
type NgsiEntities []NgsiEntity
type NgsiEntity ¶ added in v0.10.0
type NgsiEntity map[string]interface{}
type OAuthToken ¶ added in v0.9.0
type OAuthToken struct { AccessToken string `json:"access_token"` ExpiresIn int64 `json:"expires_in"` RefreshToken string `json:"refresh_token"` Scope []string `json:"scope"` TokenType string `json:"token_type"` }
OauthToken is ...
type ReadAllFunc ¶ added in v0.10.0
type Server ¶ added in v0.6.0
type Server struct { ServerType string `json:"serverType,omitempty"` DeprecatedBrokerHost string `json:"brokerHost,omitempty"` ServerHost string `json:"serverHost,omitempty"` BrokerType string `json:"brokerType,omitempty"` NgsiType string `json:"ngsiType,omitempty"` APIPath string `json:"apiPath,omitempty"` IdmType string `json:"idmType,omitempty"` IdmHost string `json:"idmHost,omitempty"` Token string `json:"token,omitempty"` Username string `json:"username,omitempty"` Password string `json:"password,omitempty"` ClientID string `json:"clientId,omitempty"` ClientSecret string `json:"clientSecret,omitempty"` HeaderName string `json:"headerName,omitempty"` HeaderValue string `json:"headerValue,omitempty"` HeaderEnvValue string `json:"headerEnvValue,omitempty"` TokenScope string `json:"tokenScope,omitempty"` Context string `json:"context,omitempty"` Tenant string `json:"tenant,omitempty"` Scope string `json:"scope,omitempty"` SafeString string `json:"safeString,omitempty"` XAuthToken string `json:"xAuthToken,omitempty"` }
Server is
type ServerList ¶ added in v0.6.0
ServerList is ...
func (*ServerList) BrokerInfo ¶ added in v0.6.0
func (info *ServerList) BrokerInfo(name string) (*Server, error)
BrokerInfo is ...
func (*ServerList) BrokerInfoJSON ¶ added in v0.6.0
func (info *ServerList) BrokerInfoJSON(name string) (*string, error)
BrokerInfoJSON is ...
func (*ServerList) BrokerList ¶ added in v0.6.0
func (info *ServerList) BrokerList() ServerList
BrokerList is ...
func (*ServerList) List ¶ added in v0.6.0
func (info *ServerList) List(singleLine bool) string
List is ...
func (*ServerList) ServerInfo ¶ added in v0.6.0
func (info *ServerList) ServerInfo(name, filter string) (*Server, error)
ServerInfo is ...
func (*ServerList) ServerInfoJSON ¶ added in v0.6.0
func (info *ServerList) ServerInfoJSON(name, filter string) (*string, error)
ServerInfoJSON is ...
func (*ServerList) ServerList ¶ added in v0.6.0
func (info *ServerList) ServerList(filter string, all bool) ServerList
ServerList is ...
type Settings ¶
type Settings struct { UsePreviousArgs bool `json:"usePreviousArgs"` Syslog string `json:"syslog"` Stderr string `json:"stderr"` Logfile string `json:"logfile"` Loglevel string `json:"loglevel"` CacheFile string `json:"cachefile"` Host string `json:"host"` Tenant string `json:"tenant"` Scope string `json:"scope"` Token string `json:"token"` }
Settings is ...
type TimeLib ¶
type TimeLib interface { Now() time.Time NowUnix() int64 Unix(sec int64, nsec int64) time.Time Format(layout string) string }
TimeLib is ...
type TokenInfo ¶
type TokenInfo struct { Type string `json:"type"` Token string `json:"token"` RefreshToken string `json:"refresh_token"` Expires time.Time `json:"expires"` OAuth *OAuthToken `json:"oauth,omitempty"` KeyrockIDM *KeyrockIDMToken `json:"keyrock_idm,omitempty"` Keyrock *KeyrockToken `json:"keyrock,omitempty"` TokenProxy *TokenProxy `json:"tokenproxy,omitempty"` TokenProvider *TokenProvider `json:"tokenprovider,omitempty"` Keystone *KeyStoneToken `json:"keystone,omitempty"` Keycloak *KeycloakToken `json:"keycloak,omitempty"` WSO2 *WSO2Token `json:"wso2,omitempty"` Kong *KongToken `json:"kong,omitempty"` }
TokenInfo is ...
type TokenPlugin ¶ added in v0.9.0
type TokenPlugin interface {
// contains filtered or unexported methods
}
TokenPlugin interface
TokenPlugin is ...
type TokenProvider ¶ added in v0.9.0
type TokenProvider struct {
AccessToken string `json:"access_token"`
}
TokenProvider is ...
type TokenProxy ¶ added in v0.9.0
type TokenProxy struct { AccessToken string `json:"access_token"` ExpiresIn int64 `json:"expires_in"` RefreshToken string `json:"refresh_token"` Scope []string `json:"scope"` TokenType string `json:"token_type"` }
Token proxy is a proxy for Keyrock TokenProxy is ...
type V1ContextElement ¶ added in v0.10.0
type V1ContextElement map[string]interface{}
type V1Request ¶ added in v0.10.0
type V1Request struct { ContextElements []V1ContextElement `json:"contextElements"` UpdateAction string `json:"updateAction"` }
type V1Response ¶ added in v0.10.0
type V1Response struct { ContextResponses []struct { ContextElement V1ContextElement `json:"contextElement"` StatusCode struct { Code string `json:"code"` ReasonPhrase string `json:"reasonPhrase"` } `json:"statusCode"` } `json:"contextResponses"` ErrorCode struct { Code string `json:"code"` ReasonPhrase string `json:"reasonPhrase"` Details string `json:"details"` } `json:"errorCode"` }
Source Files ¶
- atcontext.go
- buffer.go
- client.go
- config.go
- context.go
- encoding.go
- filelib.go
- filepathlib.go
- http_lib.go
- iolib.go
- ioutillib.go
- jsonlib.go
- keystone.go
- logger.go
- multipartlib.go
- netlib.go
- new_client.go
- ngsilib.go
- op_update.go
- reader.go
- safe_string.go
- server.go
- server_list.go
- server_mgr.go
- syslog_lib.go
- timelib.go
- token_apikey.go
- token_basic.go
- token_keycloak.go
- token_keyrock.go
- token_keyrock_idm.go
- token_keyrock_token_provider.go
- token_kong.go
- token_mgr.go
- token_password_credentials.go
- token_thinking_cities.go
- token_token_proxy.go
- token_wso2.go
- typedef.go
- validation.go
- ziplib.go