pubsubui

Documentation

Index

• Variables
• func RegisterPubSubUIServer(s grpc.ServiceRegistrar, srv PubSubUIServer)
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetData() []byte
  • func (x *Message) GetTimestamp() *timestamp.Timestamp
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type PubSubUIClient
  • func NewPubSubUIClient(cc grpc.ClientConnInterface) PubSubUIClient
• type PubSubUIServer
• type PubSubUI_FetchClient
• type PubSubUI_FetchServer
• type TopicSubscription
  • func (*TopicSubscription) Descriptor() ([]byte, []int)
  • func (x *TopicSubscription) GetGcpProjectId() string
  • func (x *TopicSubscription) GetPubsubTopicName() string
  • func (*TopicSubscription) ProtoMessage()
  • func (x *TopicSubscription) ProtoReflect() protoreflect.Message
  • func (x *TopicSubscription) Reset()
  • func (x *TopicSubscription) String() string
• type UnimplementedPubSubUIServer
  • func (UnimplementedPubSubUIServer) Fetch(*TopicSubscription, PubSubUI_FetchServer) error
• type UnsafePubSubUIServer

Variables

var File_pubsub_ui_proto protoreflect.FileDescriptor

var PubSubUI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pubsubui.PubSubUI",
	HandlerType: (*PubSubUIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Fetch",
			Handler:       _PubSubUI_Fetch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pubsub_ui.proto",
}

PubSubUI_ServiceDesc is the grpc.ServiceDesc for PubSubUI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPubSubUIServer

func RegisterPubSubUIServer(s grpc.ServiceRegistrar, srv PubSubUIServer)

Types

type Message

type Message struct {
	Data      []byte               `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData

func (x *Message) GetData() []byte

func (*Message) GetTimestamp

func (x *Message) GetTimestamp() *timestamp.Timestamp

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

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

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type PubSubUIClient

type PubSubUIClient interface {
	// Fetch PubSub message from the provided PubSub Topic
	Fetch(ctx context.Context, in *TopicSubscription, opts ...grpc.CallOption) (PubSubUI_FetchClient, error)
}

PubSubUIClient is the client API for PubSubUI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPubSubUIClient

func NewPubSubUIClient(cc grpc.ClientConnInterface) PubSubUIClient

type PubSubUIServer

type PubSubUIServer interface {
	// Fetch PubSub message from the provided PubSub Topic
	Fetch(*TopicSubscription, PubSubUI_FetchServer) error
	// contains filtered or unexported methods
}

PubSubUIServer is the server API for PubSubUI service. All implementations must embed UnimplementedPubSubUIServer for forward compatibility

type PubSubUI_FetchClient

type PubSubUI_FetchClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type PubSubUI_FetchServer

type PubSubUI_FetchServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type TopicSubscription

type TopicSubscription struct {
	GcpProjectId    string `protobuf:"bytes,1,opt,name=gcp_project_id,json=gcpProjectId,proto3" json:"gcp_project_id,omitempty"`
	PubsubTopicName string `protobuf:"bytes,2,opt,name=pubsub_topic_name,json=pubsubTopicName,proto3" json:"pubsub_topic_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicSubscription) Descriptor

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

Deprecated: Use TopicSubscription.ProtoReflect.Descriptor instead.

func (*TopicSubscription) GetGcpProjectId

func (x *TopicSubscription) GetGcpProjectId() string

func (*TopicSubscription) GetPubsubTopicName

func (x *TopicSubscription) GetPubsubTopicName() string

func (*TopicSubscription) ProtoMessage

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect

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

func (*TopicSubscription) Reset

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String

func (x *TopicSubscription) String() string

type UnimplementedPubSubUIServer

type UnimplementedPubSubUIServer struct {
}

UnimplementedPubSubUIServer must be embedded to have forward compatible implementations.

func (UnimplementedPubSubUIServer) Fetch

func (UnimplementedPubSubUIServer) Fetch(*TopicSubscription, PubSubUI_FetchServer) error

type UnsafePubSubUIServer

type UnsafePubSubUIServer interface {
	// contains filtered or unexported methods
}

UnsafePubSubUIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PubSubUIServer will result in compilation errors.