kubefox

type ComponentSvc struct {
	// contains filtered or unexported fields
}

type ContextKey string

type CustomizeResponse struct {
	RelatedResourceRules []*RelatedResourceRule `json:"relatedResources,omitempty"`
}

type DataEvent interface {
	Event

	GetData() *grpc.Data

	ChildEvent() DataEvent
	ChildErrorEvent(error) DataEvent

	SetParent(Event)
	SetParentId(string)

	SetSource(component.Component, string)
	SetTarget(component.Component)

	SetContext(*grpc.EventContext)

	GetFabric() *grpc.Fabric
	SetFabric(*grpc.Fabric)

	SetSpan(*grpc.Span)
	UpdateSpan(trace.Span)

	SetToken(jwt.Token)
	SetValue(string, string)
	SetValueNumber(string, float64)

	HTTPData() HTTPDataEvent
	KubeData() KubeDataEvent

	SetError(error)
	GetError() error
	GetErrorMsg() string
}

type Entrypoint func(Kit) error

type EntrypointMatcher struct {
	// contains filtered or unexported fields
}

type Event interface {
	GetId() string
	GetParentId() string

	GetType() string
	SetType(string)

	GetToken() *grpc.Token
	GetSpan() *grpc.Span
	GetTraceId() string
	GetSource() component.Component
	GetTarget() component.Component
	GetContext() *grpc.EventContext

	GetArg(string) string
	GetArgVar(string) *common.Var
	SetArg(string, string)
	SetArgNumber(string, float64)
	GetValue(string) string
	GetValueVar(string) *common.Var

	GetContentType() string
	SetContentType(string)
	GetContent() []byte
	SetContent([]byte)
	Marshal(any) error
	Unmarshal(any) error
	UnmarshalStrict(any) error

	HTTP() HTTPEvent
	Kube() KubeEvent
}

type EventMatcher struct {
	// contains filtered or unexported fields
}

type HTTPDataEvent interface {
	DataEvent
	HTTPEvent

	ParseRequest(*http.Request) error
	ParseResponse(*http.Response) error

	GetHTTPRequest(context.Context) (*http.Request, error)
	GetHTTPResponse() *http.Response

	SetURL(*url.URL)
	SetURLString(string) error
}

type HTTPEvent interface {
	Event

	GetURL() *url.URL
	GetURLString() string
	GetPath() string

	GetStatus() string
	SetStatus(v string)
	GetStatusCode() int
	SetStatusCode(v int)
	GetMethod() string
	SetMethod(method string)

	GetHeaderKeys() []string
	GetHeader(string) string
	GetHeaderValues(string) []string
	AddHeader(string, string)
	SetHeader(string, string)
	GetHTTPHeader() http.Header
	SetHTTPHeader(http.Header)
}

type Hook uint8

type Kit interface {
	Env(string) *common.Var

	Request() Event
	Response() Event

	Component(string) *ComponentSvc

	// Organization() string
	Platform() string
	Namespace() string
	DevMode() bool

	Ctx() context.Context
	Log() *logger.Log
}

type KitBroker interface {
	InvokeTarget(DataEvent) (DataEvent, error)
}

type KitRoundTripper struct{}

type KitSvc interface {
	Start()
	Http(string, Entrypoint)
	Kubernetes(string, Entrypoint)
	MatchEvent(string, Entrypoint)
	DefaultEntrypoint(Entrypoint)

	// Organization() string
	Platform() string
	Namespace() string
	DevMode() bool

	Fatal(err error)
	Log() *logger.Log
}

type KubeDataEvent interface {
	DataEvent
	KubeEvent
}

type KubeEvent interface {
	Event

	GetHook() Hook
	GetTargetKind() string
}

type KubeResponse struct {
	Attachments []runtime.Object `json:"attachments"`
	Status      any              `json:"status,omitempty"`
}

type ObjectStub struct {
	Kind string `json:"kind"`
}

type RelatedResourceRule struct {
	APIVersion    string                `json:"apiVersion"`
	Resource      string                `json:"resource"`
	Namespace     string                `json:"namespace,omitempty"`
	Names         []string              `json:"names,omitempty"`
	LabelSelector *metav1.LabelSelector `json:"labelSelector,omitempty"`
}

type RequestStub struct {
	Object *ObjectStub `json:"object"` // for sync requests
	Parent *ObjectStub `json:"parent"` // for customize requests
}