traceapi

Documentation

Index

• Constants
• func ServeTrace(server nproto.RPCServer, svcName string, svc Trace) error
• func SubscribeRecursiveDepthNegative(subscriber nproto.MsgSubscriber, subject, queue string, ...) error
• type RecursiveDepthNegative
  • func (*RecursiveDepthNegative) Descriptor() ([]byte, []int)
  • func (m *RecursiveDepthNegative) GetDepth() int32
  • func (*RecursiveDepthNegative) ProtoMessage()
  • func (m *RecursiveDepthNegative) Reset()
  • func (m *RecursiveDepthNegative) String() string
  • func (m *RecursiveDepthNegative) XXX_DiscardUnknown()
  • func (m *RecursiveDepthNegative) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *RecursiveDepthNegative) XXX_Merge(src proto.Message)
  • func (m *RecursiveDepthNegative) XXX_Size() int
  • func (m *RecursiveDepthNegative) XXX_Unmarshal(b []byte) error
• type RecursiveReply
  • func (*RecursiveReply) Descriptor() ([]byte, []int)
  • func (m *RecursiveReply) GetResult() int32
  • func (*RecursiveReply) ProtoMessage()
  • func (m *RecursiveReply) Reset()
  • func (m *RecursiveReply) String() string
  • func (m *RecursiveReply) XXX_DiscardUnknown()
  • func (m *RecursiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *RecursiveReply) XXX_Merge(src proto.Message)
  • func (m *RecursiveReply) XXX_Size() int
  • func (m *RecursiveReply) XXX_Unmarshal(b []byte) error
• type RecursiveRequest
  • func (*RecursiveRequest) Descriptor() ([]byte, []int)
  • func (m *RecursiveRequest) GetDepth() int32
  • func (*RecursiveRequest) ProtoMessage()
  • func (m *RecursiveRequest) Reset()
  • func (m *RecursiveRequest) String() string
  • func (m *RecursiveRequest) XXX_DiscardUnknown()
  • func (m *RecursiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *RecursiveRequest) XXX_Merge(src proto.Message)
  • func (m *RecursiveRequest) XXX_Size() int
  • func (m *RecursiveRequest) XXX_Unmarshal(b []byte) error
• type Trace
  • func InvokeTrace(client nproto.RPCClient, svcName string) Trace

Constants

const (
	SvcName  = "trace"
	SubjName = "trace.neg.depth"
)

Functions

func ServeTrace

func ServeTrace(server nproto.RPCServer, svcName string, svc Trace) error

ServeTrace serves Trace service using a RPC server.

func SubscribeRecursiveDepthNegative

func SubscribeRecursiveDepthNegative(subscriber nproto.MsgSubscriber, subject, queue string, handler func(context.Context, *RecursiveDepthNegative) error, opts ...interface{}) error

SubscribeRecursiveDepthNegative subscribes to the specified message channel.

Types

type RecursiveDepthNegative

type RecursiveDepthNegative struct {
	Depth                int32    `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

@@npmsg@@

func (*RecursiveDepthNegative) Descriptor

func (*RecursiveDepthNegative) Descriptor() ([]byte, []int)

func (*RecursiveDepthNegative) GetDepth

func (m *RecursiveDepthNegative) GetDepth() int32

func (*RecursiveDepthNegative) ProtoMessage

func (*RecursiveDepthNegative) ProtoMessage()

func (*RecursiveDepthNegative) Reset

func (m *RecursiveDepthNegative) Reset()

func (*RecursiveDepthNegative) String

func (m *RecursiveDepthNegative) String() string

func (*RecursiveDepthNegative) XXX_DiscardUnknown

func (m *RecursiveDepthNegative) XXX_DiscardUnknown()

func (*RecursiveDepthNegative) XXX_Marshal

func (m *RecursiveDepthNegative) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecursiveDepthNegative) XXX_Merge

func (dst *RecursiveDepthNegative) XXX_Merge(src proto.Message)

func (*RecursiveDepthNegative) XXX_Size

func (m *RecursiveDepthNegative) XXX_Size() int

func (*RecursiveDepthNegative) XXX_Unmarshal

func (m *RecursiveDepthNegative) XXX_Unmarshal(b []byte) error

type RecursiveReply

type RecursiveReply struct {
	Result               int32    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecursiveReply) Descriptor

func (*RecursiveReply) Descriptor() ([]byte, []int)

func (*RecursiveReply) GetResult

func (m *RecursiveReply) GetResult() int32

func (*RecursiveReply) ProtoMessage

func (*RecursiveReply) ProtoMessage()

func (*RecursiveReply) Reset

func (m *RecursiveReply) Reset()

func (*RecursiveReply) String

func (m *RecursiveReply) String() string

func (*RecursiveReply) XXX_DiscardUnknown

func (m *RecursiveReply) XXX_DiscardUnknown()

func (*RecursiveReply) XXX_Marshal

func (m *RecursiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecursiveReply) XXX_Merge

func (dst *RecursiveReply) XXX_Merge(src proto.Message)

func (*RecursiveReply) XXX_Size

func (m *RecursiveReply) XXX_Size() int

func (*RecursiveReply) XXX_Unmarshal

func (m *RecursiveReply) XXX_Unmarshal(b []byte) error

type RecursiveRequest

type RecursiveRequest struct {
	Depth                int32    `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecursiveRequest) Descriptor

func (*RecursiveRequest) Descriptor() ([]byte, []int)

func (*RecursiveRequest) GetDepth

func (m *RecursiveRequest) GetDepth() int32

func (*RecursiveRequest) ProtoMessage

func (*RecursiveRequest) ProtoMessage()

func (*RecursiveRequest) Reset

func (m *RecursiveRequest) Reset()

func (*RecursiveRequest) String

func (m *RecursiveRequest) String() string

func (*RecursiveRequest) XXX_DiscardUnknown

func (m *RecursiveRequest) XXX_DiscardUnknown()

func (*RecursiveRequest) XXX_Marshal

func (m *RecursiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecursiveRequest) XXX_Merge

func (dst *RecursiveRequest) XXX_Merge(src proto.Message)

func (*RecursiveRequest) XXX_Size

func (m *RecursiveRequest) XXX_Size() int

func (*RecursiveRequest) XXX_Unmarshal

func (m *RecursiveRequest) XXX_Unmarshal(b []byte) error

type Trace

type Trace interface {
	// Recursive calls this method recursively.
	Recursive(ctx context.Context, input *RecursiveRequest) (output *RecursiveReply, err error)
}

@@nprpc@@

func InvokeTrace

func InvokeTrace(client nproto.RPCClient, svcName string) Trace

InvokeTrace invokes Trace service using a RPC client.