akasar

Documentation

Index

• Variables
• type AkasaLet
• type Info
• type RemoteAkasaLet
  • func NewRemoteAkasaLet(ctx context.Context, regs []*codegen.Registration, bootstrap runtime.Bootstrap, ...) (*RemoteAkasaLet, error)
  • func (a *RemoteAkasaLet) Args() *protos.AkasaletArgs
  • func (a *RemoteAkasaLet) GetHealth(ctx context.Context, request *protos.GetHealthRequest) (*protos.GetHealthReply, error)
  • func (a *RemoteAkasaLet) GetImpl(t reflect.Type) (any, error)
  • func (a *RemoteAkasaLet) GetLoad(ctx context.Context, request *protos.GetLoadRequest) (*protos.GetLoadReply, error)
  • func (a *RemoteAkasaLet) GetMetrics(ctx context.Context, request *protos.GetMetricsRequest) (*protos.GetMetricsReply, error)
  • func (a *RemoteAkasaLet) GetProfile(ctx context.Context, request *protos.GetProfileRequest) (*protos.GetProfileReply, error)
  • func (a *RemoteAkasaLet) InitAkasalet(ctx context.Context, req *protos.InitAkasaletRequest) (*protos.InitAkasaletReply, error)
  • func (a *RemoteAkasaLet) UpdateComponents(ctx context.Context, req *protos.UpdateComponentsRequest) (*protos.UpdateComponentsReply, error)
  • func (a *RemoteAkasaLet) UpdateRoutingInfo(ctx context.Context, req *protos.UpdateRoutingInfoRequest) (reply *protos.UpdateRoutingInfoReply, err error)
  • func (a *RemoteAkasaLet) Wait() error
• type RemoteAkasaletOptions
• type SingleAkasalet
  • func NewSingleAkasaLet(ctx context.Context, regs []*codegen.Registration, opts SingleAkasaletOptions) (*SingleAkasalet, error)
  • func (l *SingleAkasalet) GetIface(t reflect.Type) (any, error)
  • func (l *SingleAkasalet) GetImpl(t reflect.Type) (any, error)
  • func (l *SingleAkasalet) ServeStatus(ctx context.Context) error
• type SingleAkasaletOptions

Variables

var (
	SetLogger     func(impl any, logger *slog.Logger) error
	SetAkasarInfo func(impl any, info *Info) error
	FillRefs      func(impl any, get func(t reflect.Type) (any, error)) error
	FillListeners func(impl any, get func(string) (net.Listener, string, error)) error
)

Types

type AkasaLet

type AkasaLet interface {
	// GetIface 根据接口类型获取组件的handle
	GetIface(t reflect.Type) (any, error)

	// GetImpl 根据提供的类型获取组件的实现
	GetImpl(t reflect.Type) (any, error)
}

type Info

type Info struct {
	DeploymentID string
}

type RemoteAkasaLet

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

func NewRemoteAkasaLet

func NewRemoteAkasaLet(ctx context.Context, regs []*codegen.Registration, bootstrap runtime.Bootstrap, opts RemoteAkasaletOptions) (*RemoteAkasaLet, error)

func (*RemoteAkasaLet) Args

func (a *RemoteAkasaLet) Args() *protos.AkasaletArgs

func (*RemoteAkasaLet) GetHealth

func (a *RemoteAkasaLet) GetHealth(ctx context.Context, request *protos.GetHealthRequest) (*protos.GetHealthReply, error)

func (*RemoteAkasaLet) GetImpl

func (a *RemoteAkasaLet) GetImpl(t reflect.Type) (any, error)

func (*RemoteAkasaLet) GetLoad

func (a *RemoteAkasaLet) GetLoad(ctx context.Context, request *protos.GetLoadRequest) (*protos.GetLoadReply, error)

func (*RemoteAkasaLet) GetMetrics

func (a *RemoteAkasaLet) GetMetrics(ctx context.Context, request *protos.GetMetricsRequest) (*protos.GetMetricsReply, error)

func (*RemoteAkasaLet) GetProfile

func (a *RemoteAkasaLet) GetProfile(ctx context.Context, request *protos.GetProfileRequest) (*protos.GetProfileReply, error)

func (*RemoteAkasaLet) InitAkasalet

func (a *RemoteAkasaLet) InitAkasalet(ctx context.Context, req *protos.InitAkasaletRequest) (*protos.InitAkasaletReply, error)

func (*RemoteAkasaLet) UpdateComponents

func (a *RemoteAkasaLet) UpdateComponents(ctx context.Context, req *protos.UpdateComponentsRequest) (*protos.UpdateComponentsReply, error)

func (*RemoteAkasaLet) UpdateRoutingInfo

func (a *RemoteAkasaLet) UpdateRoutingInfo(ctx context.Context, req *protos.UpdateRoutingInfoRequest) (reply *protos.UpdateRoutingInfoReply, err error)

func (*RemoteAkasaLet) Wait

func (a *RemoteAkasaLet) Wait() error

type RemoteAkasaletOptions

type RemoteAkasaletOptions struct {
	Fakes         map[reflect.Type]any
	InjectRetries int
}

type SingleAkasalet

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

func NewSingleAkasaLet

func NewSingleAkasaLet(ctx context.Context, regs []*codegen.Registration, opts SingleAkasaletOptions) (*SingleAkasalet, error)

func (*SingleAkasalet) GetIface

func (l *SingleAkasalet) GetIface(t reflect.Type) (any, error)

func (*SingleAkasalet) GetImpl

func (l *SingleAkasalet) GetImpl(t reflect.Type) (any, error)

func (*SingleAkasalet) ServeStatus

func (l *SingleAkasalet) ServeStatus(ctx context.Context) error

type SingleAkasaletOptions

type SingleAkasaletOptions struct {
	ConfigFilename string // config filename
	Config         string //config contents
	Quiet          bool
	Fakes          map[reflect.Type]any
}