dispatcher

Documentation

Index

• type HookServerClientManager
  • func NewClientManager() *HookServerClientManager
  • func (cm *HookServerClientManager) RuntimeHookServerClient(serverPath HookServerPath) (*RuntimeHookClient, error)
• type HookServerPath
• type RuntimeHookClient
• type RuntimeHookDispatcher
  • func NewRuntimeDispatcher() *RuntimeHookDispatcher
  • func (rd *RuntimeHookDispatcher) Dispatch(ctx context.Context, runtimeRequestPath config.RuntimeRequestPath, ...) (interface{}, error)

Types

type HookServerClientManager

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

func NewClientManager

func NewClientManager() *HookServerClientManager

NewClientManager TODO: garbage client gc

func (*HookServerClientManager) RuntimeHookServerClient

func (cm *HookServerClientManager) RuntimeHookServerClient(serverPath HookServerPath) (*RuntimeHookClient, error)

type HookServerPath

type HookServerPath struct {
	Path string
	Port int64
}

type RuntimeHookClient

type RuntimeHookClient struct {
	SockPath string
	v1alpha1.RuntimeHookServiceClient
}

type RuntimeHookDispatcher

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

RuntimeHookDispatcher dispatches hook request to RuntimeHookServer(e.g. koordlet)

func NewRuntimeDispatcher

func NewRuntimeDispatcher() *RuntimeHookDispatcher

func (*RuntimeHookDispatcher) Dispatch

func (rd *RuntimeHookDispatcher) Dispatch(ctx context.Context, runtimeRequestPath config.RuntimeRequestPath,
	stage config.RuntimeHookStage, request interface{}) (interface{}, error)