adminpb

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	AdminServerName = "adminpb.Admin"
)

Variables

View Source
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)

View Source
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)

View Source
var DefaultAdminClients = NewAdminClients()
View Source
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 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.

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 (*Admin_ReloadResource1Client_MulticastResult) ErrorCount

func (*Admin_ReloadResource1Client_MulticastResult) ErrorPeer

func (*Admin_ReloadResource1Client_MulticastResult) Errors

func (*Admin_ReloadResource1Client_MulticastResult) PeerCount

func (*Admin_ReloadResource1Client_MulticastResult) Response

func (*Admin_ReloadResource1Client_MulticastResult) SuccessCount

func (*Admin_ReloadResource1Client_MulticastResult) SuccessPeer

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 (*Admin_ReloadResource2Client_MulticastResult) ErrorCount

func (*Admin_ReloadResource2Client_MulticastResult) ErrorPeer

func (*Admin_ReloadResource2Client_MulticastResult) Errors

func (*Admin_ReloadResource2Client_MulticastResult) PeerCount

func (*Admin_ReloadResource2Client_MulticastResult) Response

func (*Admin_ReloadResource2Client_MulticastResult) SuccessCount

func (*Admin_ReloadResource2Client_MulticastResult) SuccessPeer

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 (*Admin_ReloadResource3Client_MulticastResult) ErrorCount

func (*Admin_ReloadResource3Client_MulticastResult) ErrorPeer

func (*Admin_ReloadResource3Client_MulticastResult) Errors

func (*Admin_ReloadResource3Client_MulticastResult) PeerCount

func (*Admin_ReloadResource3Client_MulticastResult) Response

func (*Admin_ReloadResource3Client_MulticastResult) SuccessCount

func (*Admin_ReloadResource3Client_MulticastResult) SuccessPeer

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 (*ReloadResourceResponse1_MulticastResult) ErrorCount

func (*ReloadResourceResponse1_MulticastResult) ErrorPeer

func (*ReloadResourceResponse1_MulticastResult) Errors

func (*ReloadResourceResponse1_MulticastResult) PeerCount

func (*ReloadResourceResponse1_MulticastResult) Response

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 (*ReloadResourceResponse2_MulticastResult) ErrorCount

func (*ReloadResourceResponse2_MulticastResult) ErrorPeer

func (*ReloadResourceResponse2_MulticastResult) Errors

func (*ReloadResourceResponse2_MulticastResult) PeerCount

func (*ReloadResourceResponse2_MulticastResult) Response

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 (*ReloadResourceResponse_MulticastResult) ErrorCount

func (*ReloadResourceResponse_MulticastResult) ErrorPeer

func (r *ReloadResourceResponse_MulticastResult) ErrorPeer(index int) *gira.Peer

func (*ReloadResourceResponse_MulticastResult) Errors

func (*ReloadResourceResponse_MulticastResult) PeerCount

func (*ReloadResourceResponse_MulticastResult) Response

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) ReloadResource1

func (UnimplementedAdminServer) ReloadResource2

func (UnimplementedAdminServer) ReloadResource3

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL