rxtx

package
v0.0.0-...-7c66ffc Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrorCode_name = map[int32]string{
	0: "SUCCESS",
	1: "TOO_LARGE",
	2: "NETWORK",
	3: "NOT_HANDLED",
	4: "CLIENT_ERROR",
	5: "PARAMETER",
	6: "INTERNAL",
	7: "PENDING",
	8: "TIMEOUT",
}
View Source 
var ErrorCode_value = map[string]int32{
	"SUCCESS":      0,
	"TOO_LARGE":    1,
	"NETWORK":      2,
	"NOT_HANDLED":  3,
	"CLIENT_ERROR": 4,
	"PARAMETER":    5,
	"INTERNAL":     6,
	"PENDING":      7,
	"TIMEOUT":      8,
}
View Source 
var MessageType_name = map[int32]string{
	0: "UDP",
	1: "CoAPUpstream",
	2: "CoAPPull",
	3: "CoAPPush",
	4: "UDPPull",
}
View Source 
var MessageType_value = map[string]int32{
	"UDP":          0,
	"CoAPUpstream": 1,
	"CoAPPull":     2,
	"CoAPPush":     3,
	"UDPPull":      4,
}

Functions

func RegisterRADIUSServer 

func RegisterRADIUSServer(s *grpc.Server, srv RADIUSServer)

func RegisterRxtxServer 

func RegisterRxtxServer(s *grpc.Server, srv RxtxServer)

Types

type AccessRequest 

