triple

Documentation

Index

• type ProxyService
  • func (d *ProxyService) GetReqParamsInterfaces(methodName string) ([]interface{}, bool)
  • func (d *ProxyService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)
• type TripleListenerService
  • func (ls *TripleListenerService) Close() error
  • func (ls *TripleListenerService) Refresh(c model.Listener) error
  • func (ls *TripleListenerService) ShutDown(wg interface{}) error
  • func (ls *TripleListenerService) Start() error

Types

type ProxyService

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

ProxyService grpc proxy service definition

func (*ProxyService) GetReqParamsInterfaces

func (d *ProxyService) GetReqParamsInterfaces(methodName string) ([]interface{}, bool)

GetReqParamsInterfaces get params

func (*ProxyService) InvokeWithArgs

func (d *ProxyService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)

InvokeWithArgs called when rpc invocation comes

type TripleListenerService

type TripleListenerService struct {
	listener.BaseListenerService
	// contains filtered or unexported fields
}

ListenerService the facade of a listener

func (*TripleListenerService) Close

func (ls *TripleListenerService) Close() error

func (*TripleListenerService) Refresh

func (ls *TripleListenerService) Refresh(c model.Listener) error

func (*TripleListenerService) ShutDown

func (ls *TripleListenerService) ShutDown(wg interface{}) error

func (*TripleListenerService) Start

func (ls *TripleListenerService) Start() error

Start start triple server