shared

Documentation

Index

• func BuildRoutes(service interface{}, apiPrefix string) ([]*endly.Route, error)
• func BuildRoutesWithPrefix(service interface{}, apiPrefix, actionPrefix string) ([]*endly.Route, error)
• func Init(context *endly.Context, rawRequest map[string]interface{}) error
• func IsNotFound(candidate interface{}) bool
• func LookupAPIVersion(kind string) (string, error)
• func LookupAPIVersions(kind string) ([]string, error)
• func MatchedMetaTypes(kinds ...string) []string
• func MetaTypes() []string
• func Register(adapter ContractAdapter)
• func ResourceListToInterface(target, source interface{}) error
• func TextToQuantity(target, source interface{}) error
• func ToSelector(selectorMap map[string]string) string
• type ContractAdapter
  • func Get(id string) (ContractAdapter, bool)
• type CtxClient
  • func GetCtxClient(context *endly.Context) (*CtxClient, error)
  • func (c *CtxClient) Clientset() (*kubernetes.Clientset, error)
  • func (c *CtxClient) ConfigPath() string
  • func (c *CtxClient) EndpointIP() string
• type KindMethodMeta
  • func NewKindMethodMeta(id string) *KindMethodMeta
• type KindOperations
  • func Lookup(apiVersion, kind string) (*KindOperations, error)
  • func (r *KindOperations) Lookup(method string) (ContractAdapter, error)
  • func (r *KindOperations) NewRequest(method string, requestData interface{}) (interface{}, error)
• type NotFound
  • func (f *NotFound) Error() string
• type OutputEvent
  • func NewOutputEvent(message string, tag string, value interface{}) *OutputEvent
  • func (e *OutputEvent) Messages() []*msg.Message

Functions

func BuildRoutes

func BuildRoutes(service interface{}, apiPrefix string) ([]*endly.Route, error)

BuildRoutes build routes

func BuildRoutesWithPrefix

func BuildRoutesWithPrefix(service interface{}, apiPrefix, actionPrefix string) ([]*endly.Route, error)

func Init

func Init(context *endly.Context, rawRequest map[string]interface{}) error

Init get or creates context, client

func IsNotFound

func IsNotFound(candidate interface{}) bool

IsNotFound returns true if error is not found

func LookupAPIVersion

func LookupAPIVersion(kind string) (string, error)

func LookupAPIVersions

func LookupAPIVersions(kind string) ([]string, error)

func MatchedMetaTypes

func MatchedMetaTypes(kinds ...string) []string

MatchedMetaTypes returns matched kinds

func MetaTypes

func MetaTypes() []string

MetaTypes returns meta types

func Register

func Register(adapter ContractAdapter)

Register register an adapter

func ResourceListToInterface

func ResourceListToInterface(target, source interface{}) error

func TextToQuantity

func TextToQuantity(target, source interface{}) error

func ToSelector

func ToSelector(selectorMap map[string]string) string

ToSelector returns selector

Types

type ContractAdapter

type ContractAdapter interface {
	SetService(service interface{}) error
	Call() (result interface{}, err error)
	GetId() string
}

ContractAdapter represents a contract adapter

func Get

func Get(id string) (ContractAdapter, bool)

Get returns contract adapter

type CtxClient

type CtxClient struct {
	CredConfig *cred.Config

	Namespace   string
	ResetConfig *rest.Config

	RawRequest map[string]interface{}
	// contains filtered or unexported fields
}

CtxClient represents generic google cloud service client

func GetCtxClient

func GetCtxClient(context *endly.Context) (*CtxClient, error)

GetCtxClient get or creates a new kubernetess client.

func (*CtxClient) Clientset

func (c *CtxClient) Clientset() (*kubernetes.Clientset, error)

func (*CtxClient) ConfigPath

func (c *CtxClient) ConfigPath() string

func (*CtxClient) EndpointIP

func (c *CtxClient) EndpointIP() string

type KindMethodMeta

type KindMethodMeta struct {
	metav1.TypeMeta
	Method string
}

func NewKindMethodMeta

func NewKindMethodMeta(id string) *KindMethodMeta

type KindOperations

type KindOperations struct {
	metav1.TypeMeta
	Methods map[string]ContractAdapter
}

func Lookup

func Lookup(apiVersion, kind string) (*KindOperations, error)

Lookup returns KindOperations with all defined operations or error

func (*KindOperations) Lookup

func (r *KindOperations) Lookup(method string) (ContractAdapter, error)

func (*KindOperations) NewRequest

func (r *KindOperations) NewRequest(method string, requestData interface{}) (interface{}, error)

type NotFound

type NotFound struct {
	Message string
}

NotFound represents not found error

func (*NotFound) Error

func (f *NotFound) Error() string

type OutputEvent

type OutputEvent struct {
	Message string
	Tag     string
	Value   interface{}
}

func NewOutputEvent

func NewOutputEvent(message string, tag string, value interface{}) *OutputEvent

func (*OutputEvent) Messages

func (e *OutputEvent) Messages() []*msg.Message