s4wave_trace

package
v0.51.2 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCTraceServiceServiceID = "s4wave.trace.TraceService"

Variables

This section is empty.

Functions

func NewSRPCTraceServiceHandler 

func NewSRPCTraceServiceHandler(impl SRPCTraceServiceServer, serviceID string) srpc.Handler

NewSRPCTraceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.trace.TraceService

func SRPCRegisterTraceService 

func SRPCRegisterTraceService(mux srpc.Mux, impl SRPCTraceServiceServer) error

SRPCRegisterTraceService registers the implementation with the mux. Uses the default serviceID: s4wave.trace.TraceService

Types

type SRPCTraceServiceClient 

type SRPCTraceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	StartTrace(ctx context.Context, in *StartTraceRequest) (*StartTraceResponse, error)

	StopTrace(ctx context.Context, in *StopTraceRequest) (SRPCTraceService_StopTraceClient, error)
}

func NewSRPCTraceServiceClient 

func NewSRPCTraceServiceClient(cc srpc.Client) SRPCTraceServiceClient

func NewSRPCTraceServiceClientWithServiceID 

func NewSRPCTraceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCTraceServiceClient

type SRPCTraceServiceHandler 

type SRPCTraceServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCTraceServiceHandler) GetMethodIDs 

func (SRPCTraceServiceHandler) GetMethodIDs() []string

func (*SRPCTraceServiceHandler) GetServiceID 

func (d *SRPCTraceServiceHandler) GetServiceID() string

func (*SRPCTraceServiceHandler) InvokeMethod 

func (d *SRPCTraceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCTraceServiceHandler) InvokeMethod_StartTrace 

func (SRPCTraceServiceHandler) InvokeMethod_StartTrace(impl SRPCTraceServiceServer, strm srpc.Stream) error

func (SRPCTraceServiceHandler) InvokeMethod_StopTrace 

func (SRPCTraceServiceHandler) InvokeMethod_StopTrace(impl SRPCTraceServiceServer, strm srpc.Stream) error

type SRPCTraceServiceServer 

type SRPCTraceServiceServer interface {
	StartTrace(context.Context, *StartTraceRequest) (*StartTraceResponse, error)

	StopTrace(*StopTraceRequest, SRPCTraceService_StopTraceStream) error
}

type SRPCTraceService_StartTraceStream 

type SRPCTraceService_StartTraceStream interface {
	srpc.Stream
}

type SRPCTraceService_StopTraceClient 

type SRPCTraceService_StopTraceClient interface {
	srpc.Stream
	Recv() (*StopTraceResponse, error)
	RecvTo(*StopTraceResponse) error
}

type SRPCTraceService_StopTraceStream 

type SRPCTraceService_StopTraceStream interface {
	srpc.Stream
	Send(*StopTraceResponse) error
	SendAndClose(*StopTraceResponse) error
}

type StartTraceRequest 

