endpointpb

package
v0.0.0-...-984f6f0 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NodeEndpoint_EndpointGet_FullMethodName    = "/endpoint.NodeEndpoint/EndpointGet"
	NodeEndpoint_EndpointCreate_FullMethodName = "/endpoint.NodeEndpoint/EndpointCreate"
	NodeEndpoint_EndpointDelete_FullMethodName = "/endpoint.NodeEndpoint/EndpointDelete"
	NodeEndpoint_EndpointWatch_FullMethodName  = "/endpoint.NodeEndpoint/EndpointWatch"
)

Variables

View Source 
var (
	ErrInvalidLengthEndpoint        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEndpoint          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEndpoint = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var NodeEndpoint_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "endpoint.NodeEndpoint",
	HandlerType: (*NodeEndpointServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EndpointGet",
			Handler:    _NodeEndpoint_EndpointGet_Handler,
		},
		{
			MethodName: "EndpointCreate",
			Handler:    _NodeEndpoint_EndpointCreate_Handler,
		},
		{
			MethodName: "EndpointDelete",
			Handler:    _NodeEndpoint_EndpointDelete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EndpointWatch",
			Handler:       _NodeEndpoint_EndpointWatch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/proto/endpointpb/endpoint.proto",
}

NodeEndpoint_ServiceDesc is the grpc.ServiceDesc for NodeEndpoint 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 StatusCode_name = map[int32]string{
	0: "OK",
	1: "NOK",
	2: "NotFound",
}
View Source 
var StatusCode_value = map[string]int32{
	"OK":       0,
	"NOK":      1,
	"NotFound": 2,
}

Functions

func RegisterNodeEndpointServer 

func RegisterNodeEndpointServer(s grpc.ServiceRegistrar, srv NodeEndpointServer)

Types

type EmptyResponse 

type EmptyResponse struct {
	StatusCode           StatusCode `protobuf:"varint,1,opt,name=statusCode,proto3,enum=endpoint.StatusCode" json:"statusCode,omitempty"`
	Reason               string     `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) GetReason 

func (m *EmptyResponse) GetReason() string

func (*EmptyResponse) GetStatusCode 

func (m *EmptyResponse) GetStatusCode() StatusCode

func (*EmptyResponse) Marshal 

func (m *EmptyResponse) Marshal() (dAtA []byte, err error)

func (*EmptyResponse) MarshalTo 

func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)

func (*EmptyResponse) MarshalToSizedBuffer 

func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

func (m *EmptyResponse) Size() (n int)

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

func (m *EmptyResponse) Unmarshal(dAtA []byte) error

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyResponse) XXX_Merge 

func (m *EmptyResponse) XXX_Merge(src proto.Message)

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

func (m *EmptyResponse) XXX_Unmarshal(b []byte) error

type Endpoint 

type Endpoint struct {
	IfName               string   `protobuf:"bytes,1,opt,name=ifName,proto3" json:"ifName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetIfName 

func (m *Endpoint) GetIfName() string

func (*Endpoint) Marshal 

func (m *Endpoint) Marshal() (dAtA []byte, err error)

func (*Endpoint) MarshalTo 

func (m *Endpoint) MarshalTo(dAtA []byte) (int, error)

func (*Endpoint) MarshalToSizedBuffer 

func (m *Endpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) Size 

func (m *Endpoint) Size() (n int)

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) Unmarshal 

func (m *Endpoint) Unmarshal(dAtA []byte) error

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoint) XXX_Merge 

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

func (m *Endpoint) XXX_Unmarshal(b []byte) error

type EndpointRequest 

type EndpointRequest struct {
	NodeKey              *NodeKey    `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"`
	Endpoints            []*Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	HostNodeName         string      `protobuf:"bytes,3,opt,name=hostNodeName,proto3" json:"hostNodeName,omitempty"`
	HostIP               string      `protobuf:"bytes,4,opt,name=hostIP,proto3" json:"hostIP,omitempty"`
	ServiceEndpoint      string      `protobuf:"bytes,5,opt,name=serviceEndpoint,proto3" json:"serviceEndpoint,omitempty"`
	ServerType           bool        `protobuf:"varint,6,opt,name=serverType,proto3" json:"serverType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*EndpointRequest) Descriptor 

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

func (*EndpointRequest) GetEndpoints 

func (m *EndpointRequest) GetEndpoints() []*Endpoint

func (*EndpointRequest) GetHostIP 

func (m *EndpointRequest) GetHostIP() string

func (*EndpointRequest) GetHostNodeName 

func (m *EndpointRequest) GetHostNodeName() string

func (*EndpointRequest) GetNodeKey 

func (m *EndpointRequest) GetNodeKey() *NodeKey

func (*EndpointRequest) GetServerType 

func (m *EndpointRequest) GetServerType() bool

func (*EndpointRequest) GetServiceEndpoint 

func (m *EndpointRequest) GetServiceEndpoint() string

func (*EndpointRequest) Marshal 

func (m *EndpointRequest) Marshal() (dAtA []byte, err error)

func (*EndpointRequest) MarshalTo 

func (m *EndpointRequest) MarshalTo(dAtA []byte) (int, error)

func (*EndpointRequest) MarshalToSizedBuffer 

func (m *EndpointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointRequest) ProtoMessage 

func (*EndpointRequest) ProtoMessage()

func (*EndpointRequest) Reset 

func (m *EndpointRequest) Reset()

func (*EndpointRequest) Size 

func (m *EndpointRequest) Size() (n int)

func (*EndpointRequest) String 

func (m *EndpointRequest) String() string

func (*EndpointRequest) Unmarshal 

func (m *EndpointRequest) Unmarshal(dAtA []byte) error

func (*EndpointRequest) XXX_DiscardUnknown 

func (m *EndpointRequest) XXX_DiscardUnknown()

func (*EndpointRequest) XXX_Marshal 

func (m *EndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointRequest) XXX_Merge 

func (m *EndpointRequest) XXX_Merge(src proto.Message)

func (*EndpointRequest) XXX_Size 

func (m *EndpointRequest) XXX_Size() int

func (*EndpointRequest) XXX_Unmarshal 

func (m *EndpointRequest) XXX_Unmarshal(b []byte) error

type EndpointResponse 

type EndpointResponse struct {
	NodeKey              *NodeKey          `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"`
	EndpointsStatus      []*EndpointStatus `protobuf:"bytes,2,rep,name=endpointsStatus,proto3" json:"endpointsStatus,omitempty"`
	StatusCode           StatusCode        `protobuf:"varint,3,opt,name=statusCode,proto3,enum=endpoint.StatusCode" json:"statusCode,omitempty"`
	Reason               string            `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EndpointResponse) Descriptor 

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

func (*EndpointResponse) GetEndpointsStatus 

func (m *EndpointResponse) GetEndpointsStatus() []*EndpointStatus

func (*EndpointResponse) GetNodeKey 

func (m *EndpointResponse) GetNodeKey() *NodeKey

func (*EndpointResponse) GetReason 

func (m *EndpointResponse) GetReason() string

func (*EndpointResponse) GetStatusCode 

func (m *EndpointResponse) GetStatusCode() StatusCode

func (*EndpointResponse) Marshal 

func (m *EndpointResponse) Marshal() (dAtA []byte, err error)

func (*EndpointResponse) MarshalTo 

func (m *EndpointResponse) MarshalTo(dAtA []byte) (int, error)

func (*EndpointResponse) MarshalToSizedBuffer 

func (m *EndpointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointResponse) ProtoMessage 

func (*EndpointResponse) ProtoMessage()

func (*EndpointResponse) Reset 

func (m *EndpointResponse) Reset()

func (*EndpointResponse) Size 

func (m *EndpointResponse) Size() (n int)

func (*EndpointResponse) String 

func (m *EndpointResponse) String() string

func (*EndpointResponse) Unmarshal 

func (m *EndpointResponse) Unmarshal(dAtA []byte) error

func (*EndpointResponse) XXX_DiscardUnknown 

func (m *EndpointResponse) XXX_DiscardUnknown()

func (*EndpointResponse) XXX_Marshal 

func (m *EndpointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointResponse) XXX_Merge 

func (m *EndpointResponse) XXX_Merge(src proto.Message)

func (*EndpointResponse) XXX_Size 

func (m *EndpointResponse) XXX_Size() int

func (*EndpointResponse) XXX_Unmarshal 

func (m *EndpointResponse) XXX_Unmarshal(b []byte) error

type EndpointStatus 

type EndpointStatus struct {
	IfName               string     `protobuf:"bytes,1,opt,name=ifName,proto3" json:"ifName,omitempty"`
	StatusCode           StatusCode `protobuf:"varint,2,opt,name=statusCode,proto3,enum=endpoint.StatusCode" json:"statusCode,omitempty"`
	Reason               string     `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*EndpointStatus) Descriptor 

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

func (*EndpointStatus) GetIfName 

func (m *EndpointStatus) GetIfName() string

func (*EndpointStatus) GetReason 

func (m *EndpointStatus) GetReason() string

func (*EndpointStatus) GetStatusCode 

func (m *EndpointStatus) GetStatusCode() StatusCode

func (*EndpointStatus) Marshal 

func (m *EndpointStatus) Marshal() (dAtA []byte, err error)

func (*EndpointStatus) MarshalTo 

func (m *EndpointStatus) MarshalTo(dAtA []byte) (int, error)

func (*EndpointStatus) MarshalToSizedBuffer 

func (m *EndpointStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointStatus) ProtoMessage 

func (*EndpointStatus) ProtoMessage()

func (*EndpointStatus) Reset 

func (m *EndpointStatus) Reset()

func (*EndpointStatus) Size 

func (m *EndpointStatus) Size() (n int)

func (*EndpointStatus) String 

func (m *EndpointStatus) String() string

func (*EndpointStatus) Unmarshal 

func (m *EndpointStatus) Unmarshal(dAtA []byte) error

func (*EndpointStatus) XXX_DiscardUnknown 

func (m *EndpointStatus) XXX_DiscardUnknown()

func (*EndpointStatus) XXX_Marshal 

func (m *EndpointStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointStatus) XXX_Merge 

func (m *EndpointStatus) XXX_Merge(src proto.Message)

func (*EndpointStatus) XXX_Size 

func (m *EndpointStatus) XXX_Size() int

func (*EndpointStatus) XXX_Unmarshal 

func (m *EndpointStatus) XXX_Unmarshal(b []byte) error

type NodeEndpointClient 

