spacewave_chat

package
v0.53.0 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const ChatChannelTypeID = "spacewave-chat/channel"

ChatChannelTypeID is the type identifier for chat channel objects.

View Source 
const ChatMessageTypeID = "spacewave-chat/message"

ChatMessageTypeID is the type identifier for chat message objects.

View Source 
const GeneralChannelKey = "chat/channel/general"

GeneralChannelKey is the default channel object key.

Variables

View Source 
var CreateChatChannelOpId = "spacewave-chat/channel/create"

CreateChatChannelOpId is the operation id for CreateChatChannelOp.

View Source 
var InitChatDemoOpId = "chat/init-chat-demo"

InitChatDemoOpId is the operation type ID.

View Source 
var PredChannelMessage = quad.IRI("spacewave-chat/channel-message")

PredChannelMessage is the graph predicate linking a channel to its messages.

View Source 
var PredMessageSender = quad.IRI("spacewave-chat/message-sender")

PredMessageSender is the graph predicate linking a message to its sender.

Functions

func LookupCreateChatChannelOp 

func LookupCreateChatChannelOp(ctx context.Context, operationTypeID string) (world.Operation, error)

LookupCreateChatChannelOp looks up a CreateChatChannelOp operation type.

func LookupInitChatDemoOp 

func LookupInitChatDemoOp(ctx context.Context, opTypeID string) (world.Operation, error)

LookupInitChatDemoOp looks up the init chat demo operation.

func NewChatChannelBlock added in v0.52.0 

func NewChatChannelBlock() block.Block

NewChatChannelBlock constructs a new ChatChannel block.

func NewChatMessageBlock added in v0.52.0 

func NewChatMessageBlock() block.Block

NewChatMessageBlock constructs a new ChatMessage block.

func NewChatMessagePageBlock added in v0.52.0 

func NewChatMessagePageBlock() block.Block

NewChatMessagePageBlock constructs a new ChatMessagePage block.

func NewCreateChatChannelOpBlock 

func NewCreateChatChannelOpBlock() block.Block

NewCreateChatChannelOpBlock constructs a new CreateChatChannelOp block.

func NewInitChatDemoOpBlock 

func NewInitChatDemoOpBlock() block.Block

NewInitChatDemoOpBlock creates an empty block for deserialization.

Types

type ChatChannel 

type ChatChannel struct {

	// Name is the channel display name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Topic is an optional channel topic description.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// CreatedAt is the creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"createdAt,omitempty"`
	// MessageCount is the number of messages appended to the channel.
	MessageCount uint64 `protobuf:"varint,4,opt,name=message_count,json=messageCount,proto3" json:"messageCount,omitempty"`
	// contains filtered or unexported fields
}

ChatChannel is a chat channel world object. All channels are visible to Space participants (no visibility field).

func (*ChatChannel) CloneMessageVT 

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

func (*ChatChannel) CloneVT 

func (m *ChatChannel) CloneVT() *ChatChannel

func (*ChatChannel) EqualMessageVT 

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

func (*ChatChannel) EqualVT 

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

func (*ChatChannel) GetCreatedAt 

func (x *ChatChannel) GetCreatedAt() *timestamppb.Timestamp

func (*ChatChannel) GetMessageCount added in v0.52.0 

func (x *ChatChannel) GetMessageCount() uint64

func (*ChatChannel) GetName 

func (x *ChatChannel) GetName() string

func (*ChatChannel) GetTopic 

func (x *ChatChannel) GetTopic() string

func (*ChatChannel) MarshalBlock 

func (c *ChatChannel) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatChannel to bytes.

func (*ChatChannel) MarshalJSON 

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

MarshalJSON marshals the ChatChannel to JSON.

func (*ChatChannel) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ChatChannel message to JSON.

func (*ChatChannel) MarshalProtoText 

func (x *ChatChannel) MarshalProtoText() string

func (*ChatChannel) MarshalToSizedBufferVT 

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

func (*ChatChannel) MarshalToVT 

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

func (*ChatChannel) MarshalVT 

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

func (*ChatChannel) ProtoMessage 

func (*ChatChannel) ProtoMessage()

func (*ChatChannel) Reset 

func (x *ChatChannel) Reset()

