util

Documentation

Index

• func Call(m map[string]interface{}, funcName string, params ...interface{}) (result []reflect.Value, err error)
• func DeregisterService(consulAddress, serviceName string)
• func FilterServiceByID(consulAddress, filterId string) map[string]*api.AgentService
• func FindServiceByID(consulAddress, serviceID string) *api.AgentService
• func GenerateDataPacket(sa string, data []byte) *agent.Packet
• func GenerateInvokePacket(sa, funcName string, args []byte) *agent.Packet
• func NewConn(tracer opentracing.Tracer, address string, ctx context.Context) *grpc.ClientConn
• func ProcessInvokePacket(do DigitalObject, p *agent.Packet) (*agent.Packet, error)
• func RegisterService(consulAddress string, service *ConsulService)
• type ConsulService

Functions

func Call

func Call(m map[string]interface{}, funcName string, params ...interface{}) (result []reflect.Value,
	err error)

func DeregisterService

func DeregisterService(consulAddress, serviceName string)

func FilterServiceByID

func FilterServiceByID(consulAddress, filterId string) map[string]*api.AgentService

func FindServiceByID

func FindServiceByID(consulAddress, serviceID string) *api.AgentService

func GenerateDataPacket

func GenerateDataPacket(sa string, data []byte) *agent.Packet

func GenerateInvokePacket

func GenerateInvokePacket(sa, funcName string, args []byte) *agent.Packet

func NewConn

func NewConn(tracer opentracing.Tracer, address string, ctx context.Context) *grpc.ClientConn

func ProcessInvokePacket

func ProcessInvokePacket(do DigitalObject, p *agent.Packet) (*agent.Packet, error)

func RegisterService

func RegisterService(consulAddress string, service *ConsulService)

Types

type ConsulService

type ConsulService struct {
	IP   string
	Port int
	Tag  []string
	Name string
}