pubsubv1

package
v0.0.0-...-f01885d Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 23 Imported by: 3

Documentation

Overview

Code generated by protoc-gen-go-resource. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var File_connect_pubsub_v1_pubsub_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type NopPubsubServiceClient 

type NopPubsubServiceClient struct{}

NopPubsubServiceClient is a no-op client for the google.pubsub.v1.PubsubService service.

func (*NopPubsubServiceClient) PushPubsubMessage 

func (*NopPubsubServiceClient) PushPubsubMessage(context.Context, *PubsubMessage) error

PushPubsubMessage implements pubsubv1.PubsubServiceClient.

type ParsedProjectName 

type ParsedProjectName struct {
	ProjectID string
}

func ParseFullProjectName 

func ParseFullProjectName(s string) (ParsedProjectName, error)

func ParseProjectName 

func ParseProjectName(s string) (ParsedProjectName, error)

func (ParsedProjectName) FullName 

func (n ParsedProjectName) FullName() string

func (ParsedProjectName) Key 

func (x ParsedProjectName) Key() string

Key returns the key path.

func (ParsedProjectName) Name 

func (n ParsedProjectName) Name() string

func (ParsedProjectName) String 

func (x ParsedProjectName) String() string

String returns the string representation.

type ParsedTopicName 

type ParsedTopicName struct {
	ProjectID string

	TopicID string
}

func ParseFullTopicName 

func ParseFullTopicName(s string) (ParsedTopicName, error)

func ParseTopicName 

func ParseTopicName(s string) (ParsedTopicName, error)

func (ParsedTopicName) FullName 

func (n ParsedTopicName) FullName() string

func (ParsedTopicName) Key 

func (x ParsedTopicName) Key() string

Key returns the key path.

func (ParsedTopicName) Name 

func (n ParsedTopicName) Name() string

func (ParsedTopicName) Parent 

func (x ParsedTopicName) Parent() ParsedProjectName

Parent returns the parent name.

func (ParsedTopicName) String 

func (x ParsedTopicName) String() string

String returns the string representation.

type PubsubMessage 

type PubsubMessage struct {

	// The message payload. For JSON requests, the value of this field must be
	// base64-encoded.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Attributes for this message.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

A message data and its attributes.

func (*PubsubMessage) Default 

func (x *PubsubMessage) Default()

func (*PubsubMessage) Descriptor deprecated 

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

Deprecated: Use PubsubMessage.ProtoReflect.Descriptor instead.

func (*PubsubMessage) GetAttributes 

func (x *PubsubMessage) GetAttributes() map[string]string

func (*PubsubMessage) GetData 

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

func (*PubsubMessage) MarshalJSON 

func (msg *PubsubMessage) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*PubsubMessage) ProtoMessage 

func (*PubsubMessage) ProtoMessage()

func (*PubsubMessage) ProtoReflect 

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

func (*PubsubMessage) Reset 

func (x *PubsubMessage) Reset()

func (*PubsubMessage) String 

func (x *PubsubMessage) String() string

func (*PubsubMessage) UnmarshalJSON 

func (msg *PubsubMessage) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*PubsubMessage) Validate 

func (m *PubsubMessage) Validate() error

Validate checks the field values on PubsubMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PubsubMessage) ValidateAll 

func (m *PubsubMessage) ValidateAll() error

ValidateAll checks the field values on PubsubMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PubsubMessageMultiError, or nil if none found.

type PubsubMessageMultiError 

type PubsubMessageMultiError []error

PubsubMessageMultiError is an error wrapping multiple validation errors returned by PubsubMessage.ValidateAll() if the designated constraints aren't met.

func (PubsubMessageMultiError) AllErrors 

func (m PubsubMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PubsubMessageMultiError) Error 

