pb

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Dec 15, 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

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

Jump to

Keyboard shortcuts

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