sse

package

v0.32.0 Latest Latest Go to latest Published: Jul 18, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/park285/iris-client-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ParseStream(ctx context.Context, scanner *bufio.Scanner, ch chan<- RawSSEEvent) error
type MemberNicknameUpdatedEvent
type RawSSEEvent
type SSERoomEventBody
type SSEStreamState

Constants ¶

View Source

const (
	// EventTypeMemberNicknameUpdated는 Iris가 발행하는 유일한 semantic event 타입입니다.
	// 일반 메시지 이벤트의 eventType은 Kakao 메시지 타입 코드 문자열("1", "2", ...)입니다.
	EventTypeMemberNicknameUpdated = "member_nickname_updated"

	SSEEventRoomEvent   = "room_event"
	SSEEventStreamState = "iris.stream_state"

	StreamCursorStatusCurrent = "current"
	StreamCursorStatusStale   = "stale"
	StreamCursorStatusFuture  = "future"

	StreamRecoveryQueryRecentMessages = "query_recent_messages"
)

View Source

const EventMaxBytes = 8 << 20

Variables ¶

View Source

var ErrEventTooLarge = fmt.Errorf("iris sse: accumulated event data exceeds %d bytes", defaultSSEEventMaxBytes)

Functions ¶

func ParseStream ¶

func ParseStream(ctx context.Context, scanner *bufio.Scanner, ch chan<- RawSSEEvent) error

Types ¶

type MemberNicknameUpdatedEvent ¶

type MemberNicknameUpdatedEvent struct {
	Type                string  `json:"type"`
	SourceLogID         int64   `json:"sourceLogId"`
	RawSourceLogID      *int64  `json:"rawSourceLogId,omitempty"`
	SourceGenerationID  *int64  `json:"sourceGenerationId,omitempty"`
	SourceAccountID     string  `json:"sourceAccountId,omitempty"`
	ChatLogID           *string `json:"chatLogId,omitempty"`
	ChatID              int64   `json:"chatId"`
	UserID              int64   `json:"userId"`
	PreviousDisplayName string  `json:"previousDisplayName"`
	CurrentDisplayName  string  `json:"currentDisplayName"`
	CreatedAtMs         int64   `json:"createdAtMs"`
}

type RawSSEEvent ¶

type RawSSEEvent struct {
	ID    int64
	Event string
	Data  json.RawMessage
}

type SSERoomEventBody ¶

type SSERoomEventBody struct {
	RoomEventID int64           `json:"roomEventId"`
	ChatID      int64           `json:"chatId"`
	EventType   string          `json:"eventType"`
	UserID      int64           `json:"userId"`
	Payload     json.RawMessage `json:"payload"`
}

SSERoomEventBody는 SSE room_event 프레임의 data 본문입니다. Payload는 room_events.payload 객체가 인라인된 JSON입니다(문자열 아님).

type SSEStreamState ¶

type SSEStreamState struct {
	CursorStatus        string `json:"cursorStatus"`
	LastEventID         int64  `json:"lastEventId"`
	OldestAvailableID   *int64 `json:"oldestAvailableId"`
	LatestAvailableID   *int64 `json:"latestAvailableId"`
	RecommendedRecovery string `json:"recommendedRecovery"`
}

SSEStreamState는 SSE iris.stream_state 프레임의 data 본문입니다. replay 커서가 current가 아닐 때만 전송됩니다.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL