Documentation ¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
dns.proto
It has these top-level messages:
DnsPacket WatchRequest WatchCreateRequest WatchCancelRequest WatchResponse
Index ¶
- func RegisterDnsServiceServer(s *grpc.Server, srv DnsServiceServer)
- type DnsPacket
- type DnsServiceClient
- type DnsServiceServer
- type DnsService_WatchClient
- type DnsService_WatchServer
- type WatchCancelRequest
- type WatchCreateRequest
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)
- func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest
- func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest
- func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion
- func (*WatchRequest) ProtoMessage()
- func (m *WatchRequest) Reset()
- func (m *WatchRequest) String() string
- func (*WatchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type WatchRequest_CancelRequest
- type WatchRequest_CreateRequest
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)
- func (m *WatchResponse) GetCanceled() bool
- func (m *WatchResponse) GetCreated() bool
- func (m *WatchResponse) GetErr() string
- func (m *WatchResponse) GetQname() string
- func (m *WatchResponse) GetWatchId() int64
- func (*WatchResponse) ProtoMessage()
- func (m *WatchResponse) Reset()
- func (m *WatchResponse) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDnsServiceServer ¶
func RegisterDnsServiceServer(s *grpc.Server, srv DnsServiceServer)
Types ¶
type DnsPacket ¶
type DnsPacket struct {
Msg []byte `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}
func (*DnsPacket) Descriptor ¶
func (*DnsPacket) ProtoMessage ¶
func (*DnsPacket) ProtoMessage()
type DnsServiceClient ¶
type DnsServiceClient interface { Query(ctx context.Context, in *DnsPacket, opts ...grpc.CallOption) (*DnsPacket, error) Watch(ctx context.Context, opts ...grpc.CallOption) (DnsService_WatchClient, error) }
func NewDnsServiceClient ¶
func NewDnsServiceClient(cc *grpc.ClientConn) DnsServiceClient
type DnsServiceServer ¶
type DnsService_WatchClient ¶
type DnsService_WatchClient interface { Send(*WatchRequest) error Recv() (*WatchResponse, error) grpc.ClientStream }
type DnsService_WatchServer ¶
type DnsService_WatchServer interface { Send(*WatchResponse) error Recv() (*WatchRequest, error) grpc.ServerStream }
type WatchCancelRequest ¶
type WatchCancelRequest struct { // watch_id is the watcher id to cancel WatchId int64 `protobuf:"varint,1,opt,name=watch_id,json=watchId" json:"watch_id,omitempty"` }
func (*WatchCancelRequest) Descriptor ¶
func (*WatchCancelRequest) Descriptor() ([]byte, []int)
func (*WatchCancelRequest) GetWatchId ¶
func (m *WatchCancelRequest) GetWatchId() int64
func (*WatchCancelRequest) ProtoMessage ¶
func (*WatchCancelRequest) ProtoMessage()
func (*WatchCancelRequest) Reset ¶
func (m *WatchCancelRequest) Reset()
func (*WatchCancelRequest) String ¶
func (m *WatchCancelRequest) String() string
type WatchCreateRequest ¶
type WatchCreateRequest struct {
Query *DnsPacket `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
}
func (*WatchCreateRequest) Descriptor ¶
func (*WatchCreateRequest) Descriptor() ([]byte, []int)
func (*WatchCreateRequest) GetQuery ¶
func (m *WatchCreateRequest) GetQuery() *DnsPacket
func (*WatchCreateRequest) ProtoMessage ¶
func (*WatchCreateRequest) ProtoMessage()
func (*WatchCreateRequest) Reset ¶
func (m *WatchCreateRequest) Reset()
func (*WatchCreateRequest) String ¶
func (m *WatchCreateRequest) String() string
type WatchRequest ¶
type WatchRequest struct { // request_union is a request to either create a new watcher or cancel an existing watcher. // // Types that are valid to be assigned to RequestUnion: // *WatchRequest_CreateRequest // *WatchRequest_CancelRequest RequestUnion isWatchRequest_RequestUnion `protobuf_oneof:"request_union"` }
func (*WatchRequest) Descriptor ¶
func (*WatchRequest) Descriptor() ([]byte, []int)
func (*WatchRequest) GetCancelRequest ¶
func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest
func (*WatchRequest) GetCreateRequest ¶
func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest
func (*WatchRequest) GetRequestUnion ¶
func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) Reset ¶
func (m *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (m *WatchRequest) String() string
func (*WatchRequest) XXX_OneofFuncs ¶
func (*WatchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type WatchRequest_CancelRequest ¶
type WatchRequest_CancelRequest struct {
CancelRequest *WatchCancelRequest `protobuf:"bytes,2,opt,name=cancel_request,json=cancelRequest,oneof"`
}
type WatchRequest_CreateRequest ¶
type WatchRequest_CreateRequest struct {
CreateRequest *WatchCreateRequest `protobuf:"bytes,1,opt,name=create_request,json=createRequest,oneof"`
}
type WatchResponse ¶
type WatchResponse struct { // watch_id is the ID of the watcher that corresponds to the response. WatchId int64 `protobuf:"varint,1,opt,name=watch_id,json=watchId" json:"watch_id,omitempty"` // created is set to true if the response is for a create watch request. // The client should record the watch_id and expect to receive DNS replies // from the same stream. // All replies sent to the created watcher will attach with the same watch_id. Created bool `protobuf:"varint,2,opt,name=created" json:"created,omitempty"` // canceled is set to true if the response is for a cancel watch request. // No further events will be sent to the canceled watcher. Canceled bool `protobuf:"varint,3,opt,name=canceled" json:"canceled,omitempty"` Qname string `protobuf:"bytes,4,opt,name=qname" json:"qname,omitempty"` Err string `protobuf:"bytes,5,opt,name=err" json:"err,omitempty"` }
func (*WatchResponse) Descriptor ¶
func (*WatchResponse) Descriptor() ([]byte, []int)
func (*WatchResponse) GetCanceled ¶
func (m *WatchResponse) GetCanceled() bool
func (*WatchResponse) GetCreated ¶
func (m *WatchResponse) GetCreated() bool
func (*WatchResponse) GetErr ¶
func (m *WatchResponse) GetErr() string
func (*WatchResponse) GetQname ¶
func (m *WatchResponse) GetQname() string
func (*WatchResponse) GetWatchId ¶
func (m *WatchResponse) GetWatchId() int64
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) Reset ¶
func (m *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (m *WatchResponse) String() string
Click to show internal directories.
Click to hide internal directories.