type AccessRequest struct {
	Imsi                 int64    `protobuf:"varint,1,opt,name=imsi,proto3" json:"imsi,omitempty"`
	NasIdentifier        string   `protobuf:"bytes,2,opt,name=nas_identifier,json=nasIdentifier,proto3" json:"nas_identifier,omitempty"`
	Username             string   `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password             []byte   `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	UserLocationInfo     []byte   `protobuf:"bytes,5,opt,name=user_location_info,json=userLocationInfo,proto3" json:"user_location_info,omitempty"`
	ImsiMccMnc           string   `protobuf:"bytes,6,opt,name=imsi_mcc_mnc,json=imsiMccMnc,proto3" json:"imsi_mcc_mnc,omitempty"`
	MsTimezone           []byte   `protobuf:"bytes,7,opt,name=ms_timezone,json=msTimezone,proto3" json:"ms_timezone,omitempty"`
	Imeisv               string   `protobuf:"bytes,8,opt,name=imeisv,proto3" json:"imeisv,omitempty"`
	NasIpAddress         []byte   `protobuf:"bytes,9,opt,name=nas_ip_address,json=nasIpAddress,proto3" json:"nas_ip_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AccessRequest is sent from the gRPC-backed RADIUS server to check if devices should be allowed to connect.

func (*AccessRequest) Descriptor 

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

func (*AccessRequest) GetImeisv 

func (m *AccessRequest) GetImeisv() string

func (*AccessRequest) GetImsi 

func (m *AccessRequest) GetImsi() int64

func (*AccessRequest) GetImsiMccMnc 

func (m *AccessRequest) GetImsiMccMnc() string

func (*AccessRequest) GetMsTimezone 

func (m *AccessRequest) GetMsTimezone() []byte

func (*AccessRequest) GetNasIdentifier 

func (m *AccessRequest) GetNasIdentifier() string

func (*AccessRequest) GetNasIpAddress 

func (m *AccessRequest) GetNasIpAddress() []byte

func (*AccessRequest) GetPassword 

func (m *AccessRequest) GetPassword() []byte

func (*AccessRequest) GetUserLocationInfo 

func (m *AccessRequest) GetUserLocationInfo() []byte

func (*AccessRequest) GetUsername 

func (m *AccessRequest) GetUsername() string

func (*AccessRequest) ProtoMessage 

func (*AccessRequest) ProtoMessage()

func (*AccessRequest) Reset 

func (m *AccessRequest) Reset()

func (*AccessRequest) String 

func (m *AccessRequest) String() string

func (*AccessRequest) XXX_DiscardUnknown 

func (m *AccessRequest) XXX_DiscardUnknown()

func (*AccessRequest) XXX_Marshal 

func (m *AccessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccessRequest) XXX_Merge 

func (m *AccessRequest) XXX_Merge(src proto.Message)

func (*AccessRequest) XXX_Size 

func (m *AccessRequest) XXX_Size() int

func (*AccessRequest) XXX_Unmarshal 

func (m *AccessRequest) XXX_Unmarshal(b []byte) error

type AccessResponse 

type AccessResponse struct {
	Accepted             bool     `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	IpAddress            []byte   `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AccessResponse is the response to the gRPC-backed RADIUS server.

func (*AccessResponse) Descriptor 

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

func (*AccessResponse) GetAccepted 

func (m *AccessResponse) GetAccepted() bool

func (*AccessResponse) GetIpAddress 

func (m *AccessResponse) GetIpAddress() []byte

func (*AccessResponse) GetMessage 

func (m *AccessResponse) GetMessage() string

func (*AccessResponse) ProtoMessage 

func (*AccessResponse) ProtoMessage()

func (*AccessResponse) Reset 

func (m *AccessResponse) Reset()

func (*AccessResponse) String 

func (m *AccessResponse) String() string

func (*AccessResponse) XXX_DiscardUnknown 

func (m *AccessResponse) XXX_DiscardUnknown()

func (*AccessResponse) XXX_Marshal 

func (m *AccessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccessResponse) XXX_Merge 

func (m *AccessResponse) XXX_Merge(src proto.Message)

func (*AccessResponse) XXX_Size 

func (m *AccessResponse) XXX_Size() int

func (*AccessResponse) XXX_Unmarshal 

func (m *AccessResponse) XXX_Unmarshal(b []byte) error

type AckRequest 

type AckRequest struct {
	MessageId            int64     `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Result               ErrorCode `protobuf:"varint,2,opt,name=Result,proto3,enum=rxtx.ErrorCode" json:"Result,omitempty"`
	CoapToken            int64     `protobuf:"varint,3,opt,name=coap_token,json=coapToken,proto3" json:"coap_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

The AckRequest message is sent by the listener to the upstream server to ack or report errors. A missing result field is interpreted as success.

func (*AckRequest) Descriptor 

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

func (*AckRequest) GetCoapToken 

func (m *AckRequest) GetCoapToken() int64

func (*AckRequest) GetMessageId 

func (m *AckRequest) GetMessageId() int64

func (*AckRequest) GetResult 

func (m *AckRequest) GetResult() ErrorCode

func (*AckRequest) ProtoMessage 

func (*AckRequest) ProtoMessage()

func (*AckRequest) Reset 

func (m *AckRequest) Reset()

func (*AckRequest) String 

func (m *AckRequest) String() string

func (*AckRequest) XXX_DiscardUnknown 

func (m *AckRequest) XXX_DiscardUnknown()

func (*AckRequest) XXX_Marshal 

func (m *AckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AckRequest) XXX_Merge 

func (m *AckRequest) XXX_Merge(src proto.Message)

func (*AckRequest) XXX_Size 

func (m *AckRequest) XXX_Size() int

func (*AckRequest) XXX_Unmarshal 

func (m *AckRequest) XXX_Unmarshal(b []byte) error

type AckResponse 

type AckResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The AckResponse is sent back to the listener.

func (*AckResponse) Descriptor 

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

func (*AckResponse) ProtoMessage 

func (*AckResponse) ProtoMessage()

func (*AckResponse) Reset 

func (m *AckResponse) Reset()

func (*AckResponse) String 

func (m *AckResponse) String() string

func (*AckResponse) XXX_DiscardUnknown 

func (m *AckResponse) XXX_DiscardUnknown()

func (*AckResponse) XXX_Marshal 

func (m *AckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AckResponse) XXX_Merge 

func (m *AckResponse) XXX_Merge(src proto.Message)

func (*AckResponse) XXX_Size 

func (m *AckResponse) XXX_Size() int

func (*AckResponse) XXX_Unmarshal 

func (m *AckResponse) XXX_Unmarshal(b []byte) error

type CoAPOptions 

type CoAPOptions struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Type                 int32    `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	LocationPath         []string `protobuf:"bytes,3,rep,name=location_path,json=locationPath,proto3" json:"location_path,omitempty"`
	Path                 string   `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	ContentFormat        int32    `protobuf:"varint,5,opt,name=content_format,json=contentFormat,proto3" json:"content_format,omitempty"`
	UriQuery             []string `protobuf:"bytes,6,rep,name=uri_query,json=uriQuery,proto3" json:"uri_query,omitempty"`
	Accept               int32    `protobuf:"varint,7,opt,name=accept,proto3" json:"accept,omitempty"`
	Token                int64    `protobuf:"varint,9,opt,name=token,proto3" json:"token,omitempty"`
	TimeoutSeconds       int32    `protobuf:"varint,10,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CoAPOptions) Descriptor 

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

func (*CoAPOptions) GetAccept 

func (m *CoAPOptions) GetAccept() int32

func (*CoAPOptions) GetCode 

func (m *CoAPOptions) GetCode() int32

func (*CoAPOptions) GetContentFormat 

func (m *CoAPOptions) GetContentFormat() int32

func (*CoAPOptions) GetLocationPath 

func (m *CoAPOptions) GetLocationPath() []string

func (*CoAPOptions) GetPath 

func (m *CoAPOptions) GetPath() string

func (*CoAPOptions) GetTimeoutSeconds 

func (m *CoAPOptions) GetTimeoutSeconds() int32

func (*CoAPOptions) GetToken 

func (m *CoAPOptions) GetToken() int64

func (*CoAPOptions) GetType 

func (m *CoAPOptions) GetType() int32

func (*CoAPOptions) GetUriQuery 

func (m *CoAPOptions) GetUriQuery() []string

func (*CoAPOptions) ProtoMessage 

func (*CoAPOptions) ProtoMessage()

func (*CoAPOptions) Reset 

func (m *CoAPOptions) Reset()

func (*CoAPOptions) String 

func (m *CoAPOptions) String() string

func (*CoAPOptions) XXX_DiscardUnknown 

func (m *CoAPOptions) XXX_DiscardUnknown()

func (*CoAPOptions) XXX_Marshal 

func (m *CoAPOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CoAPOptions) XXX_Merge 

func (m *CoAPOptions) XXX_Merge(src proto.Message)

func (*CoAPOptions) XXX_Size 

func (m *CoAPOptions) XXX_Size() int

func (*CoAPOptions) XXX_Unmarshal 

func (m *CoAPOptions) XXX_Unmarshal(b []byte) error

type DownstreamRequest 

type DownstreamRequest struct {
	Origin               *Origin     `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	Type                 MessageType `protobuf:"varint,2,opt,name=type,proto3,enum=rxtx.MessageType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

DownstreamRequest polls for

func (*DownstreamRequest) Descriptor 

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

func (*DownstreamRequest) GetOrigin 

func (m *DownstreamRequest) GetOrigin() *Origin

func (*DownstreamRequest) GetType 

func (m *DownstreamRequest) GetType() MessageType

func (*DownstreamRequest) ProtoMessage 

func (*DownstreamRequest) ProtoMessage()

func (*DownstreamRequest) Reset 

func (m *DownstreamRequest) Reset()

func (*DownstreamRequest) String 

func (m *DownstreamRequest) String() string

func (*DownstreamRequest) XXX_DiscardUnknown 

func (m *DownstreamRequest) XXX_DiscardUnknown()

func (*DownstreamRequest) XXX_Marshal 

func (m *DownstreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownstreamRequest) XXX_Merge 

func (m *DownstreamRequest) XXX_Merge(src proto.Message)

func (*DownstreamRequest) XXX_Size 

func (m *DownstreamRequest) XXX_Size() int

func (*DownstreamRequest) XXX_Unmarshal 

func (m *DownstreamRequest) XXX_Unmarshal(b []byte) error

type DownstreamResponse 

type DownstreamResponse struct {
	Msg                  *Message `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownstreamResponse) Descriptor 

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

func (*DownstreamResponse) GetMsg 

func (m *DownstreamResponse) GetMsg() *Message

func (*DownstreamResponse) ProtoMessage 

func (*DownstreamResponse) ProtoMessage()

func (*DownstreamResponse) Reset 

func (m *DownstreamResponse) Reset()

func (*DownstreamResponse) String 

func (m *DownstreamResponse) String() string

func (*DownstreamResponse) XXX_DiscardUnknown 

func (m *DownstreamResponse) XXX_DiscardUnknown()

func (*DownstreamResponse) XXX_Marshal 

func (m *DownstreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownstreamResponse) XXX_Merge 

func (m *DownstreamResponse) XXX_Merge(src proto.Message)

func (*DownstreamResponse) XXX_Size 

func (m *DownstreamResponse) XXX_Size() int

func (*DownstreamResponse) XXX_Unmarshal 

func (m *DownstreamResponse) XXX_Unmarshal(b []byte) error

type ErrorCode 

type ErrorCode int32
const (
	ErrorCode_SUCCESS      ErrorCode = 0
	ErrorCode_TOO_LARGE    ErrorCode = 1
	ErrorCode_NETWORK      ErrorCode = 2
	ErrorCode_NOT_HANDLED  ErrorCode = 3
	ErrorCode_CLIENT_ERROR ErrorCode = 4
	ErrorCode_PARAMETER    ErrorCode = 5
	ErrorCode_INTERNAL     ErrorCode = 6
	ErrorCode_PENDING      ErrorCode = 7
	ErrorCode_TIMEOUT      ErrorCode = 8
)

func (ErrorCode) EnumDescriptor 

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

func (ErrorCode) String 

func (x ErrorCode) String() string

type Message 

type Message struct {
	Id                   int64        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 MessageType  `protobuf:"varint,2,opt,name=type,proto3,enum=rxtx.MessageType" json:"type,omitempty"`
	Timestamp            int64        `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RemoteAddress        []byte       `protobuf:"bytes,4,opt,name=remote_address,json=remoteAddress,proto3" json:"remote_address,omitempty"`
	RemotePort           int32        `protobuf:"varint,5,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
	LocalPort            int32        `protobuf:"varint,6,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	Payload              []byte       `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	Coap                 *CoAPOptions `protobuf:"bytes,8,opt,name=coap,proto3" json:"coap,omitempty"`
	Udp                  *UDPOptions  `protobuf:"bytes,9,opt,name=udp,proto3" json:"udp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetCoap 

func (m *Message) GetCoap() *CoAPOptions

func (*Message) GetId 

func (m *Message) GetId() int64

func (*Message) GetLocalPort 

func (m *Message) GetLocalPort() int32

func (*Message) GetPayload 

func (m *Message) GetPayload() []byte

func (*Message) GetRemoteAddress 

func (m *Message) GetRemoteAddress() []byte

func (*Message) GetRemotePort 

func (m *Message) GetRemotePort() int32

func (*Message) GetTimestamp 

func (m *Message) GetTimestamp() int64

func (*Message) GetType 

func (m *Message) GetType() MessageType

func (*Message) GetUdp 

func (m *Message) GetUdp() *UDPOptions

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

type MessageType 

type MessageType int32

Message types. CoAPPull is device-initated downstream messages, CoAP push is horde-initiated downstream messages and CoAP upstream is general CoAP upstream messages. Technically they're CoAP pull messages but it makes it easier to follow the logic when there's three kinds of coap messages. The UDP messages goes both ways; context determines wether it's upstream or downstream. 

const (
	MessageType_UDP          MessageType = 0
	MessageType_CoAPUpstream MessageType = 1
	MessageType_CoAPPull     MessageType = 2
	MessageType_CoAPPush     MessageType = 3
	MessageType_UDPPull      MessageType = 4
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type Origin 

type Origin struct {
	ApnId                int32    `protobuf:"varint,1,opt,name=apn_id,json=apnId,proto3" json:"apn_id,omitempty"`
	NasId                []int32  `protobuf:"varint,2,rep,packed,name=nas_id,json=nasId,proto3" json:"nas_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Origin tells the server where the request has originated. The APN ID must be set. The NAS ID is optional and can be set to -1 if it does not apply. If the listener is capable of routing messages to the entire APN the NAS ID can be omitted.

func (*Origin) Descriptor 

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

func (*Origin) GetApnId 

func (m *Origin) GetApnId() int32

func (*Origin) GetNasId 

func (m *Origin) GetNasId() []int32

func (*Origin) ProtoMessage 

func (*Origin) ProtoMessage()

func (*Origin) Reset 

func (m *Origin) Reset()

func (*Origin) String 

func (m *Origin) String() string

func (*Origin) XXX_DiscardUnknown 

func (m *Origin) XXX_DiscardUnknown()

func (*Origin) XXX_Marshal 

func (m *Origin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Origin) XXX_Merge 

func (m *Origin) XXX_Merge(src proto.Message)

func (*Origin) XXX_Size 

func (m *Origin) XXX_Size() int

func (*Origin) XXX_Unmarshal 

func (m *Origin) XXX_Unmarshal(b []byte) error

type RADIUSClient 

type RADIUSClient interface {
	Access(ctx context.Context, in *AccessRequest, opts ...grpc.CallOption) (*AccessResponse, error)
}

RADIUSClient is the client API for RADIUS service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRADIUSClient 

func NewRADIUSClient(cc *grpc.ClientConn) RADIUSClient

type RADIUSServer 

type RADIUSServer interface {
	Access(context.Context, *AccessRequest) (*AccessResponse, error)
}

RADIUSServer is the server API for RADIUS service.

type RxtxClient 

type RxtxClient interface {
	// PutMessage sends an upstream message. The service assumes responsibility
	// for the message when a response is sent.
	PutMessage(ctx context.Context, in *UpstreamRequest, opts ...grpc.CallOption) (*DownstreamResponse, error)
	// GetMessage returns an downstream/outbound (unsolicited) message to a
	// device.
	GetMessage(ctx context.Context, in *DownstreamRequest, opts ...grpc.CallOption) (*DownstreamResponse, error)
	// Ack acknowledges receipt and status of a message. If there's an error
	// handling the message the Result field in the request contains the error.
	Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*AckResponse, error)
}

RxtxClient is the client API for Rxtx service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRxtxClient 

func NewRxtxClient(cc *grpc.ClientConn) RxtxClient

type RxtxServer 

type RxtxServer interface {
	// PutMessage sends an upstream message. The service assumes responsibility
	// for the message when a response is sent.
	PutMessage(context.Context, *UpstreamRequest) (*DownstreamResponse, error)
	// GetMessage returns an downstream/outbound (unsolicited) message to a
	// device.
	GetMessage(context.Context, *DownstreamRequest) (*DownstreamResponse, error)
	// Ack acknowledges receipt and status of a message. If there's an error
	// handling the message the Result field in the request contains the error.
	Ack(context.Context, *AckRequest) (*AckResponse, error)
}

RxtxServer is the server API for Rxtx service.

type UDPOptions 

type UDPOptions struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UDPOptions) Descriptor 

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

func (*UDPOptions) ProtoMessage 

func (*UDPOptions) ProtoMessage()

func (*UDPOptions) Reset 

func (m *UDPOptions) Reset()

func (*UDPOptions) String 

func (m *UDPOptions) String() string

func (*UDPOptions) XXX_DiscardUnknown 

func (m *UDPOptions) XXX_DiscardUnknown()

func (*UDPOptions) XXX_Marshal 

func (m *UDPOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDPOptions) XXX_Merge 

func (m *UDPOptions) XXX_Merge(src proto.Message)

func (*UDPOptions) XXX_Size 

func (m *UDPOptions) XXX_Size() int

func (*UDPOptions) XXX_Unmarshal 

func (m *UDPOptions) XXX_Unmarshal(b []byte) error

type UpstreamRequest 

type UpstreamRequest struct {
	Origin               *Origin  `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	Redelivery           bool     `protobuf:"varint,2,opt,name=redelivery,proto3" json:"redelivery,omitempty"`
	Msg                  *Message `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
	ExpectDownstream     bool     `protobuf:"varint,6,opt,name=expect_downstream,json=expectDownstream,proto3" json:"expect_downstream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The upstream request is sent by the listener when upstream data (or a request is received)

func (*UpstreamRequest) Descriptor 

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

func (*UpstreamRequest) GetExpectDownstream 

func (m *UpstreamRequest) GetExpectDownstream() bool

func (*UpstreamRequest) GetMsg 

func (m *UpstreamRequest) GetMsg() *Message

func (*UpstreamRequest) GetOrigin 

func (m *UpstreamRequest) GetOrigin() *Origin

func (*UpstreamRequest) GetRedelivery 

func (m *UpstreamRequest) GetRedelivery() bool

func (*UpstreamRequest) ProtoMessage 

func (*UpstreamRequest) ProtoMessage()

func (*UpstreamRequest) Reset 

func (m *UpstreamRequest) Reset()

func (*UpstreamRequest) String 

func (m *UpstreamRequest) String() string

func (*UpstreamRequest) XXX_DiscardUnknown 

func (m *UpstreamRequest) XXX_DiscardUnknown()

func (*UpstreamRequest) XXX_Marshal 

func (m *UpstreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpstreamRequest) XXX_Merge 

func (m *UpstreamRequest) XXX_Merge(src proto.Message)

func (*UpstreamRequest) XXX_Size 

func (m *UpstreamRequest) XXX_Size() int

func (*UpstreamRequest) XXX_Unmarshal 

func (m *UpstreamRequest) XXX_Unmarshal(b []byte) error

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.