common

package

Go to main page

Versions in this module

v1

v1.5.0

Jul 12, 2017

v1.1.0

Jun 6, 2017

v1.0.1

Mar 18, 2017

v1.0.0

Mar 18, 2017

Changes in this version

+ const ContextKeyUser

+ const DefaultRestRetryStrategy

+ const DefaultTestConfigFile

+ const FullConfigKey

+ const PasswordKey

+ const RestRetryStrategyExponential

+ const RestRetryStrategyFibonacci

+ const RoleAdmin

+ const RoleService

+ const RoleTenant

+ const ServiceNameRoot

+ const ServiceNameTest

+ const StoreTypeEtcd

+ const StoreTypeMysql

+ const StoreTypeSqlite3

+ const UsernameKey

+ var IDRingCannotReclaimZeroError = NewError("Cannot reclaim ID 0")

+ var IDRingOverflowError = NewError("No more available IDs")

+ var SupportedStoreTypes []string

+ func ExpectHttpError(c *check.C, err error, code int)

+ func GetCaller() string

+ func GetCaller2(up int) string

+ func GetMockDbName(svc string) string

+ func GetPasswd() (string, error)

+ func ReadKeyFile(filename string) (*pem.Block, error)

+ func SimpleOverwriteSchema(svc Service, rootURL string, cred *Credential) error

+ func SqlNullStringUuid() sql.NullString

type Api

+ RestRetryStrategy string

+ type Attribute struct

+ AttributeKey string

+ AttributeValue string

+ Id int

type AuthMiddleware

+ AllowedURLs []string

+ func NewAuthMiddleware(service Service, config ServiceConfig, client *RestClient) (AuthMiddleware, error)

+ func (am AuthMiddleware) Keyfunc(*jwt.Token) (interface{}, error)

+ type AuthTokenMessage struct

+ PublicKey []byte

+ Token string

+ type AuthZChecker func(ctx RestContext) bool

+ type CliState struct

+ ConfigFile *string

+ CreateSchema *bool

+ OverwriteSchema *bool

+ RootURL *string

+ func NewCliState() *CliState

+ func (c *CliState) StartService(svc Service) (*RestServiceInfo, error)

+ func (cs *CliState) Init() error

type Credential

+ func NewCredential(flagSet *flag.FlagSet) *Credential

+ func NewCredentialCobra(cmd *cli.Command) *Credential

+ func (c *Credential) Initialize() error

+ func (c *Credential) String() string

type HttpError

+ func NewError403() HttpError

+ type IDRing struct

+ Ranges []Range

+ func DecodeIDRing(data []byte) (IDRing, error)

+ func NewIDRing() IDRing

+ func (idRing *IDRing) GetID() (uint64, error)

+ func (idRing *IDRing) ReclaimID(id uint64) error

+ func (ir IDRing) Encode() ([]byte, error)

+ func (ir IDRing) String() string

+ type IPAMEndpoint struct

+ EffectiveNetworkID uint64

+ HostId string

+ Id uint64

+ InUse bool

+ Ip string

+ Name string

+ NetworkID uint64

+ RequestToken sql.NullString

+ SegmentID string

+ TenantID string

+ type IPtablesRule struct

+ Body string

+ ID uint64

+ State string

type Policy

+ Ingress []RomanaIngress

+ type Range struct

+ Max uint64

+ Min uint64

+ func (irr Range) String() string

type RestClient

+ func (rc *RestClient) Authenticate() error

+ func (rc *RestClient) GetPublicKey() (*rsa.PublicKey, error)

type RestClientConfig

+ RetryStrategy string

type RestContext

+ User User

type RestServiceInfo

+ func SimpleStartService(svc Service, rootURL string, cred *Credential) (*RestServiceInfo, error)

type Role

+ Id int

+ type RomanaIngress struct

+ Peers []Endpoint

+ Rules []Rule

+ type RomanaTestSuite struct

+ Config Config

+ ConfigFile string

+ func (rts *RomanaTestSuite) CleanUp()

+ func (rts *RomanaTestSuite) GetMockSqliteFile(svc string) string

+ func (rts *RomanaTestSuite) MockConfig(romanaConfigFile string) error

type Route

+ AuthZChecker AuthZChecker

+ type Segment struct

+ ExternalID string

+ ID uint64

+ Name string

+ NetworkID uint64

