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
Constants ¶
View Source
const ( SvcName = "trace" SubjName = "trace.neg.depth" )
Variables ¶
This section is empty.
Functions ¶
func ServeTrace ¶
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@@
Click to show internal directories.
Click to hide internal directories.