pubsubv1

package
v1.36.11-2025091615041... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_simplecloud_pubsub_v1_pubsub_api_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Message 

type Message struct {
	Topic       string       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	MessageBody *MessageBody `protobuf:"bytes,2,opt,name=messageBody,proto3" json:"messageBody,omitempty"`
	Timestamp   int64        `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) ClearMessageBody 

func (x *Message) ClearMessageBody()

func (*Message) GetMessageBody 

func (x *Message) GetMessageBody() *MessageBody

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() int64

func (*Message) GetTopic 

func (x *Message) GetTopic() string

func (*Message) HasMessageBody 

func (x *Message) HasMessageBody() bool

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SetMessageBody 

func (x *Message) SetMessageBody(v *MessageBody)

func (*Message) SetTimestamp 

func (x *Message) SetTimestamp(v int64)

func (*Message) SetTopic 

func (x *Message) SetTopic(v string)

func (*Message) String 

func (x *Message) String() string

type MessageBody 

type MessageBody struct {
	Type        string     `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	MessageData *anypb.Any `protobuf:"bytes,2,opt,name=messageData,proto3" json:"messageData,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageBody) ClearMessageData 

func (x *MessageBody) ClearMessageData()

func (*MessageBody) GetMessageData 

func (x *MessageBody) GetMessageData() *anypb.Any

func (*MessageBody) GetType 

func (x *MessageBody) GetType() string

func (*MessageBody) HasMessageData 

func (x *MessageBody) HasMessageData() bool

func (*MessageBody) ProtoMessage 

func (*MessageBody) ProtoMessage()

func (*MessageBody) ProtoReflect 

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

func (*MessageBody) Reset 

func (x *MessageBody) Reset()

func (*MessageBody) SetMessageData 

func (x *MessageBody) SetMessageData(v *anypb.Any)

func (*MessageBody) SetType 

func (x *MessageBody) SetType(v string)

func (*MessageBody) String 

func (x *MessageBody) String() string

type MessageBody_builder 

type MessageBody_builder struct {
	Type        string
	MessageData *anypb.Any
	// contains filtered or unexported fields
}

func (MessageBody_builder) Build 

func (b0 MessageBody_builder) Build() *MessageBody

type Message_builder 

type Message_builder struct {
	Topic       string
	MessageBody *MessageBody
	Timestamp   int64
	// contains filtered or unexported fields
}

func (Message_builder) Build 

func (b0 Message_builder) Build() *Message

type PublishRequest 

type PublishRequest struct {
	Topic       string       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	MessageBody *MessageBody `protobuf:"bytes,2,opt,name=messageBody,proto3" json:"messageBody,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) ClearMessageBody 

func (x *PublishRequest) ClearMessageBody()

func (*PublishRequest) GetMessageBody 

func (x *PublishRequest) GetMessageBody() *MessageBody

func (*PublishRequest) GetTopic 

func (x *PublishRequest) GetTopic() string

func (*PublishRequest) HasMessageBody 

func (x *PublishRequest) HasMessageBody() bool

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) SetMessageBody 

func (x *PublishRequest) SetMessageBody(v *MessageBody)

func (*PublishRequest) SetTopic 

func (x *PublishRequest) SetTopic(v string)

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishRequest_builder 

type PublishRequest_builder struct {
	Topic       string
	MessageBody *MessageBody
	// contains filtered or unexported fields
}

func (PublishRequest_builder) Build 

func (b0 PublishRequest_builder) Build() *PublishRequest

type PublishResponse 

type PublishResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse) GetSuccess 

func (x *PublishResponse) GetSuccess() bool

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) SetSuccess 

func (x *PublishResponse) SetSuccess(v bool)

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type PublishResponse_builder 

type PublishResponse_builder struct {
	Success bool
	// contains filtered or unexported fields
}

func (PublishResponse_builder) Build 

func (b0 PublishResponse_builder) Build() *PublishResponse

type SubscriptionRequest 

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

func (*SubscriptionRequest) GetTopic 

func (x *SubscriptionRequest) GetTopic() string

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect 

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

func (*SubscriptionRequest) Reset 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) SetTopic 

func (x *SubscriptionRequest) SetTopic(v string)

func (*SubscriptionRequest) String 

func (x *SubscriptionRequest) String() string

type SubscriptionRequest_builder 

type SubscriptionRequest_builder struct {
	Topic string
	// contains filtered or unexported fields
}

func (SubscriptionRequest_builder) Build 

func (b0 SubscriptionRequest_builder) Build() *SubscriptionRequest

Source Files

  • pubsub_api.pb.go

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.