+ TenantID uint64

type Service

+ CreateSchema func(overwrite bool) error

type ServiceConfig

+ func GetTestServiceConfig() *ServiceConfig

type Store

+ AddHost func(dc Datacenter, host *Host) error

+ DeleteHost func(hostID uint64) error

+ GetHost func(hostID uint64) (Host, error)

+ ListHosts func() ([]Host, error)

type StoreConfig

+ func MakeStoreConfig(configMap map[string]interface{}) (StoreConfig, error)

+ type Tenant struct

+ ExternalID string

+ ID uint64

+ Name string

+ NetworkID uint64

+ Segments []Segment

+ type User struct

+ Attributes []Attribute

+ Password string

+ Roles []Role

+ UserId int

+ Username string

+ var DefaultAdminUser User

v1.0.0-rc.3

Mar 18, 2017

v1.0.0-rc.2

Mar 16, 2017

v1.0.0-rc.1

Mar 8, 2017

v0

v0.9.3

Sep 8, 2016

Changes in this version

+ const MySQLUniqueConstraintErrorCode

+ var SupportedContentTypes = []string

+ var SupportedContentTypesMessage = struct{ ... }

+ func DbToHttpError(err error) error

+ func In(needle string, haystack []string) bool

+ func InitMap(keyValuePairs ...KeyValue) map[string]interface

+ func MkMap() map[string]interface

+ func MkMapStr() map[string]string

type Endpoint

+ Dest string

+ type KeyValue struct

+ Key string

+ Value interface{}

+ func KV(key string, value interface{}) KeyValue

type StoreConfig

+ func (sc StoreConfig) String() string

v0.9.2

Jul 5, 2016

v0.9.1

Jun 23, 2016

Changes in this version

+ const FindAll

+ const FindExactlyOne

+ const FindFirst

+ const FindLast

+ func IsZeroValue(val interface{}) bool

type DbStore

+ func (dbStore *DbStore) Find(query url.Values, entities interface{}, flag FindFlag) (interface{}, error)

type Endpoint

+ SegmentName string

+ TenantName string

+ type FindFlag string

+ type Host struct

+ AgentPort uint64

+ ID uint64

+ Ip string

+ Links Links

+ Name string

+ RomanaIp string

type RestClient

+ func (rc *RestClient) Find(entity interface{}, flag FindFlag) error

type Routes

+ func CreateFindRoutes(entities interface{}, store Store) Routes

type Store

+ Find func(query url.Values, entities interface{}, flag FindFlag) (interface{}, error)

v0.9.0

Jun 8, 2016

Changes in this version

+ const MaxIcmpType

+ const MaxPortNumber

+ const PolicyDirectionEgress

+ const PolicyDirectionIngress

+ const ServiceRoot

+ const StatusUnprocessableEntity

+ const Wildcard

+ func CleanURL(url string) (string, error)

+ func GetDbErrors(db *gorm.DB) error

+ func String(i interface{}) string

type Datacenter

+ func (dc Datacenter) String() string

+ type Endpoint struct

+ Any string

+ Cidr net.IPNet

+ CidrStr string

+ Peer string

+ SegmentExternalID string

+ SegmentID uint64

+ SegmentNetworkID *uint64

+ TenantExternalID string

+ TenantID uint64

+ TenantNetworkID *uint64

+ func (e Endpoint) String() string

+ type ExecErrorDetails struct

+ Error string

type HttpError

+ Details interface{}

+ ResourceID string

+ ResourceType string

+ func NewErrorConflict(details interface{}) HttpError

+ func NewHttpError(code int, details interface{}) HttpError

+ func NewUnprocessableEntityError(details interface{}) HttpError

type MultiError

+ func (m *MultiError) GetErrors() []error

+ type Policy struct

+ AppliedTo []Endpoint

+ Datacenter Datacenter

+ Description string

+ Direction string

+ ExternalID string

+ ID uint64

+ Name string

+ Peers []Endpoint

+ Rules []Rule

+ func (p *Policy) Validate() error

+ func (p Policy) String() string

+ type PortRange [2]uint

+ func (p PortRange) String() string

+ type Raw struct

+ Body string

type RestClient

+ func (rc *RestClient) GetStatusCode() int

+ func (rc *RestClient) ListHosts() ([]HostMessage, error)

