message

package

v0.0.2 Latest Latest Go to latest Published: Jan 4, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/grepplabs/backstream

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Message_Type_name = map[int32]string{
		0: "NOTIFY",
		1: "REQUEST",
		2: "RESPONSE",
	}
	Message_Type_value = map[string]int32{
		"NOTIFY":   0,
		"REQUEST":  1,
		"RESPONSE": 2,
	}
)

Enum value maps for Message_Type.

View Source

var File_internal_proto_message_proto protoreflect.FileDescriptor

Functions ¶

This section is empty.

Types ¶

type EventHTTPRequest ¶

type EventHTTPRequest struct {
	Method   string                         `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	RawPath  string                         `protobuf:"bytes,2,opt,name=rawPath,proto3" json:"rawPath,omitempty"`
	RawQuery string                         `protobuf:"bytes,3,opt,name=rawQuery,proto3" json:"rawQuery,omitempty"`
	Headers  map[string]*structpb.ListValue `` /* 155-byte string literal not displayed */
	Body     []byte                         `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*EventHTTPRequest) Descriptor deprecated

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

Deprecated: Use EventHTTPRequest.ProtoReflect.Descriptor instead.

func (*EventHTTPRequest) GetBody ¶

func (x *EventHTTPRequest) GetBody() []byte

func (*EventHTTPRequest) GetHeaders ¶

func (x *EventHTTPRequest) GetHeaders() map[string]*structpb.ListValue

func (*EventHTTPRequest) GetMethod ¶

func (x *EventHTTPRequest) GetMethod() string

func (*EventHTTPRequest) GetRawPath ¶

func (x *EventHTTPRequest) GetRawPath() string

func (*EventHTTPRequest) GetRawQuery ¶

func (x *EventHTTPRequest) GetRawQuery() string

func (*EventHTTPRequest) ProtoMessage ¶

func (*EventHTTPRequest) ProtoMessage()

func (*EventHTTPRequest) ProtoReflect ¶

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

func (*EventHTTPRequest) Reset ¶

func (x *EventHTTPRequest) Reset()

func (*EventHTTPRequest) String ¶

func (x *EventHTTPRequest) String() string

type EventHTTPResponse ¶

type EventHTTPResponse struct {
	StatusCode int32                          `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Headers    map[string]*structpb.ListValue `` /* 155-byte string literal not displayed */
	Body       []byte                         `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*EventHTTPResponse) Descriptor deprecated

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

Deprecated: Use EventHTTPResponse.ProtoReflect.Descriptor instead.

func (*EventHTTPResponse) GetBody ¶

func (x *EventHTTPResponse) GetBody() []byte

func (*EventHTTPResponse) GetHeaders ¶

func (x *EventHTTPResponse) GetHeaders() map[string]*structpb.ListValue

func (*EventHTTPResponse) GetStatusCode ¶

func (x *EventHTTPResponse) GetStatusCode() int32

func (*EventHTTPResponse) ProtoMessage ¶

func (*EventHTTPResponse) ProtoMessage()

func (*EventHTTPResponse) ProtoReflect ¶

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

func (*EventHTTPResponse) Reset ¶

func (x *EventHTTPResponse) Reset()

func (*EventHTTPResponse) String ¶

func (x *EventHTTPResponse) String() string

type Message ¶

type Message struct {
	Id   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type Message_Type `protobuf:"varint,2,opt,name=type,proto3,enum=backstream.Message_Type" json:"type,omitempty"`
	Data []byte       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData ¶

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

func (*Message) GetId ¶

func (x *Message) GetId() string

func (*Message) GetType ¶

func (x *Message) GetType() Message_Type

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_Type ¶

type Message_Type int32

const (
	Message_NOTIFY   Message_Type = 0
	Message_REQUEST  Message_Type = 1
	Message_RESPONSE Message_Type = 2
)

func (Message_Type) Descriptor ¶

func (Message_Type) Descriptor() protoreflect.EnumDescriptor

func (Message_Type) Enum ¶

func (x Message_Type) Enum() *Message_Type

func (Message_Type) EnumDescriptor deprecated

func (Message_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Message_Type.Descriptor instead.

func (Message_Type) Number ¶

func (x Message_Type) Number() protoreflect.EnumNumber

func (Message_Type) String ¶

func (x Message_Type) String() string

func (Message_Type) Type ¶

func (Message_Type) Type() protoreflect.EnumType

Source Files ¶

View all Source files

message.pb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL