apprpc

Documentation

Index

• Constants
• func CapnprpcLogLevel2zerologLevel(logLevel capnprpc.LogLevel) (zerolog.Level, error)
• func NewAppServer() capnprpc.App_Server
• func ZerologLevel2capnprpcLogLevel(logLevel zerolog.Level) (capnprpc.LogLevel, error)
• type AppRPCClient
  • func NewAppClient(serviceId ServiceID) (*AppRPCClient, error)
  • func NewAppClientForAddr(serviceId ServiceID, networkAddr string) (*AppRPCClient, error)
  • func (a *AppRPCClient) Close()
  • func (a *AppRPCClient) Configs(ctx context.Context) capnprpc.App_configs_Results_Promise
  • func (a *AppRPCClient) Id(ctx context.Context) capnprpc.App_id_Results_Promise
  • func (a *AppRPCClient) Instance(ctx context.Context) capnprpc.App_instance_Results_Promise
  • func (a *AppRPCClient) Kill(ctx context.Context) error
  • func (a *AppRPCClient) LogLevel(ctx context.Context) capnprpc.App_logLevel_Results_Promise
  • func (a *AppRPCClient) ReleaseId(ctx context.Context) capnprpc.App_releaseId_Results_Promise
  • func (a *AppRPCClient) RpcService(ctx context.Context, id ServiceID) capnprpc.App_rpcService_Results_Promise
  • func (a *AppRPCClient) RpcServiceIds(ctx context.Context) capnprpc.App_rpcServiceIds_Results_Promise
  • func (a *AppRPCClient) Runtime(ctx context.Context) capnprpc.App_runtime_Results_Promise
  • func (a *AppRPCClient) Service(ctx context.Context, id ServiceID) capnprpc.App_service_Results_Promise
  • func (a *AppRPCClient) ServiceIds(ctx context.Context) capnprpc.App_serviceIds_Results_Promise
  • func (a *AppRPCClient) StartedOn(ctx context.Context) capnprpc.App_startedOn_Results_Promise

Constants

const (
	APP_RPC_SERVICE_ID = app.ServiceID(0xe49214fa20b35ba8)
)

Functions

func CapnprpcLogLevel2zerologLevel

func CapnprpcLogLevel2zerologLevel(logLevel capnprpc.LogLevel) (zerolog.Level, error)

CapnprpcLogLevel2zerologLevel capnproc.LogLevel -> zerolog.Level error : ErrUnknownLogLevel

func NewAppServer

func NewAppServer() capnprpc.App_Server

func ZerologLevel2capnprpcLogLevel

func ZerologLevel2capnprpcLogLevel(logLevel zerolog.Level) (capnprpc.LogLevel, error)

ZerologLevel2capnprpcLogLevel zerolog.Level -> capnprpc.LogLevel error : ErrUnknownLogLevel

Types

type AppRPCClient

type AppRPCClient struct {
	*capnprpc.App
}

AppRPCClient wraps the capnprpc.App in order to provide a more user friendly interface

func NewAppClient

func NewAppClient(serviceId ServiceID) (*AppRPCClient, error)

NewAppClient creates a new App capnp RPC client. An RPCClientSpec config must exist for the specified ServiceID.

NOTE: when the app is clustered, the RPC client will connect to any instance in the cluster It will connect using the following network address : {DomainID}_{AppID}

func NewAppClientForAddr

func NewAppClientForAddr(serviceId ServiceID, networkAddr string) (*AppRPCClient, error)

NewAppClientForAddr works the same as NewAppClient, except that it enables connecting to a specific app instance by network address

func (*AppRPCClient) Close

func (a *AppRPCClient) Close()

Close releases any resources associated with this client. No further calls to the client should be made after calling Close.

func (*AppRPCClient) Configs

func (a *AppRPCClient) Configs(ctx context.Context) capnprpc.App_configs_Results_Promise

func (*AppRPCClient) Id

func (a *AppRPCClient) Id(ctx context.Context) capnprpc.App_id_Results_Promise

func (*AppRPCClient) Instance

func (a *AppRPCClient) Instance(ctx context.Context) capnprpc.App_instance_Results_Promise

func (*AppRPCClient) Kill

func (a *AppRPCClient) Kill(ctx context.Context) error

func (*AppRPCClient) LogLevel

func (a *AppRPCClient) LogLevel(ctx context.Context) capnprpc.App_logLevel_Results_Promise

func (*AppRPCClient) ReleaseId

func (a *AppRPCClient) ReleaseId(ctx context.Context) capnprpc.App_releaseId_Results_Promise

func (*AppRPCClient) RpcService

func (a *AppRPCClient) RpcService(ctx context.Context, id ServiceID) capnprpc.App_rpcService_Results_Promise

func (*AppRPCClient) RpcServiceIds

func (a *AppRPCClient) RpcServiceIds(ctx context.Context) capnprpc.App_rpcServiceIds_Results_Promise

func (*AppRPCClient) Runtime

func (a *AppRPCClient) Runtime(ctx context.Context) capnprpc.App_runtime_Results_Promise

func (*AppRPCClient) Service

func (a *AppRPCClient) Service(ctx context.Context, id ServiceID) capnprpc.App_service_Results_Promise

func (*AppRPCClient) ServiceIds

func (a *AppRPCClient) ServiceIds(ctx context.Context) capnprpc.App_serviceIds_Results_Promise

func (*AppRPCClient) StartedOn

func (a *AppRPCClient) StartedOn(ctx context.Context) capnprpc.App_startedOn_Results_Promise