ppspp

package
v0.0.0-...-249e25c Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2025 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CapConnLog_PeerLog_Event_Code_name = map[int32]string{
		0: "EVENT_CODE_INIT",
		1: "EVENT_CODE_WRITE",
		2: "EVENT_CODE_WRITE_ERR",
		3: "EVENT_CODE_FLUSH",
		4: "EVENT_CODE_FLUSH_ERR",
		5: "EVENT_CODE_READ",
		6: "EVENT_CODE_READ_ERR",
	}
	CapConnLog_PeerLog_Event_Code_value = map[string]int32{
		"EVENT_CODE_INIT":      0,
		"EVENT_CODE_WRITE":     1,
		"EVENT_CODE_WRITE_ERR": 2,
		"EVENT_CODE_FLUSH":     3,
		"EVENT_CODE_FLUSH_ERR": 4,
		"EVENT_CODE_READ":      5,
		"EVENT_CODE_READ_ERR":  6,
	}
)

Enum value maps for CapConnLog_PeerLog_Event_Code.

View Source 
var (
	CapConnLog_PeerLog_Event_MessageType_name = map[int32]string{
		0:   "MESSAGE_TYPE_HANDSHAKE",
		1:   "MESSAGE_TYPE_RESTART",
		2:   "MESSAGE_TYPE_DATA",
		3:   "MESSAGE_TYPE_ACK",
		4:   "MESSAGE_TYPE_HAVE",
		5:   "MESSAGE_TYPE_INTEGRITY",
		6:   "MESSAGE_TYPE_SIGNED_INTEGRITY",
		7:   "MESSAGE_TYPE_REQUEST",
		8:   "MESSAGE_TYPE_CANCEL",
		9:   "MESSAGE_TYPE_CHOKE",
		10:  "MESSAGE_TYPE_UNCHOKE",
		11:  "MESSAGE_TYPE_PING",
		12:  "MESSAGE_TYPE_PONG",
		13:  "MESSAGE_TYPE_STREAM_REQUEST",
		14:  "MESSAGE_TYPE_STREAM_CANCEL",
		15:  "MESSAGE_TYPE_STREAM_OPEN",
		16:  "MESSAGE_TYPE_STREAM_CLOSE",
		255: "MESSAGE_TYPE_END",
	}
	CapConnLog_PeerLog_Event_MessageType_value = map[string]int32{
		"MESSAGE_TYPE_HANDSHAKE":        0,
		"MESSAGE_TYPE_RESTART":          1,
		"MESSAGE_TYPE_DATA":             2,
		"MESSAGE_TYPE_ACK":              3,
		"MESSAGE_TYPE_HAVE":             4,
		"MESSAGE_TYPE_INTEGRITY":        5,
		"MESSAGE_TYPE_SIGNED_INTEGRITY": 6,
		"MESSAGE_TYPE_REQUEST":          7,
		"MESSAGE_TYPE_CANCEL":           8,
		"MESSAGE_TYPE_CHOKE":            9,
		"MESSAGE_TYPE_UNCHOKE":          10,
		"MESSAGE_TYPE_PING":             11,
		"MESSAGE_TYPE_PONG":             12,
		"MESSAGE_TYPE_STREAM_REQUEST":   13,
		"MESSAGE_TYPE_STREAM_CANCEL":    14,
		"MESSAGE_TYPE_STREAM_OPEN":      15,
		"MESSAGE_TYPE_STREAM_CLOSE":     16,
		"MESSAGE_TYPE_END":              255,
	}
)

Enum value maps for CapConnLog_PeerLog_Event_MessageType.

View Source 
var (
	CapConnWatchLogsResponse_Op_name = map[int32]string{
		0: "CREATE",
		1: "REMOVE",
	}
	CapConnWatchLogsResponse_Op_value = map[string]int32{
		"CREATE": 0,
		"REMOVE": 1,
	}
)

Enum value maps for CapConnWatchLogsResponse_Op.