func (m PubsubMessageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PubsubMessageValidationError 

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

PubsubMessageValidationError is the validation error returned by PubsubMessage.Validate if the designated constraints aren't met.

func (PubsubMessageValidationError) Cause 

func (e PubsubMessageValidationError) Cause() error

Cause function returns cause value.

func (PubsubMessageValidationError) Error 

func (e PubsubMessageValidationError) Error() string

Error satisfies the builtin error interface

func (PubsubMessageValidationError) ErrorName 

func (e PubsubMessageValidationError) ErrorName() string

ErrorName returns error name.

func (PubsubMessageValidationError) Field 

func (e PubsubMessageValidationError) Field() string

Field function returns field value.

func (PubsubMessageValidationError) Key 

func (e PubsubMessageValidationError) Key() bool

Key function returns key value.

func (PubsubMessageValidationError) Reason 

func (e PubsubMessageValidationError) Reason() string

Reason function returns reason value.

type PubsubService 

type PubsubService interface {
	// PushPubsubMessage processes a given message.
	PushPubsubMessage(context.Context, *PushPubsubMessageRequest) (*PushPubsubMessageResponse, error)
}

PubsubService is an implementation of the google.pubsub.v1.PubsubService service.

type PubsubServiceClient 

type PubsubServiceClient interface {
	// PushPubsubMessage pushes a given message to google.pubsub.v1.PubsubService service.
	PushPubsubMessage(context.Context, *PubsubMessage) error
}

PubsusbServiceClient is an implementation of the google.pubsub.v1.PubsubServiceClient client.

type PushPubsubMessageRequest 

type PushPubsubMessageRequest struct {

	// The subscription from which messages should be pulled.
	Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// The message.
	Message *PubsubMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

PushPubsubMessageRequest represents a request for google.pubsub.v1.PubsubService.PushPubsubMessage method.

func (*PushPubsubMessageRequest) Default 

func (x *PushPubsubMessageRequest) Default()

func (*PushPubsubMessageRequest) Descriptor deprecated 

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

Deprecated: Use PushPubsubMessageRequest.ProtoReflect.Descriptor instead.

func (*PushPubsubMessageRequest) GetMessage 

func (x *PushPubsubMessageRequest) GetMessage() *PubsubMessage

func (*PushPubsubMessageRequest) GetSubscription 

func (x *PushPubsubMessageRequest) GetSubscription() string

func (*PushPubsubMessageRequest) MarshalJSON 

func (msg *PushPubsubMessageRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*PushPubsubMessageRequest) ProtoMessage 

func (*PushPubsubMessageRequest) ProtoMessage()

func (*PushPubsubMessageRequest) ProtoReflect 

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

func (*PushPubsubMessageRequest) Reset 

func (x *PushPubsubMessageRequest) Reset()

func (*PushPubsubMessageRequest) String 

func (x *PushPubsubMessageRequest) String() string

func (*PushPubsubMessageRequest) UnmarshalJSON 

func (msg *PushPubsubMessageRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*PushPubsubMessageRequest) Validate 

func (m *PushPubsubMessageRequest) Validate() error

Validate checks the field values on PushPubsubMessageRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PushPubsubMessageRequest) ValidateAll 

func (m *PushPubsubMessageRequest) ValidateAll() error

ValidateAll checks the field values on PushPubsubMessageRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushPubsubMessageRequestMultiError, or nil if none found.

type PushPubsubMessageRequestMultiError 

type PushPubsubMessageRequestMultiError []error

PushPubsubMessageRequestMultiError is an error wrapping multiple validation errors returned by PushPubsubMessageRequest.ValidateAll() if the designated constraints aren't met.

func (PushPubsubMessageRequestMultiError) AllErrors 

func (m PushPubsubMessageRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PushPubsubMessageRequestMultiError) Error 

func (m PushPubsubMessageRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PushPubsubMessageRequestValidationError 

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

PushPubsubMessageRequestValidationError is the validation error returned by PushPubsubMessageRequest.Validate if the designated constraints aren't met.

func (PushPubsubMessageRequestValidationError) Cause 

func (e PushPubsubMessageRequestValidationError) Cause() error

Cause function returns cause value.

func (PushPubsubMessageRequestValidationError) Error 

func (e PushPubsubMessageRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PushPubsubMessageRequestValidationError) ErrorName 

func (e PushPubsubMessageRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PushPubsubMessageRequestValidationError) Field 

func (e PushPubsubMessageRequestValidationError) Field() string

Field function returns field value.

func (PushPubsubMessageRequestValidationError) Key 

func (e PushPubsubMessageRequestValidationError) Key() bool

Key function returns key value.

func (PushPubsubMessageRequestValidationError) Reason 

func (e PushPubsubMessageRequestValidationError) Reason() string

Reason function returns reason value.

type PushPubsubMessageResponse 

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

PushPubsubMessageResponse represents a response for google.pubsub.v1.PubsubService.PushPubsubMessage method.

func (*PushPubsubMessageResponse) Default 

func (x *PushPubsubMessageResponse) Default()

func (*PushPubsubMessageResponse) Descriptor deprecated 

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

Deprecated: Use PushPubsubMessageResponse.ProtoReflect.Descriptor instead.

func (*PushPubsubMessageResponse) MarshalJSON 

func (msg *PushPubsubMessageResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*PushPubsubMessageResponse) ProtoMessage 

func (*PushPubsubMessageResponse) ProtoMessage()

func (*PushPubsubMessageResponse) ProtoReflect 

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

func (*PushPubsubMessageResponse) Reset 

func (x *PushPubsubMessageResponse) Reset()

func (*PushPubsubMessageResponse) String 

func (x *PushPubsubMessageResponse) String() string

func (*PushPubsubMessageResponse) UnmarshalJSON 

func (msg *PushPubsubMessageResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*PushPubsubMessageResponse) Validate 

func (m *PushPubsubMessageResponse) Validate() error

Validate checks the field values on PushPubsubMessageResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PushPubsubMessageResponse) ValidateAll 

func (m *PushPubsubMessageResponse) ValidateAll() error

ValidateAll checks the field values on PushPubsubMessageResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushPubsubMessageResponseMultiError, or nil if none found.

type PushPubsubMessageResponseMultiError 

type PushPubsubMessageResponseMultiError []error

PushPubsubMessageResponseMultiError is an error wrapping multiple validation errors returned by PushPubsubMessageResponse.ValidateAll() if the designated constraints aren't met.

func (PushPubsubMessageResponseMultiError) AllErrors 

func (m PushPubsubMessageResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PushPubsubMessageResponseMultiError) Error 

func (m PushPubsubMessageResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PushPubsubMessageResponseValidationError 

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

PushPubsubMessageResponseValidationError is the validation error returned by PushPubsubMessageResponse.Validate if the designated constraints aren't met.

func (PushPubsubMessageResponseValidationError) Cause 

func (e PushPubsubMessageResponseValidationError) Cause() error

Cause function returns cause value.

func (PushPubsubMessageResponseValidationError) Error 

func (e PushPubsubMessageResponseValidationError) Error() string

Error satisfies the builtin error interface

func (PushPubsubMessageResponseValidationError) ErrorName 

func (e PushPubsubMessageResponseValidationError) ErrorName() string

ErrorName returns error name.

func (PushPubsubMessageResponseValidationError) Field 

func (e PushPubsubMessageResponseValidationError) Field() string

Field function returns field value.

func (PushPubsubMessageResponseValidationError) Key 

func (e PushPubsubMessageResponseValidationError) Key() bool

Key function returns key value.

func (PushPubsubMessageResponseValidationError) Reason 

func (e PushPubsubMessageResponseValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.