irplib

package module
v1.3.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 29, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

README

IRP Developer Library

This is the IRP Developer Library for performing native IRP operations using the HTTP REST API in your applications.

BREAKING CHANGES: v1.3.0 introduces breaking changes to how this library is used. This library now supports using Handle Cert authentication in addition to Handle Challenge-Response. To accomodate this, the Authenticate function has been removed and the functions AuthCert and AuthCR are added.

Certificate authentication uses the user's information to dynamically generate the certificate for authentication, the user does need to provide any certificate. Using the user's private key with the admin PUID and index, this library will create the certificate on the fly whenever the AuthCert function is called.

Certificate authentication has the benefit of allowing a longer use of the authentication information instead of challenge-response, which has a fixed TTL (typically 30 minutes on a standard LHS deployment).

Create Authentication Information

An Authentication Response is needed for any admin action such as CREATE, UPDATE, REMOVE or DELETE. It is also needed for RESOLVE if wanting to retrieve values marked as private.

There is an option to pass a custom TLS configuration depending on the needs of the remote server. While the GHR and LHS utilize self-signed certs, having a custom TLS configuration option ensures some LHS may use their own certificates that are globally recognized or using custom CAs. This library does it's best to cater to these needs. At the least, provide the following TLS configuration, which skips certificate checking, as a default

&tls.Config{InsecureSkipVerify: true}

Reading private key

This library supports usage of RSA keys in either JWK or PEM format.

An example of reading JWK private keys is as follows

privKeyBytes, err := ioutil.ReadFile("/path/to/private_key.jwk")
if err != nil {
  log.Println(err)
  os.Exit(1)
}

privateKey, err = irplib.ToJWK(privKeyBytes)
if nil != err {
  log.Println(err)
  os.Exit(1)
}

An example of reading PEM private keys is as follows

j, err := irplib.NewJWKFromRSAPubKey(data.PrivateKey.RSA.PublicKey)
if nil != err {
  log.Println(err)
  os.Exit(1)
}

Authentication

Create authentication (using challenge-response) for ADMIN requests

// create a default TLS configuration, which skips insecure and self-signed certs (needed for GHR and almost all LHS)
// other tls configuration with custom CA or keys can be added to `tlsConfig` as well
tlsConfig := &tls.Config{InsecureSkipVerify: true}

// start by getting site information for a given IRP ID, replace `irplib.ServerAdmin` with `irplib.ServerQuery` for resolve requests
server, err := irplib.GetPrefixSite(puid, irplib.ServerAdmin, tlsConfig)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// perform authentication using the given information
authResponse, err := irplib.AuthCR(server, adminIndex, adminPUID, privateKey)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

defer irplib.EndSession(authResponse) // this ends the authenticated session once we're done with our operations
Create authentication (using challenge-response) for QUERY requests

// start by getting site information for a given IRP ID, replace `irplib.ServerQuery` with `irplib.ServerAdmin` for create, update, remove or delete requests
server, err := irplib.GetPrefixSite(puid, irplib.ServerQuery, tlsConfig)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// perform authentication using the given information
authResponse, err := irplib.AuthCR(server, adminIndex, adminPUID, privateKey)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

defer irplib.EndSession(authResponse) // this ends the authenticated session once we're done with our operations
Create authentication (using certificate) for ADMIN requests

// create a default TLS configuration, which skips insecure and self-signed certs (needed for GHR and almost all LHS)
// other tls configuration with custom CA or keys can be added to `tlsConfig` as well
tlsConfig := &tls.Config{InsecureSkipVerify: true}

// start by getting site information for a given IRP ID, replace `irplib.ServerAdmin` with `irplib.ServerQuery` for resolve requests
server, err := irplib.GetPrefixSite(puid, irplib.ServerAdmin, tlsConfig)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// perform authentication using the given information
authResponse, err := irplib.AuthCert(server, adminIndex, adminPUID, privateKey, time.Minute*time.Duration(30)) // this expires the certificate after 30 minutes, change the duration as needed, it can be as short as 1-2 minutes provided the LHS and client do not have a skew in their time
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// for certificate authentication, there is no need to call `EndSession`, the certificate has a short lifetime which will expire automatically.
Create authentication (using certificate) for QUERY requests

// start by getting site information for a given IRP ID, replace `irplib.ServerQuery` with `irplib.ServerAdmin` for create, update, remove or delete requests
server, err := irplib.GetPrefixSite(puid, irplib.ServerQuery, tlsConfig)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// perform authentication using the given information
authResponse, err := irplib.AuthCert(server, adminIndex, adminPUID, privateKey, time.Minute*time.Duration(30)) // this expires the certificate after 30 minutes, change the duration as needed, it can be as short as 1-2 minutes provided the LHS and client do not have a skew in their time
if err != nil {
  log.Println(err)
  os.Exit(1)
}

// for certificate authentication, there is no need to call `EndSession`, the certificate has a short lifetime which will expire automatically.

Resolve operation

Unauthenticated resolve request - returns only values with PUBLIC read permission

This is a special method to perform resolution of IRP PUIDs without needing to go through the authentication. In this approach, only the public values that are meant to be readable by the public will be returned.


// the last parameter is an `irplib.Parameter{}` struct used to list specific indexes or types to be returned, such as `irplib.Parameter{Indexes: []int{301, 1001}}` or `irplib.Parameter{Types: []string{"hs_pubkey", "custom value"}}`

// creates a default TLS configuration, which skips insecure and self-signed certs (needed for GHR and almost all LHS)
// other tls configuration with custom CA or keys can be added to `tlsConfig` as well
tlsConfig := &tls.Config{InsecureSkipVerify: true}

// get the site information for the IRP prefix
server, err := irplib.GetPrefixSite(data.HandleID, irplib.ServerAdmin, tlsConfig)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

authResponse, err := irplib.UnauthenticatedResolve(server)
if err != nil {
  log.Println(err)
  os.Exit(1)
}

irpResponse := irplib.Resolve(, puid, irplib.Parameter{})
fmt.Println(irpResponse.ResponseCode)
Authenticated resolve request - returns values with PUBLIC and PRIVATE read permission (assuming authenticated user has necessary permission)

// the last function parameter is for list of indexes to be returned

irpResponse := irplib.Resolve(server, authResponse, puid, irplib.Parameter{Types: []string{"hs_pubkey", "custom value"}})
fmt.Println(irpResponse.ResponseCode)

Create operation

Crates a new IRP record or replaces an existing one, presuming the authenticated user has permission to do so.


var values irplib.Values

// the last parameter for creating values indicate it it should be marked as private or not; true = mark as private, false = publicly viewable for unauthenticated requests

// don't forget to add an admin to the record
values.AddAdmin(101, adminIndex, adminPUID, irplib.DefaultTTL, true)

// add a string value
values.AddString(1234, "test", "hello, world!", irplib.DefaultTTL, false)

// add a VLIST
vlv := irplib.NewVList()
vlv.Add("11.5678/ABC", 301)
vlv.Add("11.5678/ABC", 301)
values.AddVList(5433, irplib.TypeVList, vlv, irplib.DefaultTTL, true)

j, err := irplib.NewJWKFromRSAPubKey(privateKey.PublicKey)
if nil != err {
  log.Println(err)
  os.Exit(1)
}

// addd a pubkey
values.AddKey(301, irplib.TypeHSPubKey, j, irplib.DefaultTTL, false)

// the last parameter for create indicates if the IRP record should be replaced if it already exists; true = replace, false = NO NOT replace
irpResponse := irplib.Create(authResponse, puid, values, true)
fmt.Println(irpResponse.ResponseCode)

Update operation

Adds or updates specified indexes in the IRP Record, presuming the authenticated user has permission to do so.


var values irplib.Values

// add a new string value
values.AddString(12890, "hash", "68e656b251e67e8358bef8483ab0d51c6619f3e7a1a9f0e75838d41ff368f728", irplib.DefaultTTL, false)

// the last parameter for update indicates if the new IRP value can replace existing values at the given index; true = replace, false = DO NOT replace
irpResponse := irplib.Update(authResponse, puid, values, true)
fmt.Println(irpResponse.ResponseCode)

Remove operation

Removes specified indexes from the IRP Record, presuming the authenticated user has permission to do so.


// the last parameter is a slice of indexes to be removed
irpResponse := irplib.Remove(authResponse, puid, []int{12890})
fmt.Println(irpResponse.ResponseCode)

Delete operation

Completely deletes an IRP Record, presuming the authenticated user has permission to do so.


irpResponse := irplib.Delete(authResponse, puid)

Documentation

Index

Constants

View Source 
const (

	// AdminRead - Permission index for admin read
	AdminRead = iota

	// AdminWrite - Permission index for admin write
	AdminWrite

	// PublicRead - Permission index for public read
	PublicRead

	// PublicWrite - Permission index for public read, this library does not support setting public write
	PublicWrite
)
View Source 
const DefaultTTL = 86400

DefaultTTL - Default TTL of a IRP type/value. Used by LHS to determine cache lifetime.

View Source 
const (
	EncodingRSA = "RSA_PUB_KEY"
)
View Source 
const FormatAdmin = "admin"

FormatAdmin - IRP format for storing admin entry

View Source 
const FormatBase64 = "base64"

FormatBase64 - IRP format for storing base64 entry

View Source 
const FormatKey = "key"

FormatKey - IRP format for storing public keys

View Source 
const FormatSite = "site"

FormatSite - IRP format for storing site information

View Source 
const FormatString = "string"

FormatString - IRP format for storing string entry

View Source 
const FormatVList = "vlist"

FormatVList - IRP format for storing vlist entry

View Source 
const ResponseCodeAuthErr = 406

ResponseCodeAuthErr - authentication error

View Source 
const ResponseCodeAuthNeeded = 402

ResponseCodeAuthNeeded - Authentication required

View Source 
const ResponseCodeAuthenFailed = 403

ResponseCodeAuthenFailed - Failed to authenticate

View Source 
const ResponseCodeError = 2

ResponseCodeError - IRP responseCode for general error

View Source 
const ResponseCodeIRPAlreadyExist = 101

ResponseCodeIRPAlreadyExist - IRP already exists

View Source 
const ResponseCodeInsufficientPerm = 401

ResponseCodeInsufficientPerm - insufficient permission to execute requested operation

View Source 
const ResponseCodeInvalidAdmin = 400

ResponseCodeInvalidAdmin - invalid admin

View Source 
const ResponseCodeInvalidCredentials = 404

ResponseCodeInvalidCredentials - invalid credentials for authentication

View Source 
const ResponseCodeInvalidIRP = 102

ResponseCodeInvalidIRP - Encoding (or syntax) error

View Source 
const ResponseCodeNotFound = 100

ResponseCodeNotFound - IRP responseCode for IRP ID not found

View Source 
const ResponseCodeOpNotSupported = 5

ResponseCodeOpNotSupported - IRP responseCode for requested operation not supported

View Source 
const ResponseCodeProtocolError = 4

ResponseCodeProtocolError - IRP responseCode for protocol error

View Source 
const ResponseCodeServerNotResp = 301

ResponseCodeServerNotResp - Server not responsible

View Source 
const ResponseCodeServerReadOnly = 6

ResponseCodeServerReadOnly - IRP responseCode for requested server only supports read requests

View Source 
const ResponseCodeSessionFailed = 501

ResponseCodeSessionFailed - session failed

View Source 
const ResponseCodeSessionInvalidKey = 502

ResponseCodeSessionInvalidKey - session invalid key

View Source 
const ResponseCodeSessionInvalidSetup = 504

ResponseCodeSessionInvalidSetup - invalid session setup request

View Source 
const ResponseCodeSessionTimeout = 500

ResponseCodeSessionTimeout - session timed out

View Source 
const ResponseCodeSuccess = 1

ResponseCodeSuccess - IRP responseCode for success

View Source 
const ResponseCodeValueExists = 201

ResponseCodeValueExists - Value already exists

View Source 
const ResponseCodeValueInvalid = 202

ResponseCodeValueInvalid - Value invalid

View Source 
const ResponseCodeValueNotFound = 200

ResponseCodeValueNotFound - Value not found

View Source 
const ServerAdmin = int8(2)

ServerAdmin - seek admin server

View Source 
const ServerQuery = int8(1)

ServerQuery - seek query server

View Source 
const TypeHSAdmin = "HS_ADMIN"

TypeHSAdmin - IRP type/value pair for storing admins

View Source 
const TypeHSPubKey = "HS_PUBKEY"

TypeHSPubKey - IRP type/value pair for storing public keys

View Source 
const TypeHSSignature = "HS_SIGNATURE"

TypeHSSignature - IRP type/value pair for digital signature of this IRP Record

View Source 
const TypeHSSite = "HS_SITE"

TypeHSSite - IRP type/value pair for storing site information

View Source 
const TypeVList = "HS_VLIST"

TypeVList - IRP type/value pair for virtual lists, pointing to other IDs and indexes

Variables

This section is empty.