View Source 
var File_devtools_v1_ppspp_capconn_proto protoreflect.FileDescriptor

Functions

func RegisterCapConnService 

func RegisterCapConnService(host rpc.ServiceRegistry, service CapConnService)

RegisterCapConnService ...

Types

type CapConnClient 

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

CapConnClient ...

func NewCapConnClient 

func NewCapConnClient(client rpc.Caller) *CapConnClient

NewCapConnClient ...

func (*CapConnClient) LoadLog 

func (c *CapConnClient) LoadLog(
	ctx context.Context,
	req *CapConnLoadLogRequest,
	res *CapConnLoadLogResponse,
) error

LoadLog ...

func (*CapConnClient) WatchLogs 

func (c *CapConnClient) WatchLogs(
	ctx context.Context,
	req *CapConnWatchLogsRequest,
	res chan *CapConnWatchLogsResponse,
) error

WatchLogs ...

type CapConnLoadLogRequest 

type CapConnLoadLogRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnLoadLogRequest) Descriptor deprecated 

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

Deprecated: Use CapConnLoadLogRequest.ProtoReflect.Descriptor instead.

func (*CapConnLoadLogRequest) GetName 

func (x *CapConnLoadLogRequest) GetName() string

func (*CapConnLoadLogRequest) ProtoMessage 

func (*CapConnLoadLogRequest) ProtoMessage()

func (*CapConnLoadLogRequest) ProtoReflect 

func (x *CapConnLoadLogRequest) ProtoReflect() protoreflect.Message

func (*CapConnLoadLogRequest) Reset 

func (x *CapConnLoadLogRequest) Reset()

func (*CapConnLoadLogRequest) String 

func (x *CapConnLoadLogRequest) String() string

type CapConnLoadLogResponse 

