message

Documentation

Index

• Variables
• type EventHTTPRequest
  • func (*EventHTTPRequest) Descriptor() ([]byte, []int)
  • func (x *EventHTTPRequest) GetBody() []byte
  • func (x *EventHTTPRequest) GetHeaders() map[string]*structpb.ListValue
  • func (x *EventHTTPRequest) GetMethod() string
  • func (x *EventHTTPRequest) GetRawPath() string
  • func (x *EventHTTPRequest) GetRawQuery() string
  • func (*EventHTTPRequest) ProtoMessage()
  • func (x *EventHTTPRequest) ProtoReflect() protoreflect.Message
  • func (x *EventHTTPRequest) Reset()
  • func (x *EventHTTPRequest) String() string
• type EventHTTPResponse
  • func (*EventHTTPResponse) Descriptor() ([]byte, []int)
  • func (x *EventHTTPResponse) GetBody() []byte
  • func (x *EventHTTPResponse) GetHeaders() map[string]*structpb.ListValue
  • func (x *EventHTTPResponse) GetStatusCode() int32
  • func (*EventHTTPResponse) ProtoMessage()
  • func (x *EventHTTPResponse) ProtoReflect() protoreflect.Message
  • func (x *EventHTTPResponse) Reset()
  • func (x *EventHTTPResponse) String() string
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetData() []byte
  • func (x *Message) GetId() string
  • func (x *Message) GetType() Message_Type
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Message_Type
  • func (Message_Type) Descriptor() protoreflect.EnumDescriptor
  • func (x Message_Type) Enum() *Message_Type
  • func (Message_Type) EnumDescriptor() ([]byte, []int)
  • func (x Message_Type) Number() protoreflect.EnumNumber
  • func (x Message_Type) String() string
  • func (Message_Type) Type() protoreflect.EnumType

Variables

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.

var File_internal_proto_message_proto protoreflect.FileDescriptor

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

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

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

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

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