Functions

func AddGHR 

func AddGHR(address string, port int)

AddGHR - adds a GHR to the list

func AdminToIRPProto added in v1.3.6 

func AdminToIRPProto(admin *Admin) (proto []byte)

AdminToIRPProto - converts an admin to native IRP byte protocol

func ClearGHR 

func ClearGHR()

ClearGHR - clears GHR list

func CurrentTS 

func CurrentTS() (ts int64)

CurrentTS - returns current UNIX timestamp

func EndSession 

func EndSession(authResponse *AuthResponse) (err error)

EndSession - deletes a given session ID. If no logout is performed, a session ID is valid for 30 minutes of inactivity.

func ExpiredValue 

func ExpiredValue(givenTimeStr string, ttl int64) (valid bool)

ExpiredValue - checks if a given time and the ttl is within current time

func IsValidHandle added in v1.1.3 

func IsValidHandle(handleid string) (err error)

IsValidHandle - checks if a given handleid is valid

func IsValidPrefix added in v1.1.3 

func IsValidPrefix(prefix string) (err error)

IsValidPrefix - checks if a given prefix is valid

func JWKToBytes added in v1.3.0 

func JWKToBytes(j *JWK) (bytes []byte)

JWKToBytes - converts JWK to JSON bytes

func JWKToIRPProto added in v1.3.6 

func JWKToIRPProto(j *JWK) (proto []byte)

JWKToIRPProto - converts a key to native IRP byte protocol

func JWKToKey added in v1.3.0 

func JWKToKey(j *JWK) (k interface{})

JWKToKey - gets an instance of the key from JWK

func JWKToPEM added in v1.3.5 

func JWKToPEM(j *JWK) (pembytes []byte)

JWKToPEM - converts JWK to PEM bytes

func RandomInt 

func RandomInt(min, max int) int

RandomInt - generates a random number between the given range

func ReadYaml 

func ReadYaml(inputFile string, inputStruct interface{}) (fileErr error)

ReadYaml - reads a given input YAML file and returns the struct mapped from the file

func SetCustomIRPSvc 

func SetCustomIRPSvc(prefix, address string, port int, desc string)

SetCustomIRPSvc - sets a custom IRP service for connection

func SiteToIRPProto added in v1.3.6 

func SiteToIRPProto(siteInfo *SiteInfo) (proto []byte)

SiteToIRPProto - converts a site to native IRP byte protocol

func TSNow 

func TSNow() (timestamp int64)

TSNow - return the current timestamp in UTC for consistency

func TimeUTC 

func TimeUTC() (timeStr string)

TimeUTC - return the current time in UTC for consistency

func ToIRPBytes added in v1.3.6 

func ToIRPBytes(value Value) (irpBytes []byte, ok bool)

ToIRPBytes - convert IRP Values to IRP Bytes

func VListToIRPProto added in v1.3.6 

func VListToIRPProto(vlistValues *VListValues) (proto []byte)

VListToIRPProto - converts a vlist to native IRP byte protocol

func WriteYaml 

func WriteYaml(outputFile string, outputStruct interface{})

WriteYaml - writes a given struct to the given filename

Types

type Admin 

type Admin struct {
	Handle string `json:"handle"`
	Index  int    `json:"index"`

	Permissions string `json:"permissions"`
	// contains filtered or unexported fields
}

Admin - admin IRP value format

func NewAdmin 

func NewAdmin(adminIndex int, adminID string) (admin *Admin, err error)

NewAdmin - creates a new IRP Admin structure

func (*Admin) ClearPermission 

func (admin *Admin) ClearPermission()

ClearPermission - clears all permissions to start afresh

func (*Admin) HasPermission 

func (admin *Admin) HasPermission(permission AdminPerm) (hasPermission bool)

HasPermission - checks if admin has requested permission

func (*Admin) SetDefaultPermission 

func (admin *Admin) SetDefaultPermission()

SetDefaultPermission - default permission for a IRP Admin

func (*Admin) SetPermission 

func (admin *Admin) SetPermission(permission AdminPerm, hasPermission bool)

SetPermission - sets permission for a IRP Admin

type AdminPerm 

type AdminPerm int
const (

	// PermListHandles - Permission index for listing handles
	PermListHandles AdminPerm = iota

	// PermReadValues - Permission index for reading private values
	PermReadValues

	// PermAdminAdd - Permission index for adding new admins to THIS IRP Record
	PermAdminAdd

	// PermAdminRemove - Permission index for removing existing admins from THIS IRP Record
	PermAdminRemove

	// PermAdminModify - Permission index for modifying existing admins from THIS IRP Record
	PermAdminModify

	// PermValueAdd - Permission index for adding new values to THIS IRP Record
	PermValueAdd

	// PermValueRemove - Permission index for removing existing values from THIS IRP Record
	PermValueRemove

	// PermValueModify - Permission index for modifying existing values from THIS IRP Record
	PermValueModify

	// PermDeleteIRP - Permission index for deleting THIS IRP Record
	PermDeleteIRP AdminPerm = iota + 2

	// PermCreateIRP - Permission index for creating a new IRP Record
	PermCreateIRP
)

func (AdminPerm) ToInt 

func (p AdminPerm) ToInt() int

type Attribute 

type Attribute struct {
	Name  string `yaml:"name" json:"name"`
	Value string `yaml:"value" json:"value"`
}

Attribute - attributes for site information

func NewAttribute 

func NewAttribute(name, value string) (sa Attribute)

NewAttribute - creates a new instance of attribute

type AuthResponse 

type AuthResponse struct {
	Error               string `json:"error,omitempty"`
	Authenticated       bool   `json:"authenticated"`
	ServerAuthenticated bool   `json:"-"`
	Nonce               string `json:"nonce"`
	SessionID           string `json:"sessionId"`
	ServerAlg           string `json:"serverAlg,omitempty"`
	ServerSignature     string `json:"serverSignature,omitempty"`
	TTL                 int64  `json:"ttl,omitempty"`
	LastAccess          int64  `json:"-"`
	// contains filtered or unexported fields
}

AuthResponse - response from LHS for authentication

func AuthCR added in v1.3.0 

func AuthCR(server Server, authIndex int, authIRP string, j *JWK) (authResponse *AuthResponse, err error)

AuthCR - performs IRP Authentication using challenge-response and returns an authentication response

func AuthCert added in v1.3.0 

func AuthCert(server Server, authIndex int, authIRP string, j *JWK, certDuration time.Duration) (authResponse *AuthResponse, err error)

AuthCert - performs IRP Authentication using TLS cert and returns an authentication response

func UnauthenticatedResolve added in v1.3.0 

func UnauthenticatedResolve(server Server) (authResponse *AuthResponse, err error)

UnauthenticatedResolve - returns an authentication response crafted for an unauthenticated resolve request. **DO NOT USE THIS FOR ADMIN REQUESTS**

type Config 

type Config struct {
	Directory           string `yaml:"-"`
	ServerInfoDirectory string `yaml:"-"`
	//LibraryDirectory    string    `yaml:"-"`
	GHR []*Server `yaml:"-"`
}

Config - configuration information to this IRP Bridge

type Digest 

type Digest struct {
	Index  int    `json:"index"`
	Digest string `json:"digest"`
}

Digest - stores a digest of a IRP index

type IRP 

type IRP struct {
	ResponseCode int      `json:"responseCode,omitempty"`
	Handle       string   `json:"handle,omitempty"`
	Values       Values   `json:"values,omitempty"`
	Message      string   `json:"message,omitempty"`
	TotalCount   string   `json:"totalCount,omitempty"`
	Prefixes     []string `json:"prefixes,omitempty"`
	Prefix       string   `json:"prefix,omitempty"`
	Handles      []string `json:"handles,omitempty"`
}

IRP - IRP Record structure for IRP HTTP REST

func Create 

func Create(authResponse *AuthResponse, handleid string, irpValues Values, overwrite bool) (irpResponse IRP)

Create - creates a IRP ID with given values

func Delete 

func Delete(authResponse *AuthResponse, handleid string) (irpResponse IRP)

Delete - deletes a given IRP Record

func ListHandles added in v1.3.1 

func ListHandles(authResponse *AuthResponse, prefix string) (irpResponse IRP)

ListHandles - returns list of handles registered in an IRP instance for a given prefix

func ListPrefixes added in v1.3.1 

func ListPrefixes(authResponse *AuthResponse) (irpResponse IRP)

ListPrefixes - returns list of prefixes homed in an IRP instance

func Remove 

func Remove(authResponse *AuthResponse, handleid string, indexes []int) (irpResponse IRP)

Remove - removes given indexes from a IRP Record

func Resolve 