type StartTraceRequest struct {

	// Label is an optional human-readable label for the capture.
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

StartTraceRequest is the request for StartTrace.

func (*StartTraceRequest) CloneMessageVT 

func (m *StartTraceRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StartTraceRequest) CloneVT 

func (m *StartTraceRequest) CloneVT() *StartTraceRequest

func (*StartTraceRequest) EqualMessageVT 

func (this *StartTraceRequest) EqualMessageVT(thatMsg any) bool

func (*StartTraceRequest) EqualVT 

func (this *StartTraceRequest) EqualVT(that *StartTraceRequest) bool

func (*StartTraceRequest) GetLabel 

func (x *StartTraceRequest) GetLabel() string

func (*StartTraceRequest) MarshalJSON 

func (x *StartTraceRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StartTraceRequest to JSON.

func (*StartTraceRequest) MarshalProtoJSON 

func (x *StartTraceRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StartTraceRequest message to JSON.

func (*StartTraceRequest) MarshalProtoText 

func (x *StartTraceRequest) MarshalProtoText() string

func (*StartTraceRequest) MarshalToSizedBufferVT 

func (m *StartTraceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartTraceRequest) MarshalToVT 

func (m *StartTraceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartTraceRequest) MarshalVT 

func (m *StartTraceRequest) MarshalVT() (dAtA []byte, err error)

func (*StartTraceRequest) ProtoMessage 

func (*StartTraceRequest) ProtoMessage()

func (*StartTraceRequest) Reset 

func (x *StartTraceRequest) Reset()

func (*StartTraceRequest) SizeVT 

func (m *StartTraceRequest) SizeVT() (n int)

func (*StartTraceRequest) String 

func (x *StartTraceRequest) String() string

func (*StartTraceRequest) UnmarshalJSON 

func (x *StartTraceRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StartTraceRequest from JSON.

func (*StartTraceRequest) UnmarshalProtoJSON 

func (x *StartTraceRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StartTraceRequest message from JSON.

func (*StartTraceRequest) UnmarshalVT 

func (m *StartTraceRequest) UnmarshalVT(dAtA []byte) error

type StartTraceResponse 

type StartTraceResponse struct {
	// contains filtered or unexported fields
}

StartTraceResponse is the response for StartTrace.

func (*StartTraceResponse) CloneMessageVT 

func (m *StartTraceResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StartTraceResponse) CloneVT 

func (m *StartTraceResponse) CloneVT() *StartTraceResponse

func (*StartTraceResponse) EqualMessageVT 

func (this *StartTraceResponse) EqualMessageVT(thatMsg any) bool

func (*StartTraceResponse) EqualVT 

func (this *StartTraceResponse) EqualVT(that *StartTraceResponse) bool

func (*StartTraceResponse) MarshalJSON 

func (x *StartTraceResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StartTraceResponse to JSON.

func (*StartTraceResponse) MarshalProtoJSON 

func (x *StartTraceResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StartTraceResponse message to JSON.

func (*StartTraceResponse) MarshalProtoText 

func (x *StartTraceResponse) MarshalProtoText() string

func (*StartTraceResponse) MarshalToSizedBufferVT 

func (m *StartTraceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartTraceResponse) MarshalToVT 

func (m *StartTraceResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartTraceResponse) MarshalVT 

func (m *StartTraceResponse) MarshalVT() (dAtA []byte, err error)

func (*StartTraceResponse) ProtoMessage 

func (*StartTraceResponse) ProtoMessage()

func (*StartTraceResponse) Reset 

func (x *StartTraceResponse) Reset()

func (*StartTraceResponse) SizeVT 

func (m *StartTraceResponse) SizeVT() (n int)

func (*StartTraceResponse) String 

func (x *StartTraceResponse) String() string

func (*StartTraceResponse) UnmarshalJSON 

func (x *StartTraceResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StartTraceResponse from JSON.

func (*StartTraceResponse) UnmarshalProtoJSON 

func (x *StartTraceResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StartTraceResponse message from JSON.

func (*StartTraceResponse) UnmarshalVT 

func (m *StartTraceResponse) UnmarshalVT(dAtA []byte) error

type StopTraceRequest 

type StopTraceRequest struct {
	// contains filtered or unexported fields
}

StopTraceRequest is the request for StopTrace.

func (*StopTraceRequest) CloneMessageVT 

func (m *StopTraceRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StopTraceRequest) CloneVT 

func (m *StopTraceRequest) CloneVT() *StopTraceRequest

func (*StopTraceRequest) EqualMessageVT 

func (this *StopTraceRequest) EqualMessageVT(thatMsg any) bool

func (*StopTraceRequest) EqualVT 

func (this *StopTraceRequest) EqualVT(that *StopTraceRequest) bool

func (*StopTraceRequest) MarshalJSON 

func (x *StopTraceRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StopTraceRequest to JSON.

func (*StopTraceRequest) MarshalProtoJSON 

func (x *StopTraceRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StopTraceRequest message to JSON.

func (*StopTraceRequest) MarshalProtoText 

func (x *StopTraceRequest) MarshalProtoText() string

func (*StopTraceRequest) MarshalToSizedBufferVT 

func (m *StopTraceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopTraceRequest) MarshalToVT 

func (m *StopTraceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StopTraceRequest) MarshalVT 

func (m *StopTraceRequest) MarshalVT() (dAtA []byte, err error)

func (*StopTraceRequest) ProtoMessage 

func (*StopTraceRequest) ProtoMessage()

func (*StopTraceRequest) Reset 

func (x *StopTraceRequest) Reset()

func (*StopTraceRequest) SizeVT 

func (m *StopTraceRequest) SizeVT() (n int)

func (*StopTraceRequest) String 

func (x *StopTraceRequest) String() string

func (*StopTraceRequest) UnmarshalJSON 

func (x *StopTraceRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StopTraceRequest from JSON.

func (*StopTraceRequest) UnmarshalProtoJSON 

func (x *StopTraceRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StopTraceRequest message from JSON.

func (*StopTraceRequest) UnmarshalVT 

func (m *StopTraceRequest) UnmarshalVT(dAtA []byte) error

type StopTraceResponse 

type StopTraceResponse struct {

	// Data is a chunk of the raw runtime trace bytes.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

StopTraceResponse is a streamed response chunk for StopTrace.

func (*StopTraceResponse) CloneMessageVT 

func (m *StopTraceResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StopTraceResponse) CloneVT 

func (m *StopTraceResponse) CloneVT() *StopTraceResponse

func (*StopTraceResponse) EqualMessageVT 

func (this *StopTraceResponse) EqualMessageVT(thatMsg any) bool

func (*StopTraceResponse) EqualVT 

func (this *StopTraceResponse) EqualVT(that *StopTraceResponse) bool

func (*StopTraceResponse) GetData 

func (x *StopTraceResponse) GetData() []byte

func (*StopTraceResponse) MarshalJSON 

func (x *StopTraceResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StopTraceResponse to JSON.

func (*StopTraceResponse) MarshalProtoJSON 

func (x *StopTraceResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StopTraceResponse message to JSON.

func (*StopTraceResponse) MarshalProtoText 

func (x *StopTraceResponse) MarshalProtoText() string

func (*StopTraceResponse) MarshalToSizedBufferVT 

func (m *StopTraceResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopTraceResponse) MarshalToVT 

func (m *StopTraceResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StopTraceResponse) MarshalVT 

func (m *StopTraceResponse) MarshalVT() (dAtA []byte, err error)

func (*StopTraceResponse) ProtoMessage 

func (*StopTraceResponse) ProtoMessage()

func (*StopTraceResponse) Reset 

func (x *StopTraceResponse) Reset()

func (*StopTraceResponse) SizeVT 

func (m *StopTraceResponse) SizeVT() (n int)

func (*StopTraceResponse) String 

func (x *StopTraceResponse) String() string

func (*StopTraceResponse) UnmarshalJSON 

func (x *StopTraceResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StopTraceResponse from JSON.

func (*StopTraceResponse) UnmarshalProtoJSON 

func (x *StopTraceResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StopTraceResponse message from JSON.

func (*StopTraceResponse) UnmarshalVT 

func (m *StopTraceResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.