goatorepo

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 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

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.