Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)
- type AdminClient
- type AdminClients
- type AdminClientsMulticast
- type AdminClientsUnicast
- type AdminServer
- type AdminServerRouter
- type AdminServerRouterHandler
- type AdminServerRouterMiddleware
- type AdminServerRouterMiddlewareContext
- type Admin_ReloadResource1Client
- type Admin_ReloadResource1Client_MulticastResult
- func (r *Admin_ReloadResource1Client_MulticastResult) Error() error
- func (r *Admin_ReloadResource1Client_MulticastResult) ErrorCount() int
- func (r *Admin_ReloadResource1Client_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *Admin_ReloadResource1Client_MulticastResult) Errors(index int) error
- func (r *Admin_ReloadResource1Client_MulticastResult) PeerCount() int
- func (r *Admin_ReloadResource1Client_MulticastResult) Response(index int) Admin_ReloadResource1Client
- func (r *Admin_ReloadResource1Client_MulticastResult) SuccessCount() int
- func (r *Admin_ReloadResource1Client_MulticastResult) SuccessPeer(index int) *gira.Peer
- type Admin_ReloadResource1Server
- type Admin_ReloadResource1ServerRouter
- type Admin_ReloadResource2Client
- type Admin_ReloadResource2Client_MulticastResult
- func (r *Admin_ReloadResource2Client_MulticastResult) Error() error
- func (r *Admin_ReloadResource2Client_MulticastResult) ErrorCount() int
- func (r *Admin_ReloadResource2Client_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *Admin_ReloadResource2Client_MulticastResult) Errors(index int) error
- func (r *Admin_ReloadResource2Client_MulticastResult) PeerCount() int
- func (r *Admin_ReloadResource2Client_MulticastResult) Response(index int) Admin_ReloadResource2Client
- func (r *Admin_ReloadResource2Client_MulticastResult) SuccessCount() int
- func (r *Admin_ReloadResource2Client_MulticastResult) SuccessPeer(index int) *gira.Peer
- type Admin_ReloadResource2Server
- type Admin_ReloadResource2ServerRouter
- type Admin_ReloadResource3Client
- type Admin_ReloadResource3Client_MulticastResult
- func (r *Admin_ReloadResource3Client_MulticastResult) Error() error
- func (r *Admin_ReloadResource3Client_MulticastResult) ErrorCount() int
- func (r *Admin_ReloadResource3Client_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *Admin_ReloadResource3Client_MulticastResult) Errors(index int) error
- func (r *Admin_ReloadResource3Client_MulticastResult) PeerCount() int
- func (r *Admin_ReloadResource3Client_MulticastResult) Response(index int) Admin_ReloadResource3Client
- func (r *Admin_ReloadResource3Client_MulticastResult) SuccessCount() int
- func (r *Admin_ReloadResource3Client_MulticastResult) SuccessPeer(index int) *gira.Peer
- type Admin_ReloadResource3Server
- type Admin_ReloadResource3ServerRouter
- type ReloadResourceRequest
- func (*ReloadResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadResourceRequest) GetName() string
- func (*ReloadResourceRequest) ProtoMessage()
- func (x *ReloadResourceRequest) ProtoReflect() protoreflect.Message
- func (x *ReloadResourceRequest) Reset()
- func (x *ReloadResourceRequest) String() string
- type ReloadResourceRequest1
- func (*ReloadResourceRequest1) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadResourceRequest1) GetName() string
- func (*ReloadResourceRequest1) ProtoMessage()
- func (x *ReloadResourceRequest1) ProtoReflect() protoreflect.Message
- func (x *ReloadResourceRequest1) Reset()
- func (x *ReloadResourceRequest1) String() string
- type ReloadResourceRequest2
- func (*ReloadResourceRequest2) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadResourceRequest2) GetName() string
- func (*ReloadResourceRequest2) ProtoMessage()
- func (x *ReloadResourceRequest2) ProtoReflect() protoreflect.Message
- func (x *ReloadResourceRequest2) Reset()
- func (x *ReloadResourceRequest2) String() string
- type ReloadResourceRequest3
- func (*ReloadResourceRequest3) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadResourceRequest3) GetName() string
- func (*ReloadResourceRequest3) ProtoMessage()
- func (x *ReloadResourceRequest3) ProtoReflect() protoreflect.Message
- func (x *ReloadResourceRequest3) Reset()
- func (x *ReloadResourceRequest3) String() string
- type ReloadResourceResponse
- type ReloadResourceResponse1
- type ReloadResourceResponse1_MulticastResult
- func (r *ReloadResourceResponse1_MulticastResult) Error() error
- func (r *ReloadResourceResponse1_MulticastResult) ErrorCount() int
- func (r *ReloadResourceResponse1_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *ReloadResourceResponse1_MulticastResult) Errors(index int) error
- func (r *ReloadResourceResponse1_MulticastResult) PeerCount() int
- func (r *ReloadResourceResponse1_MulticastResult) Response(index int) *ReloadResourceResponse1
- func (r *ReloadResourceResponse1_MulticastResult) SuccessCount() int
- func (r *ReloadResourceResponse1_MulticastResult) SuccessPeer(index int) *gira.Peer
- type ReloadResourceResponse2
- type ReloadResourceResponse2_MulticastResult
- func (r *ReloadResourceResponse2_MulticastResult) Error() error
- func (r *ReloadResourceResponse2_MulticastResult) ErrorCount() int
- func (r *ReloadResourceResponse2_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *ReloadResourceResponse2_MulticastResult) Errors(index int) error
- func (r *ReloadResourceResponse2_MulticastResult) PeerCount() int
- func (r *ReloadResourceResponse2_MulticastResult) Response(index int) *ReloadResourceResponse2
- func (r *ReloadResourceResponse2_MulticastResult) SuccessCount() int
- func (r *ReloadResourceResponse2_MulticastResult) SuccessPeer(index int) *gira.Peer
- type ReloadResourceResponse3
- type ReloadResourceResponse_MulticastResult
- func (r *ReloadResourceResponse_MulticastResult) Error() error
- func (r *ReloadResourceResponse_MulticastResult) ErrorCount() int
- func (r *ReloadResourceResponse_MulticastResult) ErrorPeer(index int) *gira.Peer
- func (r *ReloadResourceResponse_MulticastResult) Errors(index int) error
- func (r *ReloadResourceResponse_MulticastResult) PeerCount() int
- func (r *ReloadResourceResponse_MulticastResult) Response(index int) *ReloadResourceResponse
- func (r *ReloadResourceResponse_MulticastResult) SuccessCount() int
- func (r *ReloadResourceResponse_MulticastResult) SuccessPeer(index int) *gira.Peer
- type UnimplementedAdminServer
- func (UnimplementedAdminServer) ReloadResource(context.Context, *ReloadResourceRequest) (*ReloadResourceResponse, error)
- func (UnimplementedAdminServer) ReloadResource1(Admin_ReloadResource1Server) error
- func (UnimplementedAdminServer) ReloadResource2(*ReloadResourceRequest2, Admin_ReloadResource2Server) error
- func (UnimplementedAdminServer) ReloadResource3(Admin_ReloadResource3Server) error
- type UnsafeAdminServer
Constants ¶
const ( Admin_ReloadResource_FullMethodName = "/adminpb.Admin/ReloadResource" Admin_ReloadResource1_FullMethodName = "/adminpb.Admin/ReloadResource1" Admin_ReloadResource2_FullMethodName = "/adminpb.Admin/ReloadResource2" Admin_ReloadResource3_FullMethodName = "/adminpb.Admin/ReloadResource3" )
const (
AdminServerName = "adminpb.Admin"
)
Variables ¶
var Admin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "adminpb.Admin", HandlerType: (*AdminServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReloadResource", Handler: _Admin_ReloadResource_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReloadResource1", Handler: _Admin_ReloadResource1_Handler, ClientStreams: true, }, { StreamName: "ReloadResource2", Handler: _Admin_ReloadResource2_Handler, ServerStreams: true, }, { StreamName: "ReloadResource3", Handler: _Admin_ReloadResource3_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "service/admin/admin.proto", }
Admin_ServiceDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Admin_ServiceRouterDesc = grpc.ServiceDesc{ ServiceName: "adminpb.Admin", HandlerType: (*AdminServerRouter)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReloadResource", Handler: _Admin_ReloadResource_RouterHandler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReloadResource1", Handler: _Admin_ReloadResource1_RouterHandler, ClientStreams: true, }, { StreamName: "ReloadResource2", Handler: _Admin_ReloadResource2_RouterHandler, ServerStreams: true, }, { StreamName: "ReloadResource3", Handler: _Admin_ReloadResource3_RouterHandler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "service/admin/admin.proto", }
Admin_ServiceRouterDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DefaultAdminClients = NewAdminClients()
var File_service_admin_admin_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAdminServer ¶
func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)
Types ¶
type AdminClient ¶
type AdminClient interface { ReloadResource(ctx context.Context, in *ReloadResourceRequest, opts ...grpc.CallOption) (*ReloadResourceResponse, error) ReloadResource1(ctx context.Context, opts ...grpc.CallOption) (Admin_ReloadResource1Client, error) ReloadResource2(ctx context.Context, in *ReloadResourceRequest2, opts ...grpc.CallOption) (Admin_ReloadResource2Client, error) ReloadResource3(ctx context.Context, opts ...grpc.CallOption) (Admin_ReloadResource3Client, error) }
AdminClient is the client API for Admin 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 NewAdminClient ¶
func NewAdminClient(cc grpc.ClientConnInterface) AdminClient
type AdminClients ¶
type AdminClients interface { WithServiceName(serviceName string) AdminClients // 发送到一个节点 Unicast() AdminClientsUnicast Multicast(count int) AdminClientsMulticast // 广播给所有节点 Broadcast() AdminClientsMulticast ReloadResource(ctx context.Context, address string, in *ReloadResourceRequest, opts ...grpc.CallOption) (*ReloadResourceResponse, error) ReloadResource1(ctx context.Context, address string, opts ...grpc.CallOption) (Admin_ReloadResource1Client, error) ReloadResource2(ctx context.Context, address string, in *ReloadResourceRequest2, opts ...grpc.CallOption) (Admin_ReloadResource2Client, error) ReloadResource3(ctx context.Context, address string, opts ...grpc.CallOption) (Admin_ReloadResource3Client, error) }
AdminClient is the client API for Admin 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 NewAdminClients ¶
func NewAdminClients() AdminClients
type AdminClientsMulticast ¶
type AdminClientsMulticast interface { WhereRegex(regex string) AdminClientsMulticast WherePrefix(prefix bool) AdminClientsMulticast Local() AdminClientsMulticast ReloadResource(ctx context.Context, in *ReloadResourceRequest, opts ...grpc.CallOption) (*ReloadResourceResponse_MulticastResult, error) ReloadResource1(ctx context.Context, opts ...grpc.CallOption) (*Admin_ReloadResource1Client_MulticastResult, error) ReloadResource2(ctx context.Context, in *ReloadResourceRequest2, opts ...grpc.CallOption) (*Admin_ReloadResource2Client_MulticastResult, error) ReloadResource3(ctx context.Context, opts ...grpc.CallOption) (*Admin_ReloadResource3Client_MulticastResult, error) }
type AdminClientsUnicast ¶
type AdminClientsUnicast interface { Where(serviceName string) AdminClientsUnicast WherePeer(peer *gira.Peer) AdminClientsUnicast WherePeerFullName(appFullName string) AdminClientsUnicast WhereAddress(address string) AdminClientsUnicast WhereUser(userId string) AdminClientsUnicast Local() AdminClientsUnicast ReloadResource(ctx context.Context, in *ReloadResourceRequest, opts ...grpc.CallOption) (*ReloadResourceResponse, error) ReloadResource1(ctx context.Context, opts ...grpc.CallOption) (Admin_ReloadResource1Client, error) ReloadResource2(ctx context.Context, in *ReloadResourceRequest2, opts ...grpc.CallOption) (Admin_ReloadResource2Client, error) ReloadResource3(ctx context.Context, opts ...grpc.CallOption) (Admin_ReloadResource3Client, error) }
type AdminServer ¶
type AdminServer interface { ReloadResource(context.Context, *ReloadResourceRequest) (*ReloadResourceResponse, error) ReloadResource1(Admin_ReloadResource1Server) error ReloadResource2(*ReloadResourceRequest2, Admin_ReloadResource2Server) error ReloadResource3(Admin_ReloadResource3Server) error // contains filtered or unexported methods }
AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility
type AdminServerRouter ¶
type AdminServerRouter interface { RegisterMiddleware(middle AdminServerRouterMiddleware) RegisterHandler(key string, handler AdminServerRouterHandler) UnregisterHandler(key string, handler AdminServerRouterHandler) }
AdminServerRouter is the default server router for Admin service.
func RegisterAdminServerAsRouter ¶
func RegisterAdminServerAsRouter(s grpc.ServiceRegistrar, handler AdminServerRouterHandler) AdminServerRouter
type AdminServerRouterHandler ¶
type AdminServerRouterHandler interface { AdminServer }
AdminServerRouter is the default server router handler for Admin service.
type AdminServerRouterMiddleware ¶
type AdminServerRouterMiddleware interface {
AdminServerRouterMiddlewareInvoke(ctx AdminServerRouterMiddlewareContext) error
}
AdminServerRouter is the default server router middleware for Admin service.
type AdminServerRouterMiddlewareContext ¶
type AdminServerRouterMiddlewareContext interface { Handler() AdminServer Next() Wait() error }
AdminServerRouter is the default server router middleware context for Admin service.
type Admin_ReloadResource1Client ¶
type Admin_ReloadResource1Client interface { Send(*ReloadResourceRequest1) error CloseAndRecv() (*ReloadResourceResponse1, error) grpc.ClientStream }
type Admin_ReloadResource1Client_MulticastResult ¶
type Admin_ReloadResource1Client_MulticastResult struct {
// contains filtered or unexported fields
}
func (*Admin_ReloadResource1Client_MulticastResult) Error ¶
func (r *Admin_ReloadResource1Client_MulticastResult) Error() error
func (*Admin_ReloadResource1Client_MulticastResult) ErrorCount ¶
func (r *Admin_ReloadResource1Client_MulticastResult) ErrorCount() int
func (*Admin_ReloadResource1Client_MulticastResult) ErrorPeer ¶
func (r *Admin_ReloadResource1Client_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*Admin_ReloadResource1Client_MulticastResult) Errors ¶
func (r *Admin_ReloadResource1Client_MulticastResult) Errors(index int) error
func (*Admin_ReloadResource1Client_MulticastResult) PeerCount ¶
func (r *Admin_ReloadResource1Client_MulticastResult) PeerCount() int
func (*Admin_ReloadResource1Client_MulticastResult) Response ¶
func (r *Admin_ReloadResource1Client_MulticastResult) Response(index int) Admin_ReloadResource1Client
func (*Admin_ReloadResource1Client_MulticastResult) SuccessCount ¶
func (r *Admin_ReloadResource1Client_MulticastResult) SuccessCount() int
func (*Admin_ReloadResource1Client_MulticastResult) SuccessPeer ¶
func (r *Admin_ReloadResource1Client_MulticastResult) SuccessPeer(index int) *gira.Peer
type Admin_ReloadResource1Server ¶
type Admin_ReloadResource1Server interface { SendAndClose(*ReloadResourceResponse1) error Recv() (*ReloadResourceRequest1, error) grpc.ServerStream }
type Admin_ReloadResource1ServerRouter ¶
type Admin_ReloadResource1ServerRouter interface { SendAndClose(*ReloadResourceResponse1) error Recv() (*ReloadResourceRequest1, error) grpc.ServerStream }
type Admin_ReloadResource2Client ¶
type Admin_ReloadResource2Client interface { Recv() (*ReloadResourceResponse2, error) grpc.ClientStream }
type Admin_ReloadResource2Client_MulticastResult ¶
type Admin_ReloadResource2Client_MulticastResult struct {
// contains filtered or unexported fields
}
func (*Admin_ReloadResource2Client_MulticastResult) Error ¶
func (r *Admin_ReloadResource2Client_MulticastResult) Error() error
func (*Admin_ReloadResource2Client_MulticastResult) ErrorCount ¶
func (r *Admin_ReloadResource2Client_MulticastResult) ErrorCount() int
func (*Admin_ReloadResource2Client_MulticastResult) ErrorPeer ¶
func (r *Admin_ReloadResource2Client_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*Admin_ReloadResource2Client_MulticastResult) Errors ¶
func (r *Admin_ReloadResource2Client_MulticastResult) Errors(index int) error
func (*Admin_ReloadResource2Client_MulticastResult) PeerCount ¶
func (r *Admin_ReloadResource2Client_MulticastResult) PeerCount() int
func (*Admin_ReloadResource2Client_MulticastResult) Response ¶
func (r *Admin_ReloadResource2Client_MulticastResult) Response(index int) Admin_ReloadResource2Client
func (*Admin_ReloadResource2Client_MulticastResult) SuccessCount ¶
func (r *Admin_ReloadResource2Client_MulticastResult) SuccessCount() int
func (*Admin_ReloadResource2Client_MulticastResult) SuccessPeer ¶
func (r *Admin_ReloadResource2Client_MulticastResult) SuccessPeer(index int) *gira.Peer
type Admin_ReloadResource2Server ¶
type Admin_ReloadResource2Server interface { Send(*ReloadResourceResponse2) error grpc.ServerStream }
type Admin_ReloadResource2ServerRouter ¶
type Admin_ReloadResource2ServerRouter interface { Send(*ReloadResourceResponse2) error grpc.ServerStream }
type Admin_ReloadResource3Client ¶
type Admin_ReloadResource3Client interface { Send(*ReloadResourceRequest2) error Recv() (*ReloadResourceResponse2, error) grpc.ClientStream }
type Admin_ReloadResource3Client_MulticastResult ¶
type Admin_ReloadResource3Client_MulticastResult struct {
// contains filtered or unexported fields
}
func (*Admin_ReloadResource3Client_MulticastResult) Error ¶
func (r *Admin_ReloadResource3Client_MulticastResult) Error() error
func (*Admin_ReloadResource3Client_MulticastResult) ErrorCount ¶
func (r *Admin_ReloadResource3Client_MulticastResult) ErrorCount() int
func (*Admin_ReloadResource3Client_MulticastResult) ErrorPeer ¶
func (r *Admin_ReloadResource3Client_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*Admin_ReloadResource3Client_MulticastResult) Errors ¶
func (r *Admin_ReloadResource3Client_MulticastResult) Errors(index int) error
func (*Admin_ReloadResource3Client_MulticastResult) PeerCount ¶
func (r *Admin_ReloadResource3Client_MulticastResult) PeerCount() int
func (*Admin_ReloadResource3Client_MulticastResult) Response ¶
func (r *Admin_ReloadResource3Client_MulticastResult) Response(index int) Admin_ReloadResource3Client
func (*Admin_ReloadResource3Client_MulticastResult) SuccessCount ¶
func (r *Admin_ReloadResource3Client_MulticastResult) SuccessCount() int
func (*Admin_ReloadResource3Client_MulticastResult) SuccessPeer ¶
func (r *Admin_ReloadResource3Client_MulticastResult) SuccessPeer(index int) *gira.Peer
type Admin_ReloadResource3Server ¶
type Admin_ReloadResource3Server interface { Send(*ReloadResourceResponse2) error Recv() (*ReloadResourceRequest2, error) grpc.ServerStream }
type Admin_ReloadResource3ServerRouter ¶
type Admin_ReloadResource3ServerRouter interface { Send(*ReloadResourceResponse2) error Recv() (*ReloadResourceRequest2, error) grpc.ServerStream }
type ReloadResourceRequest ¶
type ReloadResourceRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
请求消息
func (*ReloadResourceRequest) Descriptor
deprecated
func (*ReloadResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceRequest.ProtoReflect.Descriptor instead.
func (*ReloadResourceRequest) GetName ¶
func (x *ReloadResourceRequest) GetName() string
func (*ReloadResourceRequest) ProtoMessage ¶
func (*ReloadResourceRequest) ProtoMessage()
func (*ReloadResourceRequest) ProtoReflect ¶
func (x *ReloadResourceRequest) ProtoReflect() protoreflect.Message
func (*ReloadResourceRequest) Reset ¶
func (x *ReloadResourceRequest) Reset()
func (*ReloadResourceRequest) String ¶
func (x *ReloadResourceRequest) String() string
type ReloadResourceRequest1 ¶
type ReloadResourceRequest1 struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
请求消息
func (*ReloadResourceRequest1) Descriptor
deprecated
func (*ReloadResourceRequest1) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceRequest1.ProtoReflect.Descriptor instead.
func (*ReloadResourceRequest1) GetName ¶
func (x *ReloadResourceRequest1) GetName() string
func (*ReloadResourceRequest1) ProtoMessage ¶
func (*ReloadResourceRequest1) ProtoMessage()
func (*ReloadResourceRequest1) ProtoReflect ¶
func (x *ReloadResourceRequest1) ProtoReflect() protoreflect.Message
func (*ReloadResourceRequest1) Reset ¶
func (x *ReloadResourceRequest1) Reset()
func (*ReloadResourceRequest1) String ¶
func (x *ReloadResourceRequest1) String() string
type ReloadResourceRequest2 ¶
type ReloadResourceRequest2 struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
请求消息
func (*ReloadResourceRequest2) Descriptor
deprecated
func (*ReloadResourceRequest2) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceRequest2.ProtoReflect.Descriptor instead.
func (*ReloadResourceRequest2) GetName ¶
func (x *ReloadResourceRequest2) GetName() string
func (*ReloadResourceRequest2) ProtoMessage ¶
func (*ReloadResourceRequest2) ProtoMessage()
func (*ReloadResourceRequest2) ProtoReflect ¶
func (x *ReloadResourceRequest2) ProtoReflect() protoreflect.Message
func (*ReloadResourceRequest2) Reset ¶
func (x *ReloadResourceRequest2) Reset()
func (*ReloadResourceRequest2) String ¶
func (x *ReloadResourceRequest2) String() string
type ReloadResourceRequest3 ¶
type ReloadResourceRequest3 struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
请求消息
func (*ReloadResourceRequest3) Descriptor
deprecated
func (*ReloadResourceRequest3) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceRequest3.ProtoReflect.Descriptor instead.
func (*ReloadResourceRequest3) GetName ¶
func (x *ReloadResourceRequest3) GetName() string
func (*ReloadResourceRequest3) ProtoMessage ¶
func (*ReloadResourceRequest3) ProtoMessage()
func (*ReloadResourceRequest3) ProtoReflect ¶
func (x *ReloadResourceRequest3) ProtoReflect() protoreflect.Message
func (*ReloadResourceRequest3) Reset ¶
func (x *ReloadResourceRequest3) Reset()
func (*ReloadResourceRequest3) String ¶
func (x *ReloadResourceRequest3) String() string
type ReloadResourceResponse ¶
type ReloadResourceResponse struct {
// contains filtered or unexported fields
}
响应消息
func (*ReloadResourceResponse) Descriptor
deprecated
func (*ReloadResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceResponse.ProtoReflect.Descriptor instead.
func (*ReloadResourceResponse) ProtoMessage ¶
func (*ReloadResourceResponse) ProtoMessage()
func (*ReloadResourceResponse) ProtoReflect ¶
func (x *ReloadResourceResponse) ProtoReflect() protoreflect.Message
func (*ReloadResourceResponse) Reset ¶
func (x *ReloadResourceResponse) Reset()
func (*ReloadResourceResponse) String ¶
func (x *ReloadResourceResponse) String() string
type ReloadResourceResponse1 ¶
type ReloadResourceResponse1 struct {
// contains filtered or unexported fields
}
响应消息
func (*ReloadResourceResponse1) Descriptor
deprecated
func (*ReloadResourceResponse1) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceResponse1.ProtoReflect.Descriptor instead.
func (*ReloadResourceResponse1) ProtoMessage ¶
func (*ReloadResourceResponse1) ProtoMessage()
func (*ReloadResourceResponse1) ProtoReflect ¶
func (x *ReloadResourceResponse1) ProtoReflect() protoreflect.Message
func (*ReloadResourceResponse1) Reset ¶
func (x *ReloadResourceResponse1) Reset()
func (*ReloadResourceResponse1) String ¶
func (x *ReloadResourceResponse1) String() string
type ReloadResourceResponse1_MulticastResult ¶
type ReloadResourceResponse1_MulticastResult struct {
// contains filtered or unexported fields
}
func (*ReloadResourceResponse1_MulticastResult) Error ¶
func (r *ReloadResourceResponse1_MulticastResult) Error() error
func (*ReloadResourceResponse1_MulticastResult) ErrorCount ¶
func (r *ReloadResourceResponse1_MulticastResult) ErrorCount() int
func (*ReloadResourceResponse1_MulticastResult) ErrorPeer ¶
func (r *ReloadResourceResponse1_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*ReloadResourceResponse1_MulticastResult) Errors ¶
func (r *ReloadResourceResponse1_MulticastResult) Errors(index int) error
func (*ReloadResourceResponse1_MulticastResult) PeerCount ¶
func (r *ReloadResourceResponse1_MulticastResult) PeerCount() int
func (*ReloadResourceResponse1_MulticastResult) Response ¶
func (r *ReloadResourceResponse1_MulticastResult) Response(index int) *ReloadResourceResponse1
func (*ReloadResourceResponse1_MulticastResult) SuccessCount ¶
func (r *ReloadResourceResponse1_MulticastResult) SuccessCount() int
func (*ReloadResourceResponse1_MulticastResult) SuccessPeer ¶
func (r *ReloadResourceResponse1_MulticastResult) SuccessPeer(index int) *gira.Peer
type ReloadResourceResponse2 ¶
type ReloadResourceResponse2 struct {
// contains filtered or unexported fields
}
响应消息
func (*ReloadResourceResponse2) Descriptor
deprecated
func (*ReloadResourceResponse2) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceResponse2.ProtoReflect.Descriptor instead.
func (*ReloadResourceResponse2) ProtoMessage ¶
func (*ReloadResourceResponse2) ProtoMessage()
func (*ReloadResourceResponse2) ProtoReflect ¶
func (x *ReloadResourceResponse2) ProtoReflect() protoreflect.Message
func (*ReloadResourceResponse2) Reset ¶
func (x *ReloadResourceResponse2) Reset()
func (*ReloadResourceResponse2) String ¶
func (x *ReloadResourceResponse2) String() string
type ReloadResourceResponse2_MulticastResult ¶
type ReloadResourceResponse2_MulticastResult struct {
// contains filtered or unexported fields
}
func (*ReloadResourceResponse2_MulticastResult) Error ¶
func (r *ReloadResourceResponse2_MulticastResult) Error() error
func (*ReloadResourceResponse2_MulticastResult) ErrorCount ¶
func (r *ReloadResourceResponse2_MulticastResult) ErrorCount() int
func (*ReloadResourceResponse2_MulticastResult) ErrorPeer ¶
func (r *ReloadResourceResponse2_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*ReloadResourceResponse2_MulticastResult) Errors ¶
func (r *ReloadResourceResponse2_MulticastResult) Errors(index int) error
func (*ReloadResourceResponse2_MulticastResult) PeerCount ¶
func (r *ReloadResourceResponse2_MulticastResult) PeerCount() int
func (*ReloadResourceResponse2_MulticastResult) Response ¶
func (r *ReloadResourceResponse2_MulticastResult) Response(index int) *ReloadResourceResponse2
func (*ReloadResourceResponse2_MulticastResult) SuccessCount ¶
func (r *ReloadResourceResponse2_MulticastResult) SuccessCount() int
func (*ReloadResourceResponse2_MulticastResult) SuccessPeer ¶
func (r *ReloadResourceResponse2_MulticastResult) SuccessPeer(index int) *gira.Peer
type ReloadResourceResponse3 ¶
type ReloadResourceResponse3 struct {
// contains filtered or unexported fields
}
响应消息
func (*ReloadResourceResponse3) Descriptor
deprecated
func (*ReloadResourceResponse3) Descriptor() ([]byte, []int)
Deprecated: Use ReloadResourceResponse3.ProtoReflect.Descriptor instead.
func (*ReloadResourceResponse3) ProtoMessage ¶
func (*ReloadResourceResponse3) ProtoMessage()
func (*ReloadResourceResponse3) ProtoReflect ¶
func (x *ReloadResourceResponse3) ProtoReflect() protoreflect.Message
func (*ReloadResourceResponse3) Reset ¶
func (x *ReloadResourceResponse3) Reset()
func (*ReloadResourceResponse3) String ¶
func (x *ReloadResourceResponse3) String() string
type ReloadResourceResponse_MulticastResult ¶
type ReloadResourceResponse_MulticastResult struct {
// contains filtered or unexported fields
}
func (*ReloadResourceResponse_MulticastResult) Error ¶
func (r *ReloadResourceResponse_MulticastResult) Error() error
func (*ReloadResourceResponse_MulticastResult) ErrorCount ¶
func (r *ReloadResourceResponse_MulticastResult) ErrorCount() int
func (*ReloadResourceResponse_MulticastResult) ErrorPeer ¶
func (r *ReloadResourceResponse_MulticastResult) ErrorPeer(index int) *gira.Peer
func (*ReloadResourceResponse_MulticastResult) Errors ¶
func (r *ReloadResourceResponse_MulticastResult) Errors(index int) error
func (*ReloadResourceResponse_MulticastResult) PeerCount ¶
func (r *ReloadResourceResponse_MulticastResult) PeerCount() int
func (*ReloadResourceResponse_MulticastResult) Response ¶
func (r *ReloadResourceResponse_MulticastResult) Response(index int) *ReloadResourceResponse
func (*ReloadResourceResponse_MulticastResult) SuccessCount ¶
func (r *ReloadResourceResponse_MulticastResult) SuccessCount() int
func (*ReloadResourceResponse_MulticastResult) SuccessPeer ¶
func (r *ReloadResourceResponse_MulticastResult) SuccessPeer(index int) *gira.Peer
type UnimplementedAdminServer ¶
type UnimplementedAdminServer struct { }
UnimplementedAdminServer must be embedded to have forward compatible implementations.
func (UnimplementedAdminServer) ReloadResource ¶
func (UnimplementedAdminServer) ReloadResource(context.Context, *ReloadResourceRequest) (*ReloadResourceResponse, error)
func (UnimplementedAdminServer) ReloadResource1 ¶
func (UnimplementedAdminServer) ReloadResource1(Admin_ReloadResource1Server) error
func (UnimplementedAdminServer) ReloadResource2 ¶
func (UnimplementedAdminServer) ReloadResource2(*ReloadResourceRequest2, Admin_ReloadResource2Server) error
func (UnimplementedAdminServer) ReloadResource3 ¶
func (UnimplementedAdminServer) ReloadResource3(Admin_ReloadResource3Server) error
type UnsafeAdminServer ¶
type UnsafeAdminServer interface {
// contains filtered or unexported methods
}
UnsafeAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServer will result in compilation errors.