+ func (rc *RestClient) Put(url string, data interface{}, result interface{}) error

type RestClientConfig

+ RootURL string

+ type Rule struct

+ IcmpCode uint

+ IcmpType uint

+ IsStateful bool

+ PortRanges []PortRange

+ Ports []uint

+ Protocol string

+ func (r Rule) String() string

+ type Rules []Rule

+ type Tag struct

+ Key string

+ Value string

v0.8.3

May 18, 2016

v0.8.2

May 6, 2016

Changes in this version

+ const AuthPath

+ const ContextKeyRoles

+ const CredentialNone

+ const CredentialUsernamePassword

+ const PasswordEnvironmentVariable

+ func Environ() map[string]string

type Api

+ AuthPublic string

type AuthMiddleware

+ PublicKey []byte

type CommonConfig

+ Credential *Credential

+ PublicKey []byte

+ type Credential struct

+ Password string

+ Type CredentialType

+ Username string

+ func MakeCredentialFromCliArgs(username string, password string) *Credential

+ type CredentialType string

type HttpError

+ SeeAlso string

type RestClientConfig

+ Credential *Credential

type RestContext

+ Roles []Role

+ type Role interface

+ Name func() string

+ type TokenMessage struct

+ Token string

v0.8.1

Apr 1, 2016

v0.8.0

Apr 1, 2016

Changes in this version

+ const ContextKeyMarshaller

+ const ContextKeyOriginalBody

+ const ContextKeyQueryVariables

+ const ContextKeyUnmarshalledMap

+ const DefaultRestRetries

+ const DefaultRestTimeout

+ const ErrorNoValue

+ const HeaderContentType

+ const HookExecutableBodyArgument

+ const ReadWriteTimeoutDelta

+ const RequestTokenQueryParameter

+ const Starting

+ const TimeoutMessage

+ var ContentTypeMarshallers map[string]Marshaller = map[string]Marshaller

+ func BuildInfo() string

+ func IPv4ToInt(ip net.IP) uint64

+ func IntToIPv4(ipInt uint64) net.IP

+ func MakeMultiError(errors []error) error

+ func MockPortsInConfig(fname string) error

+ func PressEnterToContinue()

+ func ToBool(val string) (bool, error)

+ func WriteConfig(config Config, fname string) error

+ type Api struct

+ Hooks []Hook

+ Host string

+ Port uint64

+ RestRetries int

+ RestTestMode bool

+ RestTimeoutMillis int64

+ RootServiceUrl string

+ func (api Api) GetHostPort() string

+ type AuthBackend interface

+ type AuthMiddleware struct

+ Authenticator Authenticator

+ func NewAuth() *AuthMiddleware

+ func (am AuthMiddleware) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ type Authenticator interface

+ Authenticate func() Principal

+ type CommonConfig struct

+ Api *Api

+ type Config struct

+ Services map[string]ServiceConfig

+ func ReadConfig(fname string) (Config, error)

+ type Datacenter struct

+ Cidr string

+ EndpointBits uint

+ EndpointSpaceBits uint

+ Id uint64

+ IpVersion uint

+ Name string

+ PortBits uint

+ Prefix uint64

+ PrefixBits uint

+ SegmentBits uint

+ TenantBits uint

+ type DbStore struct

+ Config *StoreConfig

+ Db *gorm.DB

+ ServiceStore ServiceStore

+ func (dbStore *DbStore) Connect() error

+ func (dbStore *DbStore) CreateSchema(force bool) error

+ func (dbStore *DbStore) DbStore() DbStore

+ func (dbStore *DbStore) GetPasswordFunction() (string, error)

+ func (dbStore *DbStore) SetConfig(configMap map[string]interface{}) error

+ type Hook struct

+ Executable string

+ Method string

+ Output string

+ Pattern string

+ When string

+ type HostMessage struct

+ AgentPort int

+ Id string

+ Ip string

+ Links Links

+ Name string

+ RomanaIp string

+ type HttpError struct

+ Message string

+ StatusCode int

+ StatusText string

+ func NewError(code int, msg string) HttpError

+ func NewError400(message string, request string) HttpError

+ func NewError404(resourceType string, resourceId string) HttpError

+ func NewError500(err error) HttpError

+ func (e HttpError) Error() string

+ type IP struct

+ func MakeIPv4(a, b, c, d byte) IP