func (*ChatChannel) SizeVT 

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

func (*ChatChannel) String 

func (x *ChatChannel) String() string

func (*ChatChannel) UnmarshalBlock 

func (c *ChatChannel) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatChannel from bytes.

func (*ChatChannel) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ChatChannel from JSON.

func (*ChatChannel) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ChatChannel message from JSON.

func (*ChatChannel) UnmarshalVT 

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

func (*ChatChannel) Validate 

func (c *ChatChannel) Validate() error

Validate performs cursory checks on the ChatChannel.

type ChatMessage 

type ChatMessage struct {

	// SenderPeerId is the peer ID of the message sender.
	SenderPeerId string `protobuf:"bytes,1,opt,name=sender_peer_id,json=senderPeerId,proto3" json:"senderPeerId,omitempty"`
	// Content is the message content.
	Content *ChatMessageContent `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// CreatedAt is the message creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"createdAt,omitempty"`
	// ReplyToKey is the object key of the message being replied to.
	ReplyToKey string `protobuf:"bytes,4,opt,name=reply_to_key,json=replyToKey,proto3" json:"replyToKey,omitempty"`
	// Index is the zero-based message index within the channel.
	Index uint64 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

ChatMessage is a chat message world object linked to a channel.

func (*ChatMessage) CloneMessageVT 

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

func (*ChatMessage) CloneVT 

func (m *ChatMessage) CloneVT() *ChatMessage

func (*ChatMessage) EqualMessageVT 

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

func (*ChatMessage) EqualVT 

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

func (*ChatMessage) GetContent 

func (x *ChatMessage) GetContent() *ChatMessageContent

func (*ChatMessage) GetCreatedAt 

func (x *ChatMessage) GetCreatedAt() *timestamppb.Timestamp

func (*ChatMessage) GetIndex added in v0.52.0 

func (x *ChatMessage) GetIndex() uint64

func (*ChatMessage) GetReplyToKey 

func (x *ChatMessage) GetReplyToKey() string

func (*ChatMessage) GetSenderPeerId 

func (x *ChatMessage) GetSenderPeerId() string

func (*ChatMessage) MarshalBlock 

func (m *ChatMessage) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatMessage to bytes.

func (*ChatMessage) MarshalJSON 

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

MarshalJSON marshals the ChatMessage to JSON.

func (*ChatMessage) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ChatMessage message to JSON.

func (*ChatMessage) MarshalProtoText 

func (x *ChatMessage) MarshalProtoText() string

func (*ChatMessage) MarshalToSizedBufferVT 

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

func (*ChatMessage) MarshalToVT 

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

func (*ChatMessage) MarshalVT 

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

func (*ChatMessage) ProtoMessage 

func (*ChatMessage) ProtoMessage()

func (*ChatMessage) Reset 

func (x *ChatMessage) Reset()

func (*ChatMessage) SizeVT 

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

func (*ChatMessage) String 

func (x *ChatMessage) String() string

func (*ChatMessage) UnmarshalBlock 

func (m *ChatMessage) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatMessage from bytes.

func (*ChatMessage) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ChatMessage from JSON.

func (*ChatMessage) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ChatMessage message from JSON.

func (*ChatMessage) UnmarshalVT 

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

func (*ChatMessage) Validate 

func (m *ChatMessage) Validate() error

Validate performs cursory checks on the ChatMessage.

type ChatMessageContent 

type ChatMessageContent struct {

	// Types that are assignable to Content:
	//
	//	*ChatMessageContent_Text
	Content isChatMessageContent_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

ChatMessageContent contains the message body.

func (*ChatMessageContent) CloneMessageVT 

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

func (*ChatMessageContent) CloneVT 

func (m *ChatMessageContent) CloneVT() *ChatMessageContent

func (*ChatMessageContent) EqualMessageVT 

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

func (*ChatMessageContent) EqualVT 

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

func (*ChatMessageContent) GetContent 

func (m *ChatMessageContent) GetContent() isChatMessageContent_Content

func (*ChatMessageContent) GetText 

func (x *ChatMessageContent) GetText() string

func (*ChatMessageContent) MarshalJSON 

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

MarshalJSON marshals the ChatMessageContent to JSON.

func (*ChatMessageContent) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ChatMessageContent message to JSON.

func (*ChatMessageContent) MarshalProtoText 

func (x *ChatMessageContent) MarshalProtoText() string

func (*ChatMessageContent) MarshalToSizedBufferVT 

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

func (*ChatMessageContent) MarshalToVT 

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

func (*ChatMessageContent) MarshalVT 

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

func (*ChatMessageContent) ProtoMessage 

func (*ChatMessageContent) ProtoMessage()

func (*ChatMessageContent) Reset 

func (x *ChatMessageContent) Reset()

func (*ChatMessageContent) SizeVT 

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

func (*ChatMessageContent) String 

func (x *ChatMessageContent) String() string

func (*ChatMessageContent) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ChatMessageContent from JSON.

func (*ChatMessageContent) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ChatMessageContent message from JSON.

func (*ChatMessageContent) UnmarshalVT 

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

type ChatMessageContent_Text 

type ChatMessageContent_Text struct {
	// Text is a plain text message.
	Text string `protobuf:"bytes,1,opt,name=text,proto3,oneof"`
}

func (*ChatMessageContent_Text) CloneOneofVT 

func (m *ChatMessageContent_Text) CloneOneofVT() isChatMessageContent_Content

func (*ChatMessageContent_Text) CloneVT 

func (m *ChatMessageContent_Text) CloneVT() *ChatMessageContent_Text

func (*ChatMessageContent_Text) EqualVT 

func (this *ChatMessageContent_Text) EqualVT(thatIface isChatMessageContent_Content) bool

func (*ChatMessageContent_Text) MarshalToSizedBufferVT 

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

func (*ChatMessageContent_Text) MarshalToVT 

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

func (*ChatMessageContent_Text) SizeVT 

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

type ChatMessagePage added in v0.52.0 

type ChatMessagePage struct {

	// MessageKeys are page-local message object keys in creation order.
	MessageKeys []string `protobuf:"bytes,1,rep,name=message_keys,json=messageKeys,proto3" json:"messageKeys,omitempty"`
	// contains filtered or unexported fields
}

ChatMessagePage stores a bounded page of channel message keys.

func (*ChatMessagePage) CloneMessageVT added in v0.52.0 

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

func (*ChatMessagePage) CloneVT added in v0.52.0 

func (m *ChatMessagePage) CloneVT() *ChatMessagePage

func (*ChatMessagePage) EqualMessageVT added in v0.52.0 

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

func (*ChatMessagePage) EqualVT added in v0.52.0 

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

func (*ChatMessagePage) GetMessageKeys added in v0.52.0 

func (x *ChatMessagePage) GetMessageKeys() []string

func (*ChatMessagePage) MarshalBlock added in v0.52.0 

func (m *ChatMessagePage) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatMessagePage to bytes.

func (*ChatMessagePage) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the ChatMessagePage to JSON.

func (*ChatMessagePage) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the ChatMessagePage message to JSON.

func (*ChatMessagePage) MarshalProtoText added in v0.52.0 

func (x *ChatMessagePage) MarshalProtoText() string

func (*ChatMessagePage) MarshalToSizedBufferVT added in v0.52.0 

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

func (*ChatMessagePage) MarshalToVT added in v0.52.0 

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

func (*ChatMessagePage) MarshalVT added in v0.52.0 

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

func (*ChatMessagePage) ProtoMessage added in v0.52.0 

func (*ChatMessagePage) ProtoMessage()

func (*ChatMessagePage) Reset added in v0.52.0 

func (x *ChatMessagePage) Reset()

func (*ChatMessagePage) SizeVT added in v0.52.0 

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

func (*ChatMessagePage) String added in v0.52.0 

func (x *ChatMessagePage) String() string

func (*ChatMessagePage) UnmarshalBlock added in v0.52.0 

func (m *ChatMessagePage) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatMessagePage from bytes.

func (*ChatMessagePage) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the ChatMessagePage from JSON.

func (*ChatMessagePage) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the ChatMessagePage message from JSON.

func (*ChatMessagePage) UnmarshalVT added in v0.52.0 

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

func (*ChatMessagePage) Validate added in v0.52.0 

func (m *ChatMessagePage) Validate() error

Validate performs cursory checks on the ChatMessagePage.

type ChatResource added in v0.52.0 

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

ChatResource serves ChatResourceService for a single chat channel object.

func NewChatResource added in v0.52.0 

func NewChatResource(
	ws world.WorldState,
	engine world.Engine,
	objectKey string,
	localPeerID string,
) *ChatResource

NewChatResource constructs a ChatResource.

func (*ChatResource) Close added in v0.52.0 

func (r *ChatResource) Close()

Close releases the chat resource lifecycle.

func (*ChatResource) GetChannelInfo added in v0.52.0 

func (r *ChatResource) GetChannelInfo(
	ctx context.Context,
	_ *spacewave_chat_rpc.GetChannelInfoRequest,
) (*spacewave_chat_rpc.GetChannelInfoResponse, error)

GetChannelInfo reads the channel block and returns metadata.

func (*ChatResource) GetMux added in v0.52.0 

func (r *ChatResource) GetMux() srpc.Mux

GetMux returns the SRPC mux for this resource.

func (*ChatResource) ListMessages added in v0.52.0 

func (r *ChatResource) ListMessages(
	ctx context.Context,
	req *spacewave_chat_rpc.ListMessagesRequest,
) (*spacewave_chat_rpc.ListMessagesResponse, error)

ListMessages returns a page of channel messages.

func (*ChatResource) SendMessage added in v0.52.0 

func (r *ChatResource) SendMessage(
	ctx context.Context,
	req *spacewave_chat_rpc.SendMessageRequest,
) (*spacewave_chat_rpc.SendMessageResponse, error)

SendMessage creates a message object and links it to the channel.

func (*ChatResource) WatchMessages added in v0.52.0 

func (r *ChatResource) WatchMessages(
	_ *spacewave_chat_rpc.WatchMessagesRequest,
	strm spacewave_chat_rpc.SRPCChatResourceService_WatchMessagesStream,
) error

WatchMessages streams new message batches after each world change.

type CreateChatChannelOp 

type CreateChatChannelOp struct {

	// ObjectKey is the key to create the channel at.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// Name is the channel name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Topic is the optional channel topic.
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// Timestamp is the creation timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

CreateChatChannelOp creates a new chat channel.

func (*CreateChatChannelOp) ApplyWorldObjectOp 

func (o *CreateChatChannelOp) ApplyWorldObjectOp(
	ctx context.Context,
	le *logrus.Entry,
	os world.ObjectState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldObjectOp applies the operation to a world object.

func (*CreateChatChannelOp) ApplyWorldOp 

func (o *CreateChatChannelOp) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	ws world.WorldState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldOp applies the operation as a world operation.

func (*CreateChatChannelOp) CloneMessageVT 

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

func (*CreateChatChannelOp) CloneVT 

func (m *CreateChatChannelOp) CloneVT() *CreateChatChannelOp

func (*CreateChatChannelOp) EqualMessageVT 

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

func (*CreateChatChannelOp) EqualVT 

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

func (*CreateChatChannelOp) GetName 

func (x *CreateChatChannelOp) GetName() string

func (*CreateChatChannelOp) GetObjectKey 

func (x *CreateChatChannelOp) GetObjectKey() string

func (*CreateChatChannelOp) GetOperationTypeId 

func (o *CreateChatChannelOp) GetOperationTypeId() string

GetOperationTypeId returns the operation type identifier.

func (*CreateChatChannelOp) GetTimestamp 

func (x *CreateChatChannelOp) GetTimestamp() *timestamppb.Timestamp

func (*CreateChatChannelOp) GetTopic 

func (x *CreateChatChannelOp) GetTopic() string

func (*CreateChatChannelOp) MarshalBlock 

func (o *CreateChatChannelOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the block to binary.

func (*CreateChatChannelOp) MarshalJSON 

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

MarshalJSON marshals the CreateChatChannelOp to JSON.

func (*CreateChatChannelOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the CreateChatChannelOp message to JSON.

func (*CreateChatChannelOp) MarshalProtoText 

func (x *CreateChatChannelOp) MarshalProtoText() string

func (*CreateChatChannelOp) MarshalToSizedBufferVT 

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

func (*CreateChatChannelOp) MarshalToVT 

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

func (*CreateChatChannelOp) MarshalVT 

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

func (*CreateChatChannelOp) ProtoMessage 

func (*CreateChatChannelOp) ProtoMessage()

func (*CreateChatChannelOp) Reset 

func (x *CreateChatChannelOp) Reset()

func (*CreateChatChannelOp) SizeVT 

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

func (*CreateChatChannelOp) String 

func (x *CreateChatChannelOp) String() string

func (*CreateChatChannelOp) UnmarshalBlock 

func (o *CreateChatChannelOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the block to the object.

func (*CreateChatChannelOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the CreateChatChannelOp from JSON.

func (*CreateChatChannelOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the CreateChatChannelOp message from JSON.

func (*CreateChatChannelOp) UnmarshalVT 

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

func (*CreateChatChannelOp) Validate 

func (o *CreateChatChannelOp) Validate() error

Validate performs cursory checks on the op.

type InitChatDemoOp 

type InitChatDemoOp struct {

	// ChannelObjectKey is the key for the channel object.
	ChannelObjectKey string `protobuf:"bytes,1,opt,name=channel_object_key,json=channelObjectKey,proto3" json:"channelObjectKey,omitempty"`
	// Timestamp is the creation timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

InitChatDemoOp creates a "General" channel on space quickstart.

func (*InitChatDemoOp) ApplyWorldObjectOp 

func (o *InitChatDemoOp) ApplyWorldObjectOp(
	ctx context.Context,
	le *logrus.Entry,
	os world.ObjectState,
	sender peer.ID,
) (bool, error)

ApplyWorldObjectOp is not supported for this operation.

func (*InitChatDemoOp) ApplyWorldOp 

func (o *InitChatDemoOp) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	ws world.WorldState,
	sender peer.ID,
) (bool, error)

ApplyWorldOp applies the init chat demo operation.

func (*InitChatDemoOp) CloneMessageVT 

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

func (*InitChatDemoOp) CloneVT 

func (m *InitChatDemoOp) CloneVT() *InitChatDemoOp

func (*InitChatDemoOp) EqualMessageVT 

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

func (*InitChatDemoOp) EqualVT 

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

func (*InitChatDemoOp) GetChannelObjectKey 

func (x *InitChatDemoOp) GetChannelObjectKey() string

func (*InitChatDemoOp) GetOperationTypeId 

func (o *InitChatDemoOp) GetOperationTypeId() string

GetOperationTypeId returns the operation type ID.

func (*InitChatDemoOp) GetTimestamp 

func (x *InitChatDemoOp) GetTimestamp() *timestamppb.Timestamp

func (*InitChatDemoOp) MarshalBlock 

func (o *InitChatDemoOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the operation to bytes.

func (*InitChatDemoOp) MarshalJSON 

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

MarshalJSON marshals the InitChatDemoOp to JSON.

func (*InitChatDemoOp) MarshalProtoJSON 

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

MarshalProtoJSON marshals the InitChatDemoOp message to JSON.

func (*InitChatDemoOp) MarshalProtoText 

func (x *InitChatDemoOp) MarshalProtoText() string

func (*InitChatDemoOp) MarshalToSizedBufferVT 

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

func (*InitChatDemoOp) MarshalToVT 

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

func (*InitChatDemoOp) MarshalVT 

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

func (*InitChatDemoOp) ProtoMessage 

func (*InitChatDemoOp) ProtoMessage()

func (*InitChatDemoOp) Reset 

func (x *InitChatDemoOp) Reset()

func (*InitChatDemoOp) SizeVT 

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

func (*InitChatDemoOp) String 

func (x *InitChatDemoOp) String() string

func (*InitChatDemoOp) UnmarshalBlock 

func (o *InitChatDemoOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the operation from bytes.

func (*InitChatDemoOp) UnmarshalJSON 

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

UnmarshalJSON unmarshals the InitChatDemoOp from JSON.

func (*InitChatDemoOp) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the InitChatDemoOp message from JSON.

func (*InitChatDemoOp) UnmarshalVT 

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

func (*InitChatDemoOp) Validate 

func (o *InitChatDemoOp) Validate() error

Validate validates the operation.

Source Files

View all Source files

Directories

Path Synopsis

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.