Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterDynamicProxyControllerServer(s grpc.ServiceRegistrar, srv DynamicProxyControllerServer)
- type AmqpPublisher
- type AmqpPublisherConfig
- type Config
- type Controller
- func (c *Controller) BindFrontendMapping(frontendToken, name, shareToken string, trx *sqlx.Tx) error
- func (c *Controller) FrontendMappings(_ context.Context, req *FrontendMappingsRequest) (*FrontendMappingsResponse, error)
- func (c *Controller) UnbindFrontendMapping(frontendToken, name string, trx *sqlx.Tx) error
- type DynamicProxyControllerClient
- type DynamicProxyControllerServer
- type FrontendMapping
- func (*FrontendMapping) Descriptor() ([]byte, []int)deprecated
- func (x *FrontendMapping) GetId() int64
- func (x *FrontendMapping) GetName() string
- func (x *FrontendMapping) GetShareToken() string
- func (*FrontendMapping) ProtoMessage()
- func (x *FrontendMapping) ProtoReflect() protoreflect.Message
- func (x *FrontendMapping) Reset()
- func (x *FrontendMapping) String() string
- type FrontendMappingsRequest
- func (*FrontendMappingsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FrontendMappingsRequest) GetFrontendToken() string
- func (x *FrontendMappingsRequest) GetId() int64
- func (x *FrontendMappingsRequest) GetName() string
- func (*FrontendMappingsRequest) ProtoMessage()
- func (x *FrontendMappingsRequest) ProtoReflect() protoreflect.Message
- func (x *FrontendMappingsRequest) Reset()
- func (x *FrontendMappingsRequest) String() string
- type FrontendMappingsResponse
- func (*FrontendMappingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FrontendMappingsResponse) GetFrontendMappings() []*FrontendMapping
- func (*FrontendMappingsResponse) ProtoMessage()
- func (x *FrontendMappingsResponse) ProtoReflect() protoreflect.Message
- func (x *FrontendMappingsResponse) Reset()
- func (x *FrontendMappingsResponse) String() string
- type Mapping
- type Operation
- type UnimplementedDynamicProxyControllerServer
- type UnsafeDynamicProxyControllerServer
Constants ¶
const (
DynamicProxyController_FrontendMappings_FullMethodName = "/DynamicProxyController/FrontendMappings"
)
Variables ¶
var DynamicProxyController_ServiceDesc = grpc.ServiceDesc{ ServiceName: "DynamicProxyController", HandlerType: (*DynamicProxyControllerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FrontendMappings", Handler: _DynamicProxyController_FrontendMappings_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "controller/dynamicProxyController/dynamicProxyController.proto", }
DynamicProxyController_ServiceDesc is the grpc.ServiceDesc for DynamicProxyController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_controller_dynamicProxyController_dynamicProxyController_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDynamicProxyControllerServer ¶
func RegisterDynamicProxyControllerServer(s grpc.ServiceRegistrar, srv DynamicProxyControllerServer)
Types ¶
type AmqpPublisher ¶
type AmqpPublisher struct {
// contains filtered or unexported fields
}
func NewAmqpPublisher ¶
func NewAmqpPublisher(cfg *AmqpPublisherConfig) (*AmqpPublisher, error)
func (*AmqpPublisher) Close ¶
func (p *AmqpPublisher) Close() error
type AmqpPublisherConfig ¶
type Config ¶
type Config struct {
IdentityPath string `dd:"+required"`
ServiceName string `dd:"+required"`
AmqpPublisher *AmqpPublisherConfig `dd:"+required"`
}
type Controller ¶
type Controller struct {
UnimplementedDynamicProxyControllerServer
// contains filtered or unexported fields
}
func NewController ¶
func NewController(cfg *Config, str *store.Store) (*Controller, error)
func (*Controller) BindFrontendMapping ¶
func (c *Controller) BindFrontendMapping(frontendToken, name, shareToken string, trx *sqlx.Tx) error
func (*Controller) FrontendMappings ¶
func (c *Controller) FrontendMappings(_ context.Context, req *FrontendMappingsRequest) (*FrontendMappingsResponse, error)
func (*Controller) UnbindFrontendMapping ¶
func (c *Controller) UnbindFrontendMapping(frontendToken, name string, trx *sqlx.Tx) error
type DynamicProxyControllerClient ¶
type DynamicProxyControllerClient interface {
FrontendMappings(ctx context.Context, in *FrontendMappingsRequest, opts ...grpc.CallOption) (*FrontendMappingsResponse, error)
}
DynamicProxyControllerClient is the client API for DynamicProxyController 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 NewDynamicProxyControllerClient ¶
func NewDynamicProxyControllerClient(cc grpc.ClientConnInterface) DynamicProxyControllerClient
type DynamicProxyControllerServer ¶
type DynamicProxyControllerServer interface {
FrontendMappings(context.Context, *FrontendMappingsRequest) (*FrontendMappingsResponse, error)
// contains filtered or unexported methods
}
DynamicProxyControllerServer is the server API for DynamicProxyController service. All implementations must embed UnimplementedDynamicProxyControllerServer for forward compatibility.
type FrontendMapping ¶
type FrontendMapping struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*FrontendMapping) Descriptor
deprecated
func (*FrontendMapping) Descriptor() ([]byte, []int)
Deprecated: Use FrontendMapping.ProtoReflect.Descriptor instead.
func (*FrontendMapping) GetId ¶
func (x *FrontendMapping) GetId() int64
func (*FrontendMapping) GetName ¶
func (x *FrontendMapping) GetName() string
func (*FrontendMapping) GetShareToken ¶
func (x *FrontendMapping) GetShareToken() string
func (*FrontendMapping) ProtoMessage ¶
func (*FrontendMapping) ProtoMessage()
func (*FrontendMapping) ProtoReflect ¶
func (x *FrontendMapping) ProtoReflect() protoreflect.Message
func (*FrontendMapping) Reset ¶
func (x *FrontendMapping) Reset()
func (*FrontendMapping) String ¶
func (x *FrontendMapping) String() string
type FrontendMappingsRequest ¶
type FrontendMappingsRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
FrontendToken string `protobuf:"bytes,2,opt,name=frontendToken,proto3" json:"frontendToken,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*FrontendMappingsRequest) Descriptor
deprecated
func (*FrontendMappingsRequest) Descriptor() ([]byte, []int)
Deprecated: Use FrontendMappingsRequest.ProtoReflect.Descriptor instead.
func (*FrontendMappingsRequest) GetFrontendToken ¶
func (x *FrontendMappingsRequest) GetFrontendToken() string
func (*FrontendMappingsRequest) GetId ¶
func (x *FrontendMappingsRequest) GetId() int64
func (*FrontendMappingsRequest) GetName ¶
func (x *FrontendMappingsRequest) GetName() string
func (*FrontendMappingsRequest) ProtoMessage ¶
func (*FrontendMappingsRequest) ProtoMessage()
func (*FrontendMappingsRequest) ProtoReflect ¶
func (x *FrontendMappingsRequest) ProtoReflect() protoreflect.Message
func (*FrontendMappingsRequest) Reset ¶
func (x *FrontendMappingsRequest) Reset()
func (*FrontendMappingsRequest) String ¶
func (x *FrontendMappingsRequest) String() string
type FrontendMappingsResponse ¶
type FrontendMappingsResponse struct {
FrontendMappings []*FrontendMapping `protobuf:"bytes,1,rep,name=frontendMappings,proto3" json:"frontendMappings,omitempty"`
// contains filtered or unexported fields
}
func (*FrontendMappingsResponse) Descriptor
deprecated
func (*FrontendMappingsResponse) Descriptor() ([]byte, []int)
Deprecated: Use FrontendMappingsResponse.ProtoReflect.Descriptor instead.
func (*FrontendMappingsResponse) GetFrontendMappings ¶
func (x *FrontendMappingsResponse) GetFrontendMappings() []*FrontendMapping
func (*FrontendMappingsResponse) ProtoMessage ¶
func (*FrontendMappingsResponse) ProtoMessage()
func (*FrontendMappingsResponse) ProtoReflect ¶
func (x *FrontendMappingsResponse) ProtoReflect() protoreflect.Message
func (*FrontendMappingsResponse) Reset ¶
func (x *FrontendMappingsResponse) Reset()
func (*FrontendMappingsResponse) String ¶
func (x *FrontendMappingsResponse) String() string
type UnimplementedDynamicProxyControllerServer ¶
type UnimplementedDynamicProxyControllerServer struct{}
UnimplementedDynamicProxyControllerServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedDynamicProxyControllerServer) FrontendMappings ¶
func (UnimplementedDynamicProxyControllerServer) FrontendMappings(context.Context, *FrontendMappingsRequest) (*FrontendMappingsResponse, error)
type UnsafeDynamicProxyControllerServer ¶
type UnsafeDynamicProxyControllerServer interface {
// contains filtered or unexported methods
}
UnsafeDynamicProxyControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DynamicProxyControllerServer will result in compilation errors.