shared

package

v0.30.2 Latest Latest Go to latest Published: Feb 6, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

Init get or creates context, client

func LookupAPIVersion(kind string) (string, error)

func Register(adapter ContractAdapter)

Register register an adapter

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

ContractAdapter represents a contract adapter

func Get(id string) (ContractAdapter, bool)

Get returns contract adapter

type CtxClient struct {
	CredConfig *cred.Config

	Namespace string

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

CtxClient represents generic google cloud service client

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

GetCtxClient get or creates a new kubernetess client.

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

func (c *CtxClient) ConfigPath() string

type KindMethodMeta struct {
	metav1.TypeMeta
	Method string
}

func NewKindMethodMeta(id string) *KindMethodMeta

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

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

Lookup returns KindOperations with all defined operations or error

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

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

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

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