pb

package
v1.2.4 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

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

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) Descriptor() ([]byte, []int)

func (*DnsPacket) GetMsg 

func (m *DnsPacket) GetMsg() []byte

func (*DnsPacket) ProtoMessage 

func (*DnsPacket) ProtoMessage()

func (*DnsPacket) Reset 

func (m *DnsPacket) Reset()

func (*DnsPacket) String 

func (m *DnsPacket) String() string

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 DnsServiceServer interface {
	Query(context.Context, *DnsPacket) (*DnsPacket, error)
	Watch(DnsService_WatchServer) error
}

type DnsService_WatchClient added in v1.2.0 

type DnsService_WatchClient interface {
	Send(*WatchRequest) error
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type DnsService_WatchServer added in v1.2.0 

type DnsService_WatchServer interface {
	Send(*WatchResponse) error
	Recv() (*WatchRequest, error)
	grpc.ServerStream
}

type WatchCancelRequest added in v1.2.0 

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 added in v1.2.0 

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

func (*WatchCancelRequest) GetWatchId added in v1.2.0 

func (m *WatchCancelRequest) GetWatchId() int64

func (*WatchCancelRequest) ProtoMessage added in v1.2.0 

func (*WatchCancelRequest) ProtoMessage()

func (*WatchCancelRequest) Reset added in v1.2.0 

func (m *WatchCancelRequest) Reset()

func (*WatchCancelRequest) String added in v1.2.0 

func (m *WatchCancelRequest) String() string

type WatchCreateRequest added in v1.2.0 

type WatchCreateRequest struct {
	Query *DnsPacket `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
}

func (*WatchCreateRequest) Descriptor added in v1.2.0 

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

func (*WatchCreateRequest) GetQuery added in v1.2.0 

func (m *WatchCreateRequest) GetQuery() *DnsPacket

func (*WatchCreateRequest) ProtoMessage added in v1.2.0 

func (*WatchCreateRequest) ProtoMessage()

func (*WatchCreateRequest) Reset added in v1.2.0 

func (m *WatchCreateRequest) Reset()

func (*WatchCreateRequest) String added in v1.2.0 

func (m *WatchCreateRequest) String() string

type WatchRequest added in v1.2.0 

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 added in v1.2.0 

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

func (*WatchRequest) GetCancelRequest added in v1.2.0 

func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest

func (*WatchRequest) GetCreateRequest added in v1.2.0 

func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest

func (*WatchRequest) GetRequestUnion added in v1.2.0 

func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion

func (*WatchRequest) ProtoMessage added in v1.2.0 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset added in v1.2.0 

func (m *WatchRequest) Reset()

func (*WatchRequest) String added in v1.2.0 

func (m *WatchRequest) String() string

func (*WatchRequest) XXX_OneofFuncs added in v1.2.0 

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 added in v1.2.0 

type WatchRequest_CancelRequest struct {
	CancelRequest *WatchCancelRequest `protobuf:"bytes,2,opt,name=cancel_request,json=cancelRequest,oneof"`
}

type WatchRequest_CreateRequest added in v1.2.0 

type WatchRequest_CreateRequest struct {
	CreateRequest *WatchCreateRequest `protobuf:"bytes,1,opt,name=create_request,json=createRequest,oneof"`
}

type WatchResponse added in v1.2.0 

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 added in v1.2.0 

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

func (*WatchResponse) GetCanceled added in v1.2.0 

func (m *WatchResponse) GetCanceled() bool

func (*WatchResponse) GetCreated added in v1.2.0 

func (m *WatchResponse) GetCreated() bool

func (*WatchResponse) GetErr added in v1.2.0 

func (m *WatchResponse) GetErr() string

func (*WatchResponse) GetQname added in v1.2.0 

func (m *WatchResponse) GetQname() string

func (*WatchResponse) GetWatchId added in v1.2.0 

func (m *WatchResponse) GetWatchId() int64

func (*WatchResponse) ProtoMessage added in v1.2.0 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset added in v1.2.0 

func (m *WatchResponse) Reset()

func (*WatchResponse) String added in v1.2.0 

func (m *WatchResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.