goatorepo

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_goatorepo_rpc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Body

type Body struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Body) Descriptor deprecated

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

Deprecated: Use Body.ProtoReflect.Descriptor instead.

func (*Body) GetData

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

func (*Body) ProtoMessage

func (*Body) ProtoMessage()

func (*Body) ProtoReflect

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

func (*Body) Reset

func (x *Body) Reset()

func (*Body) String

func (x *Body) String() string

type KeyValue

type KeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (x *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect

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

func (*KeyValue) Reset

func (x *KeyValue) Reset()

func (*KeyValue) String

func (x *KeyValue) String() string

type RequestHeader

type RequestHeader struct {
	Method      string      `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Headers     []*KeyValue `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	Source      string      `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Destination string      `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
	ProxyRecord []string    `protobuf:"bytes,5,rep,name=proxy_record,json=proxyRecord,proto3" json:"proxy_record,omitempty"`
	ProxyNext   []string    `protobuf:"bytes,6,rep,name=proxy_next,json=proxyNext,proto3" json:"proxy_next,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestHeader) Descriptor deprecated

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetDestination

func (x *RequestHeader) GetDestination() string

func (*RequestHeader) GetHeaders

func (x *RequestHeader) GetHeaders() []*KeyValue

func (*RequestHeader) GetMethod

func (x *RequestHeader) GetMethod() string

func (*RequestHeader) GetProxyNext

func (x *RequestHeader) GetProxyNext() []string

func (*RequestHeader) GetProxyRecord

func (x *RequestHeader) GetProxyRecord() []string

func (*RequestHeader) GetSource

func (x *RequestHeader) GetSource() string

func (*RequestHeader) ProtoMessage

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect

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

func (*RequestHeader) Reset

func (x *RequestHeader) Reset()

func (*RequestHeader) String

func (x *RequestHeader) String() string

type Reset added in v0.1.3

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

func (*Reset) Descriptor deprecated added in v0.1.3

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

Deprecated: Use Reset.ProtoReflect.Descriptor instead.

func (*Reset) GetType added in v0.1.3

func (x *Reset) GetType() string

func (*Reset) ProtoMessage added in v0.1.3

func (*Reset) ProtoMessage()

func (*Reset) ProtoReflect added in v0.1.3

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

func (*Reset) Reset added in v0.1.3

func (x *Reset) Reset()

func (*Reset) String added in v0.1.3

func (x *Reset) String() string

type ResponseStatus

type ResponseStatus struct {
	Code    int32        `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Based on https://cloud.google.com/apis/design/errors See: https://github.com/googleapis/googleapis/blob/master/google/rpc/status.proto

func (*ResponseStatus) Descriptor deprecated

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

Deprecated: Use ResponseStatus.ProtoReflect.Descriptor instead.

func (*ResponseStatus) GetCode

func (x *ResponseStatus) GetCode() int32

func (*ResponseStatus) GetDetails

func (x *ResponseStatus) GetDetails() []*anypb.Any

func (*ResponseStatus) GetMessage

func (x *ResponseStatus) GetMessage() string

func (*ResponseStatus) ProtoMessage

func (*ResponseStatus) ProtoMessage()

func (*ResponseStatus) ProtoReflect

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

func (*ResponseStatus) Reset

func (x *ResponseStatus) Reset()

func (*ResponseStatus) String

func (x *ResponseStatus) String() string

type Rpc

type Rpc struct {

	// Analogous to a "Stream Identifier" in HTTP/2: allocated by the initator of an RPC, a
	// unique identifier used to group requests and responses specific to this request.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Information identifying the request to be made; hence always set in the initial
	// request. At a minimum in such a request, the RPC method to be invoked is set. This
	// information is transferred in the URL path in HTTP/2.
	Header *RequestHeader `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	// When a request finishes, it is explicitly marked with a status code, and
	// with trailers. In HTTP/2 this is communicated with a HEADERS frame following the
	// response DATA frame, with certain canonical headers set like `grpc-status`.
	Status *ResponseStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// The actual RPC request or response data: just some opaque bytes, this is usually
	// protobuf-serialised bytes.
	Body *Body `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// Like status, this is sent as part of a response, and allows arbitrary key/values
	// to be communicated. This maps onto "Trailers" in the HTTP/2 encoding, but without
	// status-code, which is encoded explicitly above.
	Trailer *Trailer `protobuf:"bytes,5,opt,name=trailer,proto3" json:"trailer,omitempty"`
	// Abnormal reset information, like RST_STREAM in HTTP/2.
	Reset_ *Reset `protobuf:"bytes,6,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

Top-level message used for all GOAT communications.

func (*Rpc) Descriptor deprecated

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

Deprecated: Use Rpc.ProtoReflect.Descriptor instead.

func (*Rpc) GetBody

func (x *Rpc) GetBody() *Body

func (*Rpc) GetHeader

func (x *Rpc) GetHeader() *RequestHeader

func (*Rpc) GetId

func (x *Rpc) GetId() uint64

func (*Rpc) GetReset_ added in v0.1.3

func (x *Rpc) GetReset_() *Reset

func (*Rpc) GetStatus

func (x *Rpc) GetStatus() *ResponseStatus

func (*Rpc) GetTrailer

func (x *Rpc) GetTrailer() *Trailer

func (*Rpc) ProtoMessage

func (*Rpc) ProtoMessage()

func (*Rpc) ProtoReflect

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

func (*Rpc) Reset

func (x *Rpc) Reset()

func (*Rpc) String

func (x *Rpc) String() string

type Trailer

type Trailer struct {
	Metadata []*KeyValue `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Signals that a stream is done. Used only as a response.

func (*Trailer) Descriptor deprecated

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

Deprecated: Use Trailer.ProtoReflect.Descriptor instead.

func (*Trailer) GetMetadata

func (x *Trailer) GetMetadata() []*KeyValue

func (*Trailer) ProtoMessage

func (*Trailer) ProtoMessage()

func (*Trailer) ProtoReflect

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

func (*Trailer) Reset

func (x *Trailer) Reset()

func (*Trailer) String

func (x *Trailer) String() string

Jump to

Keyboard shortcuts

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