pb

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2021 License: Apache-2.0 Imports: 26 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_legacy_upstream_proto protoreflect.FileDescriptor

Functions

func RegisterUpstreamServiceHandler 

func RegisterUpstreamServiceHandler(r http.Router, srv UpstreamServiceHandler, opts ...http.HandleOption)

RegisterUpstreamServiceHandler register UpstreamServiceHandler to http.Router.

func RegisterUpstreamServiceImp 

func RegisterUpstreamServiceImp(regester transport.Register, srv UpstreamServiceServer, opts ...transport.ServiceOption)

RegisterUpstreamServiceImp legacy_upstream.proto

func RegisterUpstreamServiceServer 

func RegisterUpstreamServiceServer(s grpc1.ServiceRegistrar, srv UpstreamServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func Types 

func Types() []reflect.Type

func UpstreamServiceClientType 

func UpstreamServiceClientType() reflect.Type

UpstreamServiceClientType .

func UpstreamServiceHandlerType 

func UpstreamServiceHandlerType() reflect.Type

UpstreamServiceHandlerType .

func UpstreamServiceServerType 

func UpstreamServiceServerType() reflect.Type

UpstreamServiceServerType .

Types

type AsyncRegisterRequest 

type AsyncRegisterRequest struct {
	Upstream *Upstream `protobuf:"bytes,1,opt,name=upstream,proto3" json:"upstream,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncRegisterRequest) Descriptor deprecated 

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

Deprecated: Use AsyncRegisterRequest.ProtoReflect.Descriptor instead.

func (*AsyncRegisterRequest) GetUpstream 

func (x *AsyncRegisterRequest) GetUpstream() *Upstream

func (*AsyncRegisterRequest) MarshalJSON 

func (m *AsyncRegisterRequest) MarshalJSON() ([]byte, error)

AsyncRegisterRequest implement json.Marshaler.

func (*AsyncRegisterRequest) ProtoMessage 

func (*AsyncRegisterRequest) ProtoMessage()

func (*AsyncRegisterRequest) ProtoReflect 

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

func (*AsyncRegisterRequest) Reset 

func (x *AsyncRegisterRequest) Reset()

func (*AsyncRegisterRequest) String 

func (x *AsyncRegisterRequest) String() string

func (*AsyncRegisterRequest) UnmarshalJSON 

func (m *AsyncRegisterRequest) UnmarshalJSON(b []byte) error

AsyncRegisterRequest implement json.Marshaler.

func (*AsyncRegisterRequest) UnmarshalURLValues 

func (m *AsyncRegisterRequest) UnmarshalURLValues(prefix string, values url.Values) error

AsyncRegisterRequest implement urlenc.URLValuesUnmarshaler.

func (*AsyncRegisterRequest) Validate 

func (this *AsyncRegisterRequest) Validate() error

type AsyncRegisterResponse 

type AsyncRegisterResponse struct {
	Data bool `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncRegisterResponse) Descriptor deprecated 

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

Deprecated: Use AsyncRegisterResponse.ProtoReflect.Descriptor instead.

func (*AsyncRegisterResponse) GetData 

func (x *AsyncRegisterResponse) GetData() bool

func (*AsyncRegisterResponse) MarshalJSON 

func (m *AsyncRegisterResponse) MarshalJSON() ([]byte, error)

AsyncRegisterResponse implement json.Marshaler.

func (*AsyncRegisterResponse) ProtoMessage 

func (*AsyncRegisterResponse) ProtoMessage()

func (*AsyncRegisterResponse) ProtoReflect 

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

func (*AsyncRegisterResponse) Reset 

func (x *AsyncRegisterResponse) Reset()

func (*AsyncRegisterResponse) String 

func (x *AsyncRegisterResponse) String() string

func (*AsyncRegisterResponse) UnmarshalJSON 

func (m *AsyncRegisterResponse) UnmarshalJSON(b []byte) error

AsyncRegisterResponse implement json.Marshaler.

func (*AsyncRegisterResponse) UnmarshalURLValues 

func (m *AsyncRegisterResponse) UnmarshalURLValues(prefix string, values url.Values) error

AsyncRegisterResponse implement urlenc.URLValuesUnmarshaler.

func (*AsyncRegisterResponse) Validate 

func (this *AsyncRegisterResponse) Validate() error

type RegisterRequest 

type RegisterRequest struct {
	Upstream *Upstream `protobuf:"bytes,1,opt,name=upstream,proto3" json:"upstream,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetUpstream 

func (x *RegisterRequest) GetUpstream() *Upstream

func (*RegisterRequest) MarshalJSON 

func (m *RegisterRequest) MarshalJSON() ([]byte, error)

RegisterRequest implement json.Marshaler.

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

func (*RegisterRequest) UnmarshalJSON 

func (m *RegisterRequest) UnmarshalJSON(b []byte) error

RegisterRequest implement json.Marshaler.

func (*RegisterRequest) UnmarshalURLValues 

func (m *RegisterRequest) UnmarshalURLValues(prefix string, values url.Values) error

RegisterRequest implement urlenc.URLValuesUnmarshaler.

func (*RegisterRequest) Validate 

func (this *RegisterRequest) Validate() error

type RegisterResponse 

type RegisterResponse struct {
	Data bool `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetData 

func (x *RegisterResponse) GetData() bool

func (*RegisterResponse) MarshalJSON 

func (m *RegisterResponse) MarshalJSON() ([]byte, error)

RegisterResponse implement json.Marshaler.

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

func (*RegisterResponse) UnmarshalJSON 

func (m *RegisterResponse) UnmarshalJSON(b []byte) error

RegisterResponse implement json.Marshaler.

func (*RegisterResponse) UnmarshalURLValues 

func (m *RegisterResponse) UnmarshalURLValues(prefix string, values url.Values) error

RegisterResponse implement urlenc.URLValuesUnmarshaler.

func (*RegisterResponse) Validate 

func (this *RegisterResponse) Validate() error

type UnimplementedUpstreamServiceServer 

type UnimplementedUpstreamServiceServer struct {
}

UnimplementedUpstreamServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedUpstreamServiceServer) AsyncRegister 

func (*UnimplementedUpstreamServiceServer) AsyncRegister(context.Context, *AsyncRegisterRequest) (*AsyncRegisterResponse, error)

func (*UnimplementedUpstreamServiceServer) Register 

func (*UnimplementedUpstreamServiceServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

type Upstream 

type Upstream struct {
	Az          string         `protobuf:"bytes,1,opt,name=az,proto3" json:"az,omitempty"`
	DiceAppId   string         `protobuf:"bytes,2,opt,name=diceAppId,proto3" json:"diceAppId,omitempty"`
	DiceService string         `protobuf:"bytes,3,opt,name=diceService,proto3" json:"diceService,omitempty"`
	RuntimeName string         `protobuf:"bytes,4,opt,name=runtimeName,proto3" json:"runtimeName,omitempty"`
	RuntimeId   string         `protobuf:"bytes,5,opt,name=runtimeId,proto3" json:"runtimeId,omitempty"`
	AppName     string         `protobuf:"bytes,6,opt,name=appName,proto3" json:"appName,omitempty"`
	ServiceName string         `protobuf:"bytes,7,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	OrgId       string         `protobuf:"bytes,8,opt,name=orgId,proto3" json:"orgId,omitempty"`
	ProjectId   string         `protobuf:"bytes,9,opt,name=projectId,proto3" json:"projectId,omitempty"`
	Env         string         `protobuf:"bytes,10,opt,name=env,proto3" json:"env,omitempty"`
	ApiList     []*UpstreamApi `protobuf:"bytes,11,rep,name=apiList,proto3" json:"apiList,omitempty"`
	RegisterId  int32          `protobuf:"varint,12,opt,name=registerId,proto3" json:"registerId,omitempty"`
	RegisterTag string         `protobuf:"bytes,13,opt,name=registerTag,proto3" json:"registerTag,omitempty"`
	PathPrefix  string         `protobuf:"bytes,14,opt,name=pathPrefix,proto3" json:"pathPrefix,omitempty"`
	// contains filtered or unexported fields
}

func (*Upstream) Descriptor deprecated 

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

Deprecated: Use Upstream.ProtoReflect.Descriptor instead.

func (*Upstream) GetApiList 

func (x *Upstream) GetApiList() []*UpstreamApi

func (*Upstream) GetAppName 

func (x *Upstream) GetAppName() string

func (*Upstream) GetAz 

func (x *Upstream) GetAz() string

func (*Upstream) GetDiceAppId 

func (x *Upstream) GetDiceAppId() string

func (*Upstream) GetDiceService 

func (x *Upstream) GetDiceService() string

func (*Upstream) GetEnv 

func (x *Upstream) GetEnv() string

func (*Upstream) GetOrgId 

func (x *Upstream) GetOrgId() string

func (*Upstream) GetPathPrefix 

func (x *Upstream) GetPathPrefix() string

func (*Upstream) GetProjectId 

func (x *Upstream) GetProjectId() string

func (*Upstream) GetRegisterId 

func (x *Upstream) GetRegisterId() int32

func (*Upstream) GetRegisterTag 

func (x *Upstream) GetRegisterTag() string

func (*Upstream) GetRuntimeId 

func (x *Upstream) GetRuntimeId() string

func (*Upstream) GetRuntimeName 

func (x *Upstream) GetRuntimeName() string

func (*Upstream) GetServiceName 

func (x *Upstream) GetServiceName() string

func (*Upstream) MarshalJSON 

func (m *Upstream) MarshalJSON() ([]byte, error)

Upstream implement json.Marshaler.

func (*Upstream) ProtoMessage 

func (*Upstream) ProtoMessage()

func (*Upstream) ProtoReflect 

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

func (*Upstream) Reset 

func (x *Upstream) Reset()

func (*Upstream) String 

func (x *Upstream) String() string

func (*Upstream) UnmarshalJSON 

func (m *Upstream) UnmarshalJSON(b []byte) error

Upstream implement json.Marshaler.

func (*Upstream) UnmarshalURLValues 

func (m *Upstream) UnmarshalURLValues(prefix string, values url.Values) error

Upstream implement urlenc.URLValuesUnmarshaler.

func (*Upstream) Validate 

func (this *Upstream) Validate() error

type UpstreamApi 

type UpstreamApi struct {
	Path        string          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	GatewayPath string          `protobuf:"bytes,2,opt,name=gatewayPath,proto3" json:"gatewayPath,omitempty"`
	Method      string          `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Address     string          `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	IsInner     bool            `protobuf:"varint,5,opt,name=isInner,proto3" json:"isInner,omitempty"`
	IsCustom    bool            `protobuf:"varint,6,opt,name=isCustom,proto3" json:"isCustom,omitempty"`
	Doc         *structpb.Value `protobuf:"bytes,7,opt,name=doc,proto3" json:"doc,omitempty"`
	Name        string          `protobuf:"bytes,8,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamApi) Descriptor deprecated 

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

Deprecated: Use UpstreamApi.ProtoReflect.Descriptor instead.

func (*UpstreamApi) GetAddress 

func (x *UpstreamApi) GetAddress() string

func (*UpstreamApi) GetDoc 

func (x *UpstreamApi) GetDoc() *structpb.Value

func (*UpstreamApi) GetGatewayPath 

func (x *UpstreamApi) GetGatewayPath() string

func (*UpstreamApi) GetIsCustom 

func (x *UpstreamApi) GetIsCustom() bool

func (*UpstreamApi) GetIsInner 

func (x *UpstreamApi) GetIsInner() bool

func (*UpstreamApi) GetMethod 

func (x *UpstreamApi) GetMethod() string

func (*UpstreamApi) GetName 

func (x *UpstreamApi) GetName() string

func (*UpstreamApi) GetPath 

func (x *UpstreamApi) GetPath() string

func (*UpstreamApi) MarshalJSON 

func (m *UpstreamApi) MarshalJSON() ([]byte, error)

UpstreamApi implement json.Marshaler.

func (*UpstreamApi) ProtoMessage 

func (*UpstreamApi) ProtoMessage()

func (*UpstreamApi) ProtoReflect 

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

func (*UpstreamApi) Reset 

func (x *UpstreamApi) Reset()

func (*UpstreamApi) String 

func (x *UpstreamApi) String() string

func (*UpstreamApi) UnmarshalJSON 

func (m *UpstreamApi) UnmarshalJSON(b []byte) error

UpstreamApi implement json.Marshaler.

func (*UpstreamApi) UnmarshalURLValues 

func (m *UpstreamApi) UnmarshalURLValues(prefix string, values url.Values) error

UpstreamApi implement urlenc.URLValuesUnmarshaler.

func (*UpstreamApi) Validate 

func (this *UpstreamApi) Validate() error

type UpstreamServiceClient 

type UpstreamServiceClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	AsyncRegister(ctx context.Context, in *AsyncRegisterRequest, opts ...grpc.CallOption) (*AsyncRegisterResponse, error)
}

UpstreamServiceClient is the client API for UpstreamService 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 NewUpstreamServiceClient 

func NewUpstreamServiceClient(cc grpc1.ClientConnInterface) UpstreamServiceClient

type UpstreamServiceHandler 

type UpstreamServiceHandler interface {
	// PUT /api/gateway/register
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// PUT /api/gateway/register_async
	AsyncRegister(context.Context, *AsyncRegisterRequest) (*AsyncRegisterResponse, error)
}

UpstreamServiceHandler is the server API for UpstreamService service.

type UpstreamServiceServer 

type UpstreamServiceServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	AsyncRegister(context.Context, *AsyncRegisterRequest) (*AsyncRegisterResponse, error)
}

UpstreamServiceServer is the server API for UpstreamService service. All implementations should embed UnimplementedUpstreamServiceServer for forward compatibility

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.