protobuftypes

package
v1.5.4 Latest Latest
Warning

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

 Go to latest Published: May 30, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Messaging_CreateMessage_FullMethodName         = "/tests.protobuftypes.message.v1.Messaging/CreateMessage"
	Messaging_CreateMessagesFromCSV_FullMethodName = "/tests.protobuftypes.message.v1.Messaging/CreateMessagesFromCSV"
	Messaging_ListMessages_FullMethodName          = "/tests.protobuftypes.message.v1.Messaging/ListMessages"
	Messaging_ListMessagesCSV_FullMethodName       = "/tests.protobuftypes.message.v1.Messaging/ListMessagesCSV"
	Messaging_GetMessage_FullMethodName            = "/tests.protobuftypes.message.v1.Messaging/GetMessage"
	Messaging_UpdateMessage_FullMethodName         = "/tests.protobuftypes.message.v1.Messaging/UpdateMessage"
)

Variables

View Source 
var File_example_api_tests_protobuftypes_message_proto protoreflect.FileDescriptor
View Source 
var Messaging_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tests.protobuftypes.message.v1.Messaging",
	HandlerType: (*MessagingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateMessage",
			Handler:    _Messaging_CreateMessage_Handler,
		},
		{
			MethodName: "CreateMessagesFromCSV",
			Handler:    _Messaging_CreateMessagesFromCSV_Handler,
		},
		{
			MethodName: "ListMessages",
			Handler:    _Messaging_ListMessages_Handler,
		},
		{
			MethodName: "ListMessagesCSV",
			Handler:    _Messaging_ListMessagesCSV_Handler,
		},
		{
			MethodName: "GetMessage",
			Handler:    _Messaging_GetMessage_Handler,
		},
		{
			MethodName: "UpdateMessage",
			Handler:    _Messaging_UpdateMessage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "example/api/tests/protobuftypes/message.proto",
}

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

Functions

func MessagingServiceRoutes 

func MessagingServiceRoutes(svc MessagingService, opts ...gors.Option) []gors.Route

func RegisterMessagingServer 

func RegisterMessagingServer(s grpc.ServiceRegistrar, srv MessagingServer)

Types

type Message 

