Versions in this module Expand all Collapse all v1 v1.3.0 Apr 17, 2024 Changes in this version + type KafkaClient struct + func NewKafkaClient(serviceId string, kafkaversion string, kafkahost []string, ...) (kafkaClient *KafkaClient, err error) + func (this *KafkaClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) (err error) + func (this *KafkaClient) CallNR(callInfo core.CallInfo) (err error) + func (this *KafkaClient) Delete(key string) (err error) + func (this *KafkaClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error) + func (this *KafkaClient) Stop() (err error) + func (this *KafkaClient) Unmarshal(data []byte) (*core.RPCInfo, error) + func (this *KafkaClient) UnmarshalResult(data []byte) (*core.ResultInfo, error) + type KafkaService struct + func NewKafkaService(serviceId string, kafkaversion string, kafkahost []string, rpcId string) (kafkaService *KafkaService, err error) + func (s *KafkaService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error) + func (s *KafkaService) Unmarshal(data []byte) (*core.RPCInfo, error) + func (this *KafkaService) Callback(callinfo core.CallInfo) error + func (this *KafkaService) Start(service core.IRpcServer) (err error) + func (this *KafkaService) Stop() (err error) + type NatsClient struct + func NewNatsClient(natsaddr string, pushrpcId, receiveId string) (natsClient *NatsClient, err error) + func (this *NatsClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) error + func (this *NatsClient) CallNR(callInfo core.CallInfo) error + func (this *NatsClient) Delete(key string) (err error) + func (this *NatsClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error) + func (this *NatsClient) Stop() (err error) + func (this *NatsClient) Unmarshal(data []byte) (*core.RPCInfo, error) + func (this *NatsClient) UnmarshalResult(data []byte) (*core.ResultInfo, error) + type NatsService struct + func NewNatsService(natsaddr string, rpcId string) (natsService *NatsService, err error) + func (s *NatsService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error) + func (s *NatsService) Unmarshal(data []byte) (*core.RPCInfo, error) + func (this *NatsService) Callback(callinfo core.CallInfo) error + func (this *NatsService) Start(service core.IRpcServer) (err error) + func (this *NatsService) Stop() (err error)
Go to main page