type NodeEndpointClient interface {
	EndpointGet(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EndpointResponse, error)
	EndpointCreate(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	EndpointDelete(ctx context.Context, in *EndpointRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	EndpointWatch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (NodeEndpoint_EndpointWatchClient, error)
}

NodeEndpointClient is the client API for NodeEndpoint 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 NewNodeEndpointClient 

func NewNodeEndpointClient(cc grpc.ClientConnInterface) NodeEndpointClient

type NodeEndpointServer 

type NodeEndpointServer interface {
	EndpointGet(context.Context, *EndpointRequest) (*EndpointResponse, error)
	EndpointCreate(context.Context, *EndpointRequest) (*EmptyResponse, error)
	EndpointDelete(context.Context, *EndpointRequest) (*EmptyResponse, error)
	EndpointWatch(*WatchRequest, NodeEndpoint_EndpointWatchServer) error
	// contains filtered or unexported methods
}

NodeEndpointServer is the server API for NodeEndpoint service. All implementations must embed UnimplementedNodeEndpointServer for forward compatibility

type NodeEndpoint_EndpointWatchClient 

type NodeEndpoint_EndpointWatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type NodeEndpoint_EndpointWatchServer 

type NodeEndpoint_EndpointWatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type NodeKey 

type NodeKey struct {
	Topology             string   `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	NodeName             string   `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeKey) Descriptor 

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

func (*NodeKey) GetNodeName 

func (m *NodeKey) GetNodeName() string

func (*NodeKey) GetTopology 

func (m *NodeKey) GetTopology() string

func (*NodeKey) Marshal 

func (m *NodeKey) Marshal() (dAtA []byte, err error)

func (*NodeKey) MarshalTo 

func (m *NodeKey) MarshalTo(dAtA []byte) (int, error)

func (*NodeKey) MarshalToSizedBuffer 

func (m *NodeKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeKey) ProtoMessage 

func (*NodeKey) ProtoMessage()

func (*NodeKey) Reset 

func (m *NodeKey) Reset()

func (*NodeKey) Size 

func (m *NodeKey) Size() (n int)

func (*NodeKey) String 

func (m *NodeKey) String() string

func (*NodeKey) Unmarshal 

func (m *NodeKey) Unmarshal(dAtA []byte) error

func (*NodeKey) XXX_DiscardUnknown 

func (m *NodeKey) XXX_DiscardUnknown()

func (*NodeKey) XXX_Marshal 

func (m *NodeKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeKey) XXX_Merge 

func (m *NodeKey) XXX_Merge(src proto.Message)

func (*NodeKey) XXX_Size 

func (m *NodeKey) XXX_Size() int

func (*NodeKey) XXX_Unmarshal 

func (m *NodeKey) XXX_Unmarshal(b []byte) error

type StatusCode 

type StatusCode int32
const (
	StatusCode_OK       StatusCode = 0
	StatusCode_NOK      StatusCode = 1
	StatusCode_NotFound StatusCode = 2
)

func (StatusCode) EnumDescriptor 

func (StatusCode) EnumDescriptor() ([]byte, []int)

func (StatusCode) String 

func (x StatusCode) String() string

type UnimplementedNodeEndpointServer 

type UnimplementedNodeEndpointServer struct {
}

UnimplementedNodeEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeEndpointServer) EndpointCreate 

func (UnimplementedNodeEndpointServer) EndpointCreate(context.Context, *EndpointRequest) (*EmptyResponse, error)

func (UnimplementedNodeEndpointServer) EndpointDelete 

func (UnimplementedNodeEndpointServer) EndpointDelete(context.Context, *EndpointRequest) (*EmptyResponse, error)

func (UnimplementedNodeEndpointServer) EndpointGet 

func (UnimplementedNodeEndpointServer) EndpointGet(context.Context, *EndpointRequest) (*EndpointResponse, error)

func (UnimplementedNodeEndpointServer) EndpointWatch 

func (UnimplementedNodeEndpointServer) EndpointWatch(*WatchRequest, NodeEndpoint_EndpointWatchServer) error

type UnsafeNodeEndpointServer 

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

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

type WatchRequest 

type WatchRequest struct {
	Topology             string   `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	NodeName             string   `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	IfName               string   `protobuf:"bytes,3,opt,name=ifName,proto3" json:"ifName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetIfName 

func (m *WatchRequest) GetIfName() string

func (*WatchRequest) GetNodeName 

func (m *WatchRequest) GetNodeName() string

func (*WatchRequest) GetTopology 

func (m *WatchRequest) GetTopology() string

func (*WatchRequest) Marshal 

func (m *WatchRequest) Marshal() (dAtA []byte, err error)

func (*WatchRequest) MarshalTo 

func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchRequest) MarshalToSizedBuffer 

func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size 

func (m *WatchRequest) Size() (n int)

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) Unmarshal 

func (m *WatchRequest) Unmarshal(dAtA []byte) error

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchRequest) XXX_Merge 

func (m *WatchRequest) XXX_Merge(src proto.Message)

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

func (m *WatchRequest) XXX_Unmarshal(b []byte) error

type WatchResponse 

type WatchResponse struct {
	Topology             string     `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	NodeName             string     `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	IfName               string     `protobuf:"bytes,3,opt,name=ifName,proto3" json:"ifName,omitempty"`
	StatusCode           StatusCode `protobuf:"varint,4,opt,name=statusCode,proto3,enum=endpoint.StatusCode" json:"statusCode,omitempty"`
	Reason               string     `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetIfName 

func (m *WatchResponse) GetIfName() string

func (*WatchResponse) GetNodeName 

func (m *WatchResponse) GetNodeName() string

func (*WatchResponse) GetReason 

func (m *WatchResponse) GetReason() string

func (*WatchResponse) GetStatusCode 

func (m *WatchResponse) GetStatusCode() StatusCode

func (*WatchResponse) GetTopology 

func (m *WatchResponse) GetTopology() string

func (*WatchResponse) Marshal 

func (m *WatchResponse) Marshal() (dAtA []byte, err error)

func (*WatchResponse) MarshalTo 

func (m *WatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*WatchResponse) MarshalToSizedBuffer 

func (m *WatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) Size 

func (m *WatchResponse) Size() (n int)

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) Unmarshal 

func (m *WatchResponse) Unmarshal(dAtA []byte) error

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchResponse) XXX_Merge 

func (m *WatchResponse) XXX_Merge(src proto.Message)

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

func (m *WatchResponse) XXX_Unmarshal(b []byte) error

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.