info

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2024 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetClaimRequestChannel

func GetClaimRequestChannel(service, clientID string) bus.Channel

func GetResponseChannel

func GetResponseChannel(service, clientID string) bus.Channel

func GetStreamChannel

func GetStreamChannel(service, nodeID string) bus.Channel

Types

type MethodInfo

type MethodInfo struct {
	AffinityEnabled bool
	Multi           bool
	RequireClaim    bool
	Queue           bool
}

type RequestInfo

type RequestInfo struct {
	psrpc.RPCInfo
	AffinityEnabled bool
	RequireClaim    bool
	Queue           bool
}

func (*RequestInfo) GetClaimResponseChannel

func (i *RequestInfo) GetClaimResponseChannel() bus.Channel

func (*RequestInfo) GetHandlerKey

func (i *RequestInfo) GetHandlerKey() string

func (*RequestInfo) GetRPCChannel

func (i *RequestInfo) GetRPCChannel() bus.Channel

func (*RequestInfo) GetStreamServerChannel

func (i *RequestInfo) GetStreamServerChannel() bus.Channel

type ServiceDefinition

type ServiceDefinition struct {
	Name    string
	ID      string
	Methods sync.Map
}

func (*ServiceDefinition) GetInfo

func (s *ServiceDefinition) GetInfo(rpc string, topic []string) *RequestInfo

func (*ServiceDefinition) RegisterMethod

func (s *ServiceDefinition) RegisterMethod(name string, affinityEnabled, multi, requireClaim, queue bool)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL