pb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Fleet_Listen_FullMethodName = "/pb.Fleet/Listen"
)

Variables

View Source 
var File_fleet_proto protoreflect.FileDescriptor
View Source 
var Fleet_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Fleet",
	HandlerType: (*FleetServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _Fleet_Listen_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "fleet.proto",
}

Fleet_ServiceDesc is the grpc.ServiceDesc for Fleet service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFleetServer 

func RegisterFleetServer(s grpc.ServiceRegistrar, srv FleetServer)

Types

type Call 

type Call struct {

	// Types that are assignable to Payload:
	//
	//	*Call_ServingAt
	//	*Call_Request
	Payload isCall_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Call) Descriptor deprecated 

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

Deprecated: Use Call.ProtoReflect.Descriptor instead.

func (*Call) GetPayload 

func (m *Call) GetPayload() isCall_Payload

func (*Call) GetRequest 

func (x *Call) GetRequest() *Request

func (*Call) GetServingAt 

func (x *Call) GetServingAt() string

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) ProtoReflect 

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

func (*Call) Reset 

func (x *Call) Reset()

func (*Call) String 

func (x *Call) String() string

type Call_Request 

type Call_Request struct {
	Request *Request `protobuf:"bytes,2,opt,name=request,proto3,oneof"`
}

type Call_ServingAt 

type Call_ServingAt struct {
	ServingAt string `protobuf:"bytes,1,opt,name=servingAt,proto3,oneof"`
}

type FleetClient 

type FleetClient interface {
	Listen(ctx context.Context, opts ...grpc.CallOption) (Fleet_ListenClient, error)
}

FleetClient is the client API for Fleet service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFleetClient 

func NewFleetClient(cc grpc.ClientConnInterface) FleetClient

type FleetServer 

type FleetServer interface {
	Listen(Fleet_ListenServer) error
	// contains filtered or unexported methods
}

FleetServer is the server API for Fleet service. All implementations must embed UnimplementedFleetServer for forward compatibility

type Fleet_ListenClient 

type Fleet_ListenClient interface {
	Send(*Reply) error
	Recv() (*Call, error)
	grpc.ClientStream
}

type Fleet_ListenServer 

type Fleet_ListenServer interface {
	Send(*Call) error
	Recv() (*Reply, error)
	grpc.ServerStream
}

type HeaderFields 

type HeaderFields struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*HeaderFields) Descriptor deprecated 

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

Deprecated: Use HeaderFields.ProtoReflect.Descriptor instead.

func (*HeaderFields) GetFields 

func (x *HeaderFields) GetFields() []string

func (*HeaderFields) ProtoMessage 

func (*HeaderFields) ProtoMessage()

func (*HeaderFields) ProtoReflect 

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

func (*HeaderFields) Reset 

func (x *HeaderFields) Reset()

func (*HeaderFields) String 

func (x *HeaderFields) String() string

type Reply 

type Reply struct {

	// Types that are assignable to Payload:
	//
	//	*Reply_Subdomain
	//	*Reply_Response
	Payload isReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetPayload 

func (m *Reply) GetPayload() isReply_Payload

func (*Reply) GetResponse 

func (x *Reply) GetResponse() *Response

func (*Reply) GetSubdomain 

func (x *Reply) GetSubdomain() string

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type Reply_Response 

type Reply_Response struct {
	Response *Response `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type Reply_Subdomain 

type Reply_Subdomain struct {
	Subdomain string `protobuf:"bytes,1,opt,name=subdomain,proto3,oneof"`
}

type Request 

type Request struct {
	Id     string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Method string                   `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Url    string                   `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Body   []byte                   `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Header map[string]*HeaderFields `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetBody 

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

func (*Request) GetHeader 

func (x *Request) GetHeader() map[string]*HeaderFields

func (*Request) GetId 

func (x *Request) GetId() string

func (*Request) GetMethod 

func (x *Request) GetMethod() string

func (*Request) GetUrl 

func (x *Request) GetUrl() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Id     string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data   []byte                   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Status int32                    `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	Header map[string]*HeaderFields `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetData 

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

func (*Response) GetHeader 

func (x *Response) GetHeader() map[string]*HeaderFields

func (*Response) GetId 

func (x *Response) GetId() string

func (*Response) GetStatus 

func (x *Response) GetStatus() int32

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type UnimplementedFleetServer 

type UnimplementedFleetServer struct {
}

UnimplementedFleetServer must be embedded to have forward compatible implementations.

func (UnimplementedFleetServer) Listen 

func (UnimplementedFleetServer) Listen(Fleet_ListenServer) error

type UnsafeFleetServer 

type UnsafeFleetServer interface {
	// contains filtered or unexported methods
}

UnsafeFleetServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FleetServer will result in compilation errors.

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.