+ type IndexResponse struct

+ Links Links

+ ServiceName string

+ type LinkResponse struct

+ Href string

+ Rel string

+ type Links []LinkResponse

+ func (links Links) FindByRel(rel string) string

+ type MakeMessage func() interface

+ type Marshaller interface

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

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

+ type MultiError struct

+ func NewMultiError() *MultiError

+ func (m *MultiError) Error() string

+ func (m *MultiError) GetError() error

+ func (me MultiError) Add(err error)

+ type NegotiatorMiddleware struct

+ func NewNegotiator() *NegotiatorMiddleware

+ func (negotiator NegotiatorMiddleware) ServeHTTP(writer http.ResponseWriter, request *http.Request, next http.HandlerFunc)

+ type PlaceholderAuth struct

+ func (p PlaceholderAuth) Authenticate() Principal

+ type PortUpdateMessage struct

+ Port uint64

+ type Principal struct

+ Id string

+ Rights []string

+ type RestClient struct

+ func NewRestClient(url string, config RestClientConfig) (*RestClient, error)

+ func (rc *RestClient) Delete(url string, data interface{}, result interface{}) error

+ func (rc *RestClient) Get(url string, result interface{}) error

+ func (rc *RestClient) GetServiceConfig(rootServiceUrl string, svc Service) (*ServiceConfig, error)

+ func (rc *RestClient) GetServiceUrl(rootServiceUrl string, name string) (string, error)

+ func (rc *RestClient) NewUrl(dest string) error

+ func (rc *RestClient) Post(url string, data interface{}, result interface{}) error

+ type RestClientConfig struct

+ Retries int

+ TestMode bool

+ TimeoutMillis int64

+ func GetDefaultRestClientConfig() RestClientConfig

+ func GetRestClientConfig(config ServiceConfig) RestClientConfig

+ type RestContext struct

+ HookOutput string

+ PathVariables map[string]string

+ QueryVariables url.Values

+ RequestToken string

+ type RestHandler func(input interface{}, context RestContext) (interface{}, error)

+ type RestServiceInfo struct

+ Address string

+ Channel chan ServiceMessage

+ func InitializeService(service Service, config ServiceConfig) (*RestServiceInfo, error)

+ func ListenAndServe(svr *http.Server) (*RestServiceInfo, error)

+ func RunNegroni(n *negroni.Negroni, addr string, timeout time.Duration) (*RestServiceInfo, error)

+ type RomanaHandler struct

+ func (romanaHandler RomanaHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ type RootIndexResponse struct

+ Links Links

+ ServiceName string

+ Services []ServiceResponse

+ type Route struct

+ Handler RestHandler

+ Hook *Hook

+ MakeMessage MakeMessage

+ Method string

+ Pattern string

+ UseRequestToken bool

+ type Routes []Route

+ type Service interface

+ Initialize func() error

+ Name func() string

+ Routes func() Routes

+ SetConfig func(config ServiceConfig) error

+ type ServiceConfig struct

+ Common CommonConfig

+ ServiceSpecific map[string]interface{}

+ type ServiceMessage string

+ type ServiceResponse struct

+ Links Links

+ Name string

+ type ServiceStore interface

+ CreateSchemaPostProcess func() error

+ Entities func() []interface{}

+ type ServiceUtils struct

+ RequestIdToStatus map[string]interface{}

+ RequestIdToTimestamp map[string]int64

+ func (su ServiceUtils) AddStatus(requestId string, value interface{})

+ func (su ServiceUtils) GetStatus(resourceType string, requestId string) (interface{}, error)

+ type Store interface

+ Connect func() error

+ CreateSchema func(force bool) error

+ SetConfig func(configMap map[string]interface{}) error

+ type StoreConfig struct

+ Database string

+ Host string

+ Password string

+ Port uint64

+ Type string

+ Username string

+ type UnmarshallerMiddleware struct

+ func NewUnmarshaller() *UnmarshallerMiddleware

+ func (m UnmarshallerMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ type UnwrappedRestHandlerInput struct

+ Request *http.Request

+ ResponseWriter http.ResponseWriter

v0.6.4-1

Mar 8, 2016

Incompatible versions in this module

v2.0.2+incompatible

Feb 7, 2018

v2.0.1+incompatible

Dec 22, 2017

v2.0.0+incompatible

Nov 14, 2017

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