edge

package
v0.0.0-...-9cb6926 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ChunkedMessage_Signal_name = map[int32]string{
		0: "Flushed",
	}
	ChunkedMessage_Signal_value = map[string]int32{
		"Flushed": 0,
	}
)

Enum value maps for ChunkedMessage_Signal.

View Source 
var File_dwango_nicolive_chat_service_edge_payload_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BackwardSegment 

type BackwardSegment struct {
	Until    *timestamppb.Timestamp       `protobuf:"bytes,1,opt,name=until,proto3" json:"until,omitempty"`
	Segment  *PackedSegment_Next          `protobuf:"bytes,2,opt,name=segment,proto3" json:"segment,omitempty"`
	Snapshot *PackedSegment_StateSnapshot `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*BackwardSegment) Descriptor deprecated 

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

Deprecated: Use BackwardSegment.ProtoReflect.Descriptor instead.

func (*BackwardSegment) GetSegment 

func (x *BackwardSegment) GetSegment() *PackedSegment_Next

func (*BackwardSegment) GetSnapshot 

func (x *BackwardSegment) GetSnapshot() *PackedSegment_StateSnapshot

func (*BackwardSegment) GetUntil 

func (x *BackwardSegment) GetUntil() *timestamppb.Timestamp

func (*BackwardSegment) ProtoMessage 

func (*BackwardSegment) ProtoMessage()

func (*BackwardSegment) ProtoReflect 

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

func (*BackwardSegment) Reset 

func (x *BackwardSegment) Reset()

func (*BackwardSegment) String 

func (x *BackwardSegment) String() string

type ChunkedEntry 

type ChunkedEntry struct {

	// Types that are valid to be assigned to Entry:
	//
	//	*ChunkedEntry_Backward
	//	*ChunkedEntry_Previous
	//	*ChunkedEntry_Segment
	//	*ChunkedEntry_Next
	Entry isChunkedEntry_Entry `protobuf_oneof:"entry"`
	// contains filtered or unexported fields
}

func (*ChunkedEntry) Descriptor deprecated 

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

Deprecated: Use ChunkedEntry.ProtoReflect.Descriptor instead.

func (*ChunkedEntry) GetBackward 

func (x *ChunkedEntry) GetBackward() *BackwardSegment

func (*ChunkedEntry) GetEntry 

func (x *ChunkedEntry) GetEntry() isChunkedEntry_Entry

func (*ChunkedEntry) GetNext 

func (x *ChunkedEntry) GetNext() *ChunkedEntry_ReadyForNext

func (*ChunkedEntry) GetPrevious 

func (x *ChunkedEntry) GetPrevious() *MessageSegment

func (*ChunkedEntry) GetSegment 

func (x *ChunkedEntry) GetSegment() *MessageSegment

func (*ChunkedEntry) ProtoMessage 

func (*ChunkedEntry) ProtoMessage()

func (*ChunkedEntry) ProtoReflect 

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

func (*ChunkedEntry) Reset 

func (x *ChunkedEntry) Reset()

func (*ChunkedEntry) String 

func (x *ChunkedEntry) String() string

type ChunkedEntry_Backward 

type ChunkedEntry_Backward struct {
	Backward *BackwardSegment `protobuf:"bytes,2,opt,name=backward,proto3,oneof"`
}

type ChunkedEntry_Next 

type ChunkedEntry_Next struct {
	Next *ChunkedEntry_ReadyForNext `protobuf:"bytes,4,opt,name=next,proto3,oneof"`
}

type ChunkedEntry_Previous 

type ChunkedEntry_Previous struct {
	Previous *MessageSegment `protobuf:"bytes,3,opt,name=previous,proto3,oneof"`
}

type ChunkedEntry_ReadyForNext 

type ChunkedEntry_ReadyForNext struct {
	At int64 `protobuf:"varint,1,opt,name=at,proto3" json:"at,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkedEntry_ReadyForNext) Descriptor deprecated 

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

Deprecated: Use ChunkedEntry_ReadyForNext.ProtoReflect.Descriptor instead.

func (*ChunkedEntry_ReadyForNext) GetAt 

func (x *ChunkedEntry_ReadyForNext) GetAt() int64

func (*ChunkedEntry_ReadyForNext) ProtoMessage 

func (*ChunkedEntry_ReadyForNext) ProtoMessage()

func (*ChunkedEntry_ReadyForNext) ProtoReflect 

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

func (*ChunkedEntry_ReadyForNext) Reset 

func (x *ChunkedEntry_ReadyForNext) Reset()

func (*ChunkedEntry_ReadyForNext) String 

func (x *ChunkedEntry_ReadyForNext) String() string

type ChunkedEntry_Segment 

type ChunkedEntry_Segment struct {
	Segment *MessageSegment `protobuf:"bytes,1,opt,name=segment,proto3,oneof"`
}

type ChunkedMessage 

type ChunkedMessage struct {
	Meta *ChunkedMessage_Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*ChunkedMessage_Message
	//	*ChunkedMessage_State
	//	*ChunkedMessage_Signal_
	Payload isChunkedMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*ChunkedMessage) Descriptor deprecated 

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

Deprecated: Use ChunkedMessage.ProtoReflect.Descriptor instead.

func (*ChunkedMessage) GetMessage 

func (x *ChunkedMessage) GetMessage() *data.NicoliveMessage

func (*ChunkedMessage) GetMeta 

func (x *ChunkedMessage) GetMeta() *ChunkedMessage_Meta

func (*ChunkedMessage) GetPayload 

func (x *ChunkedMessage) GetPayload() isChunkedMessage_Payload

func (*ChunkedMessage) GetSignal 

func (x *ChunkedMessage) GetSignal() ChunkedMessage_Signal

func (*ChunkedMessage) GetState 

func (x *ChunkedMessage) GetState() *data.NicoliveState

func (*ChunkedMessage) ProtoMessage 

func (*ChunkedMessage) ProtoMessage()

func (*ChunkedMessage) ProtoReflect 

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

func (*ChunkedMessage) Reset 

func (x *ChunkedMessage) Reset()

func (*ChunkedMessage) String 

func (x *ChunkedMessage) String() string

type ChunkedMessage_Message 

type ChunkedMessage_Message struct {
	Message *data.NicoliveMessage `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type ChunkedMessage_Meta 

type ChunkedMessage_Meta struct {
	Id     string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	At     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	Origin *data.NicoliveOrigin   `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkedMessage_Meta) Descriptor deprecated 

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

Deprecated: Use ChunkedMessage_Meta.ProtoReflect.Descriptor instead.

func (*ChunkedMessage_Meta) GetAt 

func (x *ChunkedMessage_Meta) GetAt() *timestamppb.Timestamp

func (*ChunkedMessage_Meta) GetId 

func (x *ChunkedMessage_Meta) GetId() string

func (*ChunkedMessage_Meta) GetOrigin 

func (x *ChunkedMessage_Meta) GetOrigin() *data.NicoliveOrigin

func (*ChunkedMessage_Meta) ProtoMessage 

func (*ChunkedMessage_Meta) ProtoMessage()

func (*ChunkedMessage_Meta) ProtoReflect 

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

func (*ChunkedMessage_Meta) Reset 

func (x *ChunkedMessage_Meta) Reset()

func (*ChunkedMessage_Meta) String 

func (x *ChunkedMessage_Meta) String() string

type ChunkedMessage_Signal 

type ChunkedMessage_Signal int32
const (
	ChunkedMessage_Flushed ChunkedMessage_Signal = 0
)

func (ChunkedMessage_Signal) Descriptor 

func (ChunkedMessage_Signal) Descriptor() protoreflect.EnumDescriptor

func (ChunkedMessage_Signal) Enum 

func (x ChunkedMessage_Signal) Enum() *ChunkedMessage_Signal

func (ChunkedMessage_Signal) EnumDescriptor deprecated 

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

Deprecated: Use ChunkedMessage_Signal.Descriptor instead.

func (ChunkedMessage_Signal) Number 

func (x ChunkedMessage_Signal) Number() protoreflect.EnumNumber

func (ChunkedMessage_Signal) String 

func (x ChunkedMessage_Signal) String() string

func (ChunkedMessage_Signal) Type 

func (ChunkedMessage_Signal) Type() protoreflect.EnumType

type ChunkedMessage_Signal_ 

type ChunkedMessage_Signal_ struct {
	Signal ChunkedMessage_Signal `protobuf:"varint,5,opt,name=signal,proto3,enum=dwango.nicolive.chat.service.edge.ChunkedMessage_Signal,oneof"`
}

type ChunkedMessage_State 

type ChunkedMessage_State struct {
	State *data.NicoliveState `protobuf:"bytes,4,opt,name=state,proto3,oneof"`
}

type MessageSegment 

type MessageSegment struct {
	From  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Until *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=until,proto3" json:"until,omitempty"`
	Uri   string                 `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageSegment) Descriptor deprecated 

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

Deprecated: Use MessageSegment.ProtoReflect.Descriptor instead.

func (*MessageSegment) GetFrom 

func (x *MessageSegment) GetFrom() *timestamppb.Timestamp

func (*MessageSegment) GetUntil 

func (x *MessageSegment) GetUntil() *timestamppb.Timestamp

func (*MessageSegment) GetUri 

func (x *MessageSegment) GetUri() string

func (*MessageSegment) ProtoMessage 

func (*MessageSegment) ProtoMessage()

func (*MessageSegment) ProtoReflect 

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

func (*MessageSegment) Reset 

func (x *MessageSegment) Reset()

func (*MessageSegment) String 

func (x *MessageSegment) String() string

type PackedSegment 

type PackedSegment struct {
	Messages []*ChunkedMessage            `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	Next     *PackedSegment_Next          `protobuf:"bytes,2,opt,name=next,proto3" json:"next,omitempty"`
	Snapshot *PackedSegment_StateSnapshot `protobuf:"bytes,3,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*PackedSegment) Descriptor deprecated 

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

Deprecated: Use PackedSegment.ProtoReflect.Descriptor instead.

func (*PackedSegment) GetMessages 

func (x *PackedSegment) GetMessages() []*ChunkedMessage

func (*PackedSegment) GetNext 

func (x *PackedSegment) GetNext() *PackedSegment_Next

func (*PackedSegment) GetSnapshot 

func (x *PackedSegment) GetSnapshot() *PackedSegment_StateSnapshot

func (*PackedSegment) ProtoMessage 

func (*PackedSegment) ProtoMessage()

func (*PackedSegment) ProtoReflect 

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

func (*PackedSegment) Reset 

func (x *PackedSegment) Reset()

func (*PackedSegment) String 

func (x *PackedSegment) String() string

type PackedSegment_Next 

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

func (*PackedSegment_Next) Descriptor deprecated 

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

Deprecated: Use PackedSegment_Next.ProtoReflect.Descriptor instead.

func (*PackedSegment_Next) GetUri 

func (x *PackedSegment_Next) GetUri() string

func (*PackedSegment_Next) ProtoMessage 

func (*PackedSegment_Next) ProtoMessage()

func (*PackedSegment_Next) ProtoReflect 

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

func (*PackedSegment_Next) Reset 

func (x *PackedSegment_Next) Reset()

func (*PackedSegment_Next) String 

func (x *PackedSegment_Next) String() string

type PackedSegment_StateSnapshot 

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

func (*PackedSegment_StateSnapshot) Descriptor deprecated 

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

Deprecated: Use PackedSegment_StateSnapshot.ProtoReflect.Descriptor instead.

func (*PackedSegment_StateSnapshot) GetUri 

func (x *PackedSegment_StateSnapshot) GetUri() string

func (*PackedSegment_StateSnapshot) ProtoMessage 

func (*PackedSegment_StateSnapshot) ProtoMessage()

func (*PackedSegment_StateSnapshot) ProtoReflect 

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

func (*PackedSegment_StateSnapshot) Reset 

func (x *PackedSegment_StateSnapshot) Reset()

func (*PackedSegment_StateSnapshot) String 

func (x *PackedSegment_StateSnapshot) String() string

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.