proto

package
v0.0.0-...-b31dffb Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Authority_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_testing.authority.Authority",
	HandlerType: (*AuthorityServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Servers",
			Handler:       _Authority_Servers_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "medium/grpc_testing/proto/authority.proto",
}

Authority_ServiceDesc is the grpc.ServiceDesc for Authority 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 File_medium_grpc_testing_proto_authority_proto protoreflect.FileDescriptor

Functions

func RegisterAuthorityServer

func RegisterAuthorityServer(s grpc.ServiceRegistrar, srv AuthorityServer)

Types

type AuthorityClient

type AuthorityClient interface {
	// ProcessExporter instructs the Processor to process some data from an exporter and
	// stream the results back.
	Servers(ctx context.Context, in *ServersReq, opts ...grpc.CallOption) (Authority_ServersClient, error)
}

AuthorityClient is the client API for Authority service.

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

func NewAuthorityClient

func NewAuthorityClient(cc grpc.ClientConnInterface) AuthorityClient

type AuthorityServer

type AuthorityServer interface {
	// ProcessExporter instructs the Processor to process some data from an exporter and
	// stream the results back.
	Servers(*ServersReq, Authority_ServersServer) error
	// contains filtered or unexported methods
}

AuthorityServer is the server API for Authority service. All implementations must embed UnimplementedAuthorityServer for forward compatibility

type Authority_ServersClient

type Authority_ServersClient interface {
	Recv() (*ServerMsg, error)
	grpc.ClientStream
}

type Authority_ServersServer

type Authority_ServersServer interface {
	Send(*ServerMsg) error
	grpc.ServerStream
}

type ServerMsg

type ServerMsg struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerMsg) Descriptor deprecated

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

Deprecated: Use ServerMsg.ProtoReflect.Descriptor instead.

func (*ServerMsg) GetName

func (x *ServerMsg) GetName() string

func (*ServerMsg) ProtoMessage

func (*ServerMsg) ProtoMessage()

func (*ServerMsg) ProtoReflect

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

func (*ServerMsg) Reset

func (x *ServerMsg) Reset()

func (*ServerMsg) String

func (x *ServerMsg) String() string

type ServersReq

type ServersReq struct {
	NameFilterRe     string   `protobuf:"bytes,1,opt,name=name_filter_re,json=nameFilterRe,proto3" json:"name_filter_re,omitempty"`
	DatacenterFilter []string `protobuf:"bytes,2,rep,name=datacenter_filter,json=datacenterFilter,proto3" json:"datacenter_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ServersReq) Descriptor deprecated

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

Deprecated: Use ServersReq.ProtoReflect.Descriptor instead.

func (*ServersReq) GetDatacenterFilter

func (x *ServersReq) GetDatacenterFilter() []string

func (*ServersReq) GetNameFilterRe

func (x *ServersReq) GetNameFilterRe() string

func (*ServersReq) ProtoMessage

func (*ServersReq) ProtoMessage()

func (*ServersReq) ProtoReflect

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

func (*ServersReq) Reset

func (x *ServersReq) Reset()

func (*ServersReq) String

func (x *ServersReq) String() string

type UnimplementedAuthorityServer

type UnimplementedAuthorityServer struct {
}

UnimplementedAuthorityServer must be embedded to have forward compatible implementations.

func (UnimplementedAuthorityServer) Servers

type UnsafeAuthorityServer

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

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

Jump to

Keyboard shortcuts

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