func Resolve(authResponse *AuthResponse, handleid string, param Parameter) (irpResponse IRP)

Resolve - resolves a given IRP ID using authentication

func Update 

func Update(authResponse *AuthResponse, handleid string, irpValues Values, overwrite bool) (irpResponse IRP)

Update - updates a IRP ID with given values

func (*IRP) GetByIndex 

func (irp *IRP) GetByIndex(irpIndex int) (value Value)

GetByIndex - returns an IRP Value by index

func (*IRP) GetByType 

func (irp *IRP) GetByType(irpType string) (values []Value)

GetByType - returns a list of IRP Values by type

type Interface 

type Interface struct {
	Admin    bool   `yaml:"admin" json:"admin"`
	Query    bool   `yaml:"query" json:"query"`
	Port     int    `yaml:"port" json:"port"`
	Protocol string `yaml:"protocol" json:"protocol"`
}

Interface - interface information for the site server

func NewInterface 

func NewInterface(protocol string, port int, admin, query bool) (i *Interface)

NewInterface - creates a new instance of site interface

type JWK added in v1.1.0 

type JWK key.JWK // create a new type based on `key.JWK` for reference in this library

func NewJWK 

func NewJWK(k interface{}) (j *JWK, err error)

NewJWK - creates a new `JWK` istance from a given key

func ParseJWK added in v1.3.5 

func ParseJWK(jsonBytes []byte) (j *JWK, err error)

ParseJWK - parse a JSON string in bytes to a JWK instance

func ParsePEM added in v1.3.5 

func ParsePEM(pemBytes, passwd []byte) (j *JWK, err error)

ParsePEM - parse PEM bytes to a JWK instance

type Parameter 

type Parameter struct {
	Indexes []int
	Types   []string
	// contains filtered or unexported fields
}

Parameter - optional parameters to send to the Connect function to not clutter up the input variables

type Server 

type Server struct {
	Address    string      `json:"address"`
	Interfaces []Interface `yaml:"interfaces" json:"interfaces"`
	ServerID   int         `yaml:"serverId,omitempty" json:"serverId,omitempty"`
	PublicKey  struct {
		Format string `yaml:"format,omitempty" json:"format,omitempty"`
		Value  *JWK   `yaml:"value,omitempty" json:"value,omitempty"`
	} `yaml:"publicKey,omitempty" json:"publicKey,omitempty"`
	// contains filtered or unexported fields
}

Server - server information stored in the site information

func GetPrefixSite 

func GetPrefixSite(handleid string, srvType int8, tlsConfig *tls.Config) (server Server, err error)

GetPrefixSite - get where this prefix lives from the MPA

func NewServer 

func NewServer(serverId int, address string, i *Interface) (s *Server)

func (*Server) AddInterface 

func (s *Server) AddInterface(i *Interface)

AddInterface - adds a new interface for this server

func (*Server) AddPubKey 

func (s *Server) AddPubKey(k *JWK)

AddPubKey - adds public key for this site information

func (*Server) GetHTTP 

func (s *Server) GetHTTP() (i *Interface)

GetHTTP - returns the HTTP interface information

func (*Server) IsIPv4 

func (s *Server) IsIPv4() bool

IsIPv4 - check if the string is an IP version 4 by checking number of colon

func (*Server) IsIPv6 

func (s *Server) IsIPv6() bool

IsIPv6 - check if the string is an IP version 6 by checking number of colon

type SiteInfo 

type SiteInfo struct {
	Attributes      []Attribute `yaml:"attributes" json:"attributes,omitempty"`
	MultiPrimary    bool        `yaml:"multiPrimary,omitempty" json:"multiPrimary"`
	PrimarySite     bool        `yaml:"primarySite,omitempty" json:"primarySite"`
	ProtocolVersion string      `yaml:"protocolVersion,omitempty" json:"protocolVersion"`
	SerialNumber    int         `yaml:"serialNumber,omitempty" json:"serialNumber"`
	Servers         []Server    `yaml:"servers,omitempty" json:"servers,omitempty"`
	Version         int         `yaml:"version,omitempty" json:"version,omitempty"`
	TTL             int64       `yaml:"ttl" json:"ttl"`                // we keep TTL here to be used by the library or applications
	LastUpdate      string      `yaml:"lastupdate,omitempty" json:"-"` // used by library to know if the cached site information is still valid
	Registry        string      `yaml:"registry,omitempty" json:"-"`   // keep the information about the server that responded to the query we used
}

SiteInfo - Handle data for sites

func NewSiteInfo 

func NewSiteInfo() (siteInfo *SiteInfo)

NewSiteInfo - creates a new instance of site information

func (*SiteInfo) AddServer 

func (si *SiteInfo) AddServer(server *Server)

AddServer - add new server instance to this siteinfo

func (*SiteInfo) GetServers 

func (si *SiteInfo) GetServers() (servers []Server)

GetServers - returns list of servers configured for this prefix

type VList 

type VList struct {
	Index  int `json:"index"`
	Values []struct {
		IRP   string `json:"handle"`
		Index int    `json:"index"`
	} `json:"values"`
	TTL       int64 `json:"ttl"`        // optional. default value will be used if this is not given
	AdminOnly bool  `json:"admin_only"` // optional. sane public permissions will be set if not given
}

VList - format for IRP Request storing HS_VLIST information

type VListValue 

type VListValue struct {
	Handle string `json:"handle"`
	Index  int    `json:"index"`
}

VListValue - stores VList values

type VListValues 

type VListValues []VListValue

VListValues - array of VList values for storage in an Handle Record

func NewVList 

func NewVList() (vListValues *VListValues)

NewVList - creates a new instance of `VListValues`

func (*VListValues) Add 

func (vListValues *VListValues) Add(handleid string, index int) (err error)

Add - adds a puid and index to the `VListValues` instance

func (*VListValues) Remove 

func (vListValues *VListValues) Remove(handleid string, index int) (err error)

Remove - removes a puid and index from the `VListValues` instance

type Value 

type Value struct {
	Index int    `json:"index"`
	Type  string `json:"type"`

	Data struct {
		Format string      `json:"format"`
		Value  interface{} `json:"value"`
	} `json:"data"`

	Permissions string `json:"permissions,omitempty"`
	TTL         int64  `json:"ttl"`
	Timestamp   string `json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Value - IRP value structure

func CreateDigest 

func CreateDigest(handleid string, index int, expires int64, irpValues Values, authIndex int, authIRP string, j *JWK) (dgValue *Value, err error)

CreateDigest - creates digests of given IRP values

func (*Value) HasPermission added in v1.1.7 

func (value *Value) HasPermission(permission ValuePerm) (hasPermission bool)

HasPermission - checks if value has requested permission

func (*Value) OK 

func (value *Value) OK() (ok bool)

OK - checks to make sure a value is ok to be used

func (*Value) SetPermPrivateRW 

func (value *Value) SetPermPrivateRW()

SetPermPrivateRW - sets permission for a IRP Value for admin only

func (*Value) SetPermPublicRead 

func (value *Value) SetPermPublicRead(hasPerm bool)

SetPermPublicRead - sets permission for a IRP Value for public read

type ValuePerm 

type ValuePerm int

type Values 

type Values []Value

Values - array of values for a IRP Request

func (*Values) Add 

func (irpValues *Values) Add(index int, irpType string, irpFormat string, irpValue interface{}, ttl int64, isPrivate bool)

Add - generic add value to an IRP Request

func (*Values) AddAdmin 

func (irpValues *Values) AddAdmin(index int, adminIndex int, adminID string, ttl int64, isPrivate bool) (err error)

AddAdmin - adds an admin value to an IRP Request Values

func (*Values) AddBase64 

func (irpValues *Values) AddBase64(index int, irpType string, input []byte, ttl int64, isPrivate bool)

AddBase64 - adds a base64 (standard encoding) value to an IRP Request Values

func (*Values) AddKey 

func (irpValues *Values) AddKey(index int, irpType string, j *JWK, ttl int64, isPrivate bool)

AddKey - adds a JWK key value to an IRP Request Values

func (*Values) AddSite 

func (irpValues *Values) AddSite(index int, irpType string, si *SiteInfo, ttl int64, isPrivate bool)

AddSite - adds a site information value to an IRP Request Values

func (*Values) AddString 

func (irpValues *Values) AddString(index int, irpType string, str string, ttl int64, isPrivate bool)

AddString - adds a string value to an IRP Request Values

func (*Values) AddVList 

func (irpValues *Values) AddVList(index int, irpValue *VListValues, ttl int64, isPrivate bool)

AddVList - adds a VLIST value to an IRP Request Values

func (*Values) AddValue 

func (irpValues *Values) AddValue(value *Value)

AddValue - adds a value to an IRP Request

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.