type Message struct {
	MessageId             string              `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	StringType            string              `protobuf:"bytes,2,opt,name=string_type,json=stringType,proto3" json:"string_type,omitempty"`
	RecursiveType         *RecursiveParent    `protobuf:"bytes,3,opt,name=recursive_type,json=recursiveType,proto3" json:"recursive_type,omitempty"`
	EmbeddedType          *Message_EmbMessage `protobuf:"bytes,4,opt,name=embedded_type,json=embeddedType,proto3" json:"embedded_type,omitempty"`
	SubType               *SubMessage         `protobuf:"bytes,5,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"`
	RepeatedType          []string            `protobuf:"bytes,6,rep,name=repeated_type,json=repeatedType,proto3" json:"repeated_type,omitempty"`
	RepeatedSubType       []*SubMessage       `protobuf:"bytes,7,rep,name=repeated_sub_type,json=repeatedSubType,proto3" json:"repeated_sub_type,omitempty"`
	RepeatedRecursiveType []*RecursiveParent  `` /* 126-byte string literal not displayed */
	MapType               map[string]string   `` /* 170-byte string literal not displayed */
	Body                  *structpb.Struct    `protobuf:"bytes,10,opt,name=body,proto3" json:"body,omitempty"`
	Media                 []*structpb.Struct  `protobuf:"bytes,11,rep,name=media,proto3" json:"media,omitempty"`
	NotUsed               *emptypb.Empty      `protobuf:"bytes,12,opt,name=not_used,json=notUsed,proto3" json:"not_used,omitempty"`
	// Description of value
	ValueType *structpb.Value `protobuf:"bytes,13,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	// Description of repeated value
	RepeatedValueType []*structpb.Value       `protobuf:"bytes,14,rep,name=repeated_value_type,json=repeatedValueType,proto3" json:"repeated_value_type,omitempty"`
	BoolValueType     *wrapperspb.BoolValue   `protobuf:"bytes,15,opt,name=bool_value_type,json=boolValueType,proto3" json:"bool_value_type,omitempty"`
	BytesValueType    *wrapperspb.BytesValue  `protobuf:"bytes,16,opt,name=bytes_value_type,json=bytesValueType,proto3" json:"bytes_value_type,omitempty"`
	Int32ValueType    *wrapperspb.Int32Value  `protobuf:"bytes,17,opt,name=int32_value_type,json=int32ValueType,proto3" json:"int32_value_type,omitempty"`
	Uint32ValueType   *wrapperspb.UInt32Value `protobuf:"bytes,18,opt,name=uint32_value_type,json=uint32ValueType,proto3" json:"uint32_value_type,omitempty"`
	StringValueType   *wrapperspb.StringValue `protobuf:"bytes,19,opt,name=string_value_type,json=stringValueType,proto3" json:"string_value_type,omitempty"`
	Int64ValueType    *wrapperspb.Int64Value  `protobuf:"bytes,20,opt,name=int64_value_type,json=int64ValueType,proto3" json:"int64_value_type,omitempty"`
	Uint64ValueType   *wrapperspb.UInt64Value `protobuf:"bytes,21,opt,name=uint64_value_type,json=uint64ValueType,proto3" json:"uint64_value_type,omitempty"`
	FloatValueType    *wrapperspb.FloatValue  `protobuf:"bytes,22,opt,name=float_value_type,json=floatValueType,proto3" json:"float_value_type,omitempty"`
	DoubleValueType   *wrapperspb.DoubleValue `protobuf:"bytes,23,opt,name=double_value_type,json=doubleValueType,proto3" json:"double_value_type,omitempty"`
	TimestampType     *timestamppb.Timestamp  `protobuf:"bytes,24,opt,name=timestamp_type,json=timestampType,proto3" json:"timestamp_type,omitempty"`
	DurationType      *durationpb.Duration    `protobuf:"bytes,25,opt,name=duration_type,json=durationType,proto3" json:"duration_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody 

func (x *Message) GetBody() *structpb.Struct

func (*Message) GetBoolValueType 

func (x *Message) GetBoolValueType() *wrapperspb.BoolValue

func (*Message) GetBytesValueType 

func (x *Message) GetBytesValueType() *wrapperspb.BytesValue

func (*Message) GetDoubleValueType 

func (x *Message) GetDoubleValueType() *wrapperspb.DoubleValue

func (*Message) GetDurationType 

func (x *Message) GetDurationType() *durationpb.Duration

func (*Message) GetEmbeddedType 

func (x *Message) GetEmbeddedType() *Message_EmbMessage

func (*Message) GetFloatValueType 

func (x *Message) GetFloatValueType() *wrapperspb.FloatValue

func (*Message) GetInt32ValueType 

func (x *Message) GetInt32ValueType() *wrapperspb.Int32Value

func (*Message) GetInt64ValueType 

func (x *Message) GetInt64ValueType() *wrapperspb.Int64Value

func (*Message) GetMapType 

func (x *Message) GetMapType() map[string]string

func (*Message) GetMedia 

func (x *Message) GetMedia() []*structpb.Struct

func (*Message) GetMessageId 

func (x *Message) GetMessageId() string

func (*Message) GetNotUsed 

func (x *Message) GetNotUsed() *emptypb.Empty

func (*Message) GetRecursiveType 

func (x *Message) GetRecursiveType() *RecursiveParent

func (*Message) GetRepeatedRecursiveType 

func (x *Message) GetRepeatedRecursiveType() []*RecursiveParent

func (*Message) GetRepeatedSubType 

func (x *Message) GetRepeatedSubType() []*SubMessage

func (*Message) GetRepeatedType 

func (x *Message) GetRepeatedType() []string

func (*Message) GetRepeatedValueType 

func (x *Message) GetRepeatedValueType() []*structpb.Value

func (*Message) GetStringType 

func (x *Message) GetStringType() string

func (*Message) GetStringValueType 

func (x *Message) GetStringValueType() *wrapperspb.StringValue

func (*Message) GetSubType 

func (x *Message) GetSubType() *SubMessage

func (*Message) GetTimestampType 

func (x *Message) GetTimestampType() *timestamppb.Timestamp

func (*Message) GetUint32ValueType 

func (x *Message) GetUint32ValueType() *wrapperspb.UInt32Value

func (*Message) GetUint64ValueType 

func (x *Message) GetUint64ValueType() *wrapperspb.UInt64Value

func (*Message) GetValueType 

func (x *Message) GetValueType() *structpb.Value

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 Message_EmbMessage 

type Message_EmbMessage struct {
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Message_EmbMessage) Descriptor deprecated 

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

Deprecated: Use Message_EmbMessage.ProtoReflect.Descriptor instead.

func (*Message_EmbMessage) GetMessageId 

func (x *Message_EmbMessage) GetMessageId() string

func (*Message_EmbMessage) ProtoMessage 

func (*Message_EmbMessage) ProtoMessage()

func (*Message_EmbMessage) ProtoReflect 

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

func (*Message_EmbMessage) Reset 

func (x *Message_EmbMessage) Reset()

func (*Message_EmbMessage) String 

func (x *Message_EmbMessage) String() string

type MessagingClient 

type MessagingClient interface {
	CreateMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	CreateMessagesFromCSV(ctx context.Context, in *httpbody.HttpBody, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	ListMessages(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*structpb.Value, error)
	// OpenAPI does not allow requestBody in GET operations.
	// But it should not convert it to query params either.
	ListMessagesCSV(ctx context.Context, in *httpbody.HttpBody, opts ...grpc.CallOption) (*httpbody.HttpBody, error)
	GetMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	UpdateMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*structpb.Struct, error)
}

MessagingClient is the client API for Messaging 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 NewMessagingClient 

func NewMessagingClient(cc grpc.ClientConnInterface) MessagingClient

type MessagingServer 

type MessagingServer interface {
	CreateMessage(context.Context, *Message) (*Message, error)
	CreateMessagesFromCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)
	ListMessages(context.Context, *emptypb.Empty) (*structpb.Value, error)
	// OpenAPI does not allow requestBody in GET operations.
	// But it should not convert it to query params either.
	ListMessagesCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)
	GetMessage(context.Context, *Message) (*Message, error)
	UpdateMessage(context.Context, *Message) (*structpb.Struct, error)
	// contains filtered or unexported methods
}

MessagingServer is the server API for Messaging service. All implementations must embed UnimplementedMessagingServer for forward compatibility

type MessagingService 

type MessagingService interface {
	CreateMessage(context.Context, *Message) (*Message, error)
	CreateMessagesFromCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)
	ListMessages(context.Context, *emptypb.Empty) (*structpb.Value, error)
	// OpenAPI does not allow requestBody in GET operations.
	// But it should not convert it to query params either.
	ListMessagesCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)
	GetMessage(context.Context, *Message) (*Message, error)
	UpdateMessage(context.Context, *Message) (*structpb.Struct, error)
}

MessagingService is the service API for Messaging service.

type RecursiveChild 

type RecursiveChild struct {
	ChildId int32            `protobuf:"varint,1,opt,name=child_id,json=childId,proto3" json:"child_id,omitempty"`
	Parent  *RecursiveParent `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*RecursiveChild) Descriptor deprecated 

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