type CapConnLoadLogResponse struct {
	Log *CapConnLog `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnLoadLogResponse) Descriptor deprecated 

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

Deprecated: Use CapConnLoadLogResponse.ProtoReflect.Descriptor instead.

func (*CapConnLoadLogResponse) GetLog 

func (x *CapConnLoadLogResponse) GetLog() *CapConnLog

func (*CapConnLoadLogResponse) ProtoMessage 

func (*CapConnLoadLogResponse) ProtoMessage()

func (*CapConnLoadLogResponse) ProtoReflect 

func (x *CapConnLoadLogResponse) ProtoReflect() protoreflect.Message

func (*CapConnLoadLogResponse) Reset 

func (x *CapConnLoadLogResponse) Reset()

func (*CapConnLoadLogResponse) String 

func (x *CapConnLoadLogResponse) String() string

type CapConnLog 

type CapConnLog struct {
	PeerLogs []*CapConnLog_PeerLog `protobuf:"bytes,1,rep,name=peer_logs,json=peerLogs,proto3" json:"peer_logs,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnLog) Descriptor deprecated 

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

Deprecated: Use CapConnLog.ProtoReflect.Descriptor instead.

func (*CapConnLog) GetPeerLogs 

func (x *CapConnLog) GetPeerLogs() []*CapConnLog_PeerLog

func (*CapConnLog) ProtoMessage 

func (*CapConnLog) ProtoMessage()

func (*CapConnLog) ProtoReflect 

func (x *CapConnLog) ProtoReflect() protoreflect.Message

func (*CapConnLog) Reset 

func (x *CapConnLog) Reset()

func (*CapConnLog) String 

func (x *CapConnLog) String() string

type CapConnLog_PeerLog 

type CapConnLog_PeerLog struct {
	Label  string                      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Events []*CapConnLog_PeerLog_Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnLog_PeerLog) Descriptor deprecated 

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

Deprecated: Use CapConnLog_PeerLog.ProtoReflect.Descriptor instead.

func (*CapConnLog_PeerLog) GetEvents 

func (x *CapConnLog_PeerLog) GetEvents() []*CapConnLog_PeerLog_Event

func (*CapConnLog_PeerLog) GetLabel 

func (x *CapConnLog_PeerLog) GetLabel() string

func (*CapConnLog_PeerLog) ProtoMessage 

func (*CapConnLog_PeerLog) ProtoMessage()

func (*CapConnLog_PeerLog) ProtoReflect 

func (x *CapConnLog_PeerLog) ProtoReflect() protoreflect.Message

func (*CapConnLog_PeerLog) Reset 

func (x *CapConnLog_PeerLog) Reset()

func (*CapConnLog_PeerLog) String 

func (x *CapConnLog_PeerLog) String() string

type CapConnLog_PeerLog_Event 

type CapConnLog_PeerLog_Event struct {
	Code             CapConnLog_PeerLog_Event_Code          `protobuf:"varint,1,opt,name=code,proto3,enum=strims.devtools.v1.ppspp.CapConnLog_PeerLog_Event_Code" json:"code,omitempty"`
	Timestamp        int64                                  `protobuf:"fixed64,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	MessageTypes     []CapConnLog_PeerLog_Event_MessageType `` /* 172-byte string literal not displayed */
	MessageAddresses []uint64                               `protobuf:"varint,4,rep,packed,name=message_addresses,json=messageAddresses,proto3" json:"message_addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnLog_PeerLog_Event) Descriptor deprecated 

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

Deprecated: Use CapConnLog_PeerLog_Event.ProtoReflect.Descriptor instead.

func (*CapConnLog_PeerLog_Event) GetCode 

func (x *CapConnLog_PeerLog_Event) GetCode() CapConnLog_PeerLog_Event_Code

func (*CapConnLog_PeerLog_Event) GetMessageAddresses 

func (x *CapConnLog_PeerLog_Event) GetMessageAddresses() []uint64

func (*CapConnLog_PeerLog_Event) GetMessageTypes 

func (x *CapConnLog_PeerLog_Event) GetMessageTypes() []CapConnLog_PeerLog_Event_MessageType

func (*CapConnLog_PeerLog_Event) GetTimestamp 

func (x *CapConnLog_PeerLog_Event) GetTimestamp() int64

func (*CapConnLog_PeerLog_Event) ProtoMessage 

func (*CapConnLog_PeerLog_Event) ProtoMessage()

func (*CapConnLog_PeerLog_Event) ProtoReflect 

func (x *CapConnLog_PeerLog_Event) ProtoReflect() protoreflect.Message

func (*CapConnLog_PeerLog_Event) Reset 

func (x *CapConnLog_PeerLog_Event) Reset()

func (*CapConnLog_PeerLog_Event) String 

func (x *CapConnLog_PeerLog_Event) String() string

type CapConnLog_PeerLog_Event_Code 

type CapConnLog_PeerLog_Event_Code int32
const (
	CapConnLog_PeerLog_Event_EVENT_CODE_INIT      CapConnLog_PeerLog_Event_Code = 0
	CapConnLog_PeerLog_Event_EVENT_CODE_WRITE     CapConnLog_PeerLog_Event_Code = 1
	CapConnLog_PeerLog_Event_EVENT_CODE_WRITE_ERR CapConnLog_PeerLog_Event_Code = 2
	CapConnLog_PeerLog_Event_EVENT_CODE_FLUSH     CapConnLog_PeerLog_Event_Code = 3
	CapConnLog_PeerLog_Event_EVENT_CODE_FLUSH_ERR CapConnLog_PeerLog_Event_Code = 4
	CapConnLog_PeerLog_Event_EVENT_CODE_READ      CapConnLog_PeerLog_Event_Code = 5
	CapConnLog_PeerLog_Event_EVENT_CODE_READ_ERR  CapConnLog_PeerLog_Event_Code = 6
)

func (CapConnLog_PeerLog_Event_Code) Descriptor 

func (CapConnLog_PeerLog_Event_Code) Descriptor() protoreflect.EnumDescriptor

func (CapConnLog_PeerLog_Event_Code) Enum 

func (x CapConnLog_PeerLog_Event_Code) Enum() *CapConnLog_PeerLog_Event_Code

func (CapConnLog_PeerLog_Event_Code) EnumDescriptor deprecated 

func (CapConnLog_PeerLog_Event_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use CapConnLog_PeerLog_Event_Code.Descriptor instead.

func (CapConnLog_PeerLog_Event_Code) Number 

func (x CapConnLog_PeerLog_Event_Code) Number() protoreflect.EnumNumber

func (CapConnLog_PeerLog_Event_Code) String 

func (x CapConnLog_PeerLog_Event_Code) String() string

func (CapConnLog_PeerLog_Event_Code) Type 

func (CapConnLog_PeerLog_Event_Code) Type() protoreflect.EnumType

type CapConnLog_PeerLog_Event_MessageType 

type CapConnLog_PeerLog_Event_MessageType int32
const (
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_HANDSHAKE        CapConnLog_PeerLog_Event_MessageType = 0
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_RESTART          CapConnLog_PeerLog_Event_MessageType = 1
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_DATA             CapConnLog_PeerLog_Event_MessageType = 2
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_ACK              CapConnLog_PeerLog_Event_MessageType = 3
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_HAVE             CapConnLog_PeerLog_Event_MessageType = 4
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_INTEGRITY        CapConnLog_PeerLog_Event_MessageType = 5
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_SIGNED_INTEGRITY CapConnLog_PeerLog_Event_MessageType = 6
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_REQUEST          CapConnLog_PeerLog_Event_MessageType = 7
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_CANCEL           CapConnLog_PeerLog_Event_MessageType = 8
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_CHOKE            CapConnLog_PeerLog_Event_MessageType = 9
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_UNCHOKE          CapConnLog_PeerLog_Event_MessageType = 10
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_PING             CapConnLog_PeerLog_Event_MessageType = 11
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_PONG             CapConnLog_PeerLog_Event_MessageType = 12
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_STREAM_REQUEST   CapConnLog_PeerLog_Event_MessageType = 13
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_STREAM_CANCEL    CapConnLog_PeerLog_Event_MessageType = 14
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_STREAM_OPEN      CapConnLog_PeerLog_Event_MessageType = 15
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_STREAM_CLOSE     CapConnLog_PeerLog_Event_MessageType = 16
	CapConnLog_PeerLog_Event_MESSAGE_TYPE_END              CapConnLog_PeerLog_Event_MessageType = 255
)

func (CapConnLog_PeerLog_Event_MessageType) Descriptor 

func (CapConnLog_PeerLog_Event_MessageType) Descriptor() protoreflect.EnumDescriptor

func (CapConnLog_PeerLog_Event_MessageType) Enum 

func (x CapConnLog_PeerLog_Event_MessageType) Enum() *CapConnLog_PeerLog_Event_MessageType

func (CapConnLog_PeerLog_Event_MessageType) EnumDescriptor deprecated 

func (CapConnLog_PeerLog_Event_MessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CapConnLog_PeerLog_Event_MessageType.Descriptor instead.

func (CapConnLog_PeerLog_Event_MessageType) Number 

func (x CapConnLog_PeerLog_Event_MessageType) Number() protoreflect.EnumNumber

func (CapConnLog_PeerLog_Event_MessageType) String 

func (x CapConnLog_PeerLog_Event_MessageType) String() string

func (CapConnLog_PeerLog_Event_MessageType) Type 

func (CapConnLog_PeerLog_Event_MessageType) Type() protoreflect.EnumType

type CapConnService 

type CapConnService interface {
	WatchLogs(
		ctx context.Context,
		req *CapConnWatchLogsRequest,
	) (<-chan *CapConnWatchLogsResponse, error)
	LoadLog(
		ctx context.Context,
		req *CapConnLoadLogRequest,
	) (*CapConnLoadLogResponse, error)
}

CapConnService ...

type CapConnWatchLogsRequest 

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

func (*CapConnWatchLogsRequest) Descriptor deprecated 

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

Deprecated: Use CapConnWatchLogsRequest.ProtoReflect.Descriptor instead.

func (*CapConnWatchLogsRequest) ProtoMessage 

func (*CapConnWatchLogsRequest) ProtoMessage()

func (*CapConnWatchLogsRequest) ProtoReflect 

func (x *CapConnWatchLogsRequest) ProtoReflect() protoreflect.Message

func (*CapConnWatchLogsRequest) Reset 

func (x *CapConnWatchLogsRequest) Reset()

func (*CapConnWatchLogsRequest) String 

func (x *CapConnWatchLogsRequest) String() string

type CapConnWatchLogsResponse 

type CapConnWatchLogsResponse struct {
	Op   CapConnWatchLogsResponse_Op `protobuf:"varint,1,opt,name=op,proto3,enum=strims.devtools.v1.ppspp.CapConnWatchLogsResponse_Op" json:"op,omitempty"`
	Name string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CapConnWatchLogsResponse) Descriptor deprecated 

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

Deprecated: Use CapConnWatchLogsResponse.ProtoReflect.Descriptor instead.

func (*CapConnWatchLogsResponse) GetName 

func (x *CapConnWatchLogsResponse) GetName() string

func (*CapConnWatchLogsResponse) GetOp 

func (x *CapConnWatchLogsResponse) GetOp() CapConnWatchLogsResponse_Op

func (*CapConnWatchLogsResponse) ProtoMessage 

func (*CapConnWatchLogsResponse) ProtoMessage()

func (*CapConnWatchLogsResponse) ProtoReflect 

func (x *CapConnWatchLogsResponse) ProtoReflect() protoreflect.Message

func (*CapConnWatchLogsResponse) Reset 

func (x *CapConnWatchLogsResponse) Reset()

func (*CapConnWatchLogsResponse) String 

func (x *CapConnWatchLogsResponse) String() string

type CapConnWatchLogsResponse_Op 

type CapConnWatchLogsResponse_Op int32
const (
	CapConnWatchLogsResponse_CREATE CapConnWatchLogsResponse_Op = 0
	CapConnWatchLogsResponse_REMOVE CapConnWatchLogsResponse_Op = 1
)

func (CapConnWatchLogsResponse_Op) Descriptor 

func (CapConnWatchLogsResponse_Op) Descriptor() protoreflect.EnumDescriptor

func (CapConnWatchLogsResponse_Op) Enum 

func (x CapConnWatchLogsResponse_Op) Enum() *CapConnWatchLogsResponse_Op

func (CapConnWatchLogsResponse_Op) EnumDescriptor deprecated 

func (CapConnWatchLogsResponse_Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use CapConnWatchLogsResponse_Op.Descriptor instead.

func (CapConnWatchLogsResponse_Op) Number 

func (x CapConnWatchLogsResponse_Op) Number() protoreflect.EnumNumber

func (CapConnWatchLogsResponse_Op) String 

func (x CapConnWatchLogsResponse_Op) String() string

func (CapConnWatchLogsResponse_Op) Type 

func (CapConnWatchLogsResponse_Op) Type() protoreflect.EnumType

type UnimplementedCapConnService 

type UnimplementedCapConnService struct{}

CapConnService ...

func (*UnimplementedCapConnService) LoadLog 

func (s *UnimplementedCapConnService) LoadLog(
	ctx context.Context,
	req *CapConnLoadLogRequest,
) (*CapConnLoadLogResponse, error)

func (*UnimplementedCapConnService) WatchLogs 

func (s *UnimplementedCapConnService) WatchLogs(
	ctx context.Context,
	req *CapConnWatchLogsRequest,
) (<-chan *CapConnWatchLogsResponse, 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.