Deprecated: Use RecursiveChild.ProtoReflect.Descriptor instead.

func (*RecursiveChild) GetChildId 

func (x *RecursiveChild) GetChildId() int32

func (*RecursiveChild) GetParent 

func (x *RecursiveChild) GetParent() *RecursiveParent

func (*RecursiveChild) ProtoMessage 

func (*RecursiveChild) ProtoMessage()

func (*RecursiveChild) ProtoReflect 

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

func (*RecursiveChild) Reset 

func (x *RecursiveChild) Reset()

func (*RecursiveChild) String 

func (x *RecursiveChild) String() string

type RecursiveParent 

type RecursiveParent struct {
	ParentId int32           `protobuf:"varint,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Child    *RecursiveChild `protobuf:"bytes,2,opt,name=child,proto3" json:"child,omitempty"`
	// contains filtered or unexported fields
}

func (*RecursiveParent) Descriptor deprecated 

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

Deprecated: Use RecursiveParent.ProtoReflect.Descriptor instead.

func (*RecursiveParent) GetChild 

func (x *RecursiveParent) GetChild() *RecursiveChild

func (*RecursiveParent) GetParentId 

func (x *RecursiveParent) GetParentId() int32

func (*RecursiveParent) ProtoMessage 

func (*RecursiveParent) ProtoMessage()

func (*RecursiveParent) ProtoReflect 

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

func (*RecursiveParent) Reset 

func (x *RecursiveParent) Reset()

func (*RecursiveParent) String 

func (x *RecursiveParent) String() string

type SubMessage 

type SubMessage struct {
	MessageId     string         `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	SubSubMessage *SubSubMessage `protobuf:"bytes,2,opt,name=sub_sub_message,json=subSubMessage,proto3" json:"sub_sub_message,omitempty"`
	// contains filtered or unexported fields
}

func (*SubMessage) Descriptor deprecated 

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

Deprecated: Use SubMessage.ProtoReflect.Descriptor instead.

func (*SubMessage) GetMessageId 

func (x *SubMessage) GetMessageId() string

func (*SubMessage) GetSubSubMessage 

func (x *SubMessage) GetSubSubMessage() *SubSubMessage

func (*SubMessage) ProtoMessage 

func (*SubMessage) ProtoMessage()

func (*SubMessage) ProtoReflect 

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

func (*SubMessage) Reset 

func (x *SubMessage) Reset()

func (*SubMessage) String 

func (x *SubMessage) String() string

type SubSubMessage 

type SubSubMessage struct {
	MessageId string  `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Integers  []int32 `protobuf:"varint,2,rep,packed,name=integers,proto3" json:"integers,omitempty"`
	// contains filtered or unexported fields
}

func (*SubSubMessage) Descriptor deprecated 

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

Deprecated: Use SubSubMessage.ProtoReflect.Descriptor instead.

func (*SubSubMessage) GetIntegers 

func (x *SubSubMessage) GetIntegers() []int32

func (*SubSubMessage) GetMessageId 

func (x *SubSubMessage) GetMessageId() string

func (*SubSubMessage) ProtoMessage 

func (*SubSubMessage) ProtoMessage()

func (*SubSubMessage) ProtoReflect 

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

func (*SubSubMessage) Reset 

func (x *SubSubMessage) Reset()

func (*SubSubMessage) String 

func (x *SubSubMessage) String() string

type UnimplementedMessagingServer 

type UnimplementedMessagingServer struct {
}

UnimplementedMessagingServer must be embedded to have forward compatible implementations.

func (UnimplementedMessagingServer) CreateMessage 

func (UnimplementedMessagingServer) CreateMessage(context.Context, *Message) (*Message, error)

func (UnimplementedMessagingServer) CreateMessagesFromCSV 

func (UnimplementedMessagingServer) CreateMessagesFromCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)

func (UnimplementedMessagingServer) GetMessage 

func (UnimplementedMessagingServer) GetMessage(context.Context, *Message) (*Message, error)

func (UnimplementedMessagingServer) ListMessages 

func (UnimplementedMessagingServer) ListMessages(context.Context, *emptypb.Empty) (*structpb.Value, error)

func (UnimplementedMessagingServer) ListMessagesCSV 

func (UnimplementedMessagingServer) ListMessagesCSV(context.Context, *httpbody.HttpBody) (*httpbody.HttpBody, error)

func (UnimplementedMessagingServer) UpdateMessage 

func (UnimplementedMessagingServer) UpdateMessage(context.Context, *Message) (*structpb.Struct, error)

type UnsafeMessagingServer 

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

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

Source Files

View all Source files

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.