wirepb

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 (
	Wire_WireGet_FullMethodName    = "/wire.Wire/WireGet"
	Wire_WireCreate_FullMethodName = "/wire.Wire/WireCreate"
	Wire_WireDelete_FullMethodName = "/wire.Wire/WireDelete"
	Wire_WireWatch_FullMethodName  = "/wire.Wire/WireWatch"
)

Variables

View Source 
var (
	ErrInvalidLengthWire        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWire          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWire = fmt.Errorf("proto: unexpected end of group")
)
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,
}
View Source 
var Wire_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "wire.Wire",
	HandlerType: (*WireServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WireGet",
			Handler:    _Wire_WireGet_Handler,
		},
		{
			MethodName: "WireCreate",
			Handler:    _Wire_WireCreate_Handler,
		},
		{
			MethodName: "WireDelete",
			Handler:    _Wire_WireDelete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WireWatch",
			Handler:       _Wire_WireWatch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/proto/wirepb/wire.proto",
}

Wire_ServiceDesc is the grpc.ServiceDesc for Wire service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWireServer 

func RegisterWireServer(s grpc.ServiceRegistrar, srv WireServer)

Types

type EmptyResponse 

type EmptyResponse struct {
	StatusCode           StatusCode `protobuf:"varint,1,opt,name=statusCode,proto3,enum=wire.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 {
	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"`
	Local                bool     `protobuf:"varint,4,opt,name=local,proto3" json:"local,omitempty"`
	HostNodeName         string   `protobuf:"bytes,5,opt,name=hostNodeName,proto3" json:"hostNodeName,omitempty"`
	HostIP               string   `protobuf:"bytes,6,opt,name=hostIP,proto3" json:"hostIP,omitempty"`
	ServiceEndpoint      string   `protobuf:"bytes,7,opt,name=serviceEndpoint,proto3" json:"serviceEndpoint,omitempty"`
	ClusterName          string   `protobuf:"bytes,8,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	NoAction             bool     `protobuf:"varint,9,opt,name=NoAction,proto3" json:"NoAction,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetClusterName 

func (m *Endpoint) GetClusterName() string

func (*Endpoint) GetHostIP 

func (m *Endpoint) GetHostIP() string

func (*Endpoint) GetHostNodeName 

func (m *Endpoint) GetHostNodeName() string

func (*Endpoint) GetIfName 

func (m *Endpoint) GetIfName() string

func (*Endpoint) GetLocal 

func (m *Endpoint) GetLocal() bool

func (*Endpoint) GetNoAction 

func (m *Endpoint) GetNoAction() bool

func (*Endpoint) GetNodeName 

func (m *Endpoint) GetNodeName() string

func (*Endpoint) GetServiceEndpoint 

func (m *Endpoint) GetServiceEndpoint() string

func (*Endpoint) GetTopology 

func (m *Endpoint) GetTopology() 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 EndpointStatus 

type EndpointStatus struct {
	StatusCode           StatusCode `protobuf:"varint,1,opt,name=statusCode,proto3,enum=wire.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 (*EndpointStatus) Descriptor 

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

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 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 UnimplementedWireServer 

type UnimplementedWireServer struct {
}

UnimplementedWireServer must be embedded to have forward compatible implementations.

func (UnimplementedWireServer) WireCreate 

func (UnimplementedWireServer) WireCreate(context.Context, *WireRequest) (*EmptyResponse, error)

func (UnimplementedWireServer) WireDelete 

func (UnimplementedWireServer) WireDelete(context.Context, *WireRequest) (*EmptyResponse, error)

func (UnimplementedWireServer) WireGet 

func (UnimplementedWireServer) WireGet(context.Context, *WireRequest) (*WireResponse, error)

func (UnimplementedWireServer) WireWatch 

func (UnimplementedWireServer) WireWatch(*WatchRequest, Wire_WireWatchServer) error

type UnsafeWireServer 

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

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

type WatchRequest 

type WatchRequest struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetName 

func (m *WatchRequest) GetName() string

func (*WatchRequest) GetNamespace 

func (m *WatchRequest) GetNamespace() 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 {
	Namespace            string     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	StatusCode           StatusCode `protobuf:"varint,3,opt,name=statusCode,proto3,enum=wire.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 (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetName 

func (m *WatchResponse) GetName() string

func (*WatchResponse) GetNamespace 

func (m *WatchResponse) GetNamespace() string

func (*WatchResponse) GetReason 

func (m *WatchResponse) GetReason() string

func (*WatchResponse) GetStatusCode 

func (m *WatchResponse) GetStatusCode() StatusCode

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

type WireClient 

type WireClient interface {
	WireGet(ctx context.Context, in *WireRequest, opts ...grpc.CallOption) (*WireResponse, error)
	WireCreate(ctx context.Context, in *WireRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	WireDelete(ctx context.Context, in *WireRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	WireWatch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Wire_WireWatchClient, error)
}

WireClient is the client API for Wire 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 NewWireClient 

func NewWireClient(cc grpc.ClientConnInterface) WireClient

type WireKey 

type WireKey struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WireKey) Descriptor 

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

func (*WireKey) GetName 

func (m *WireKey) GetName() string

func (*WireKey) GetNamespace 

func (m *WireKey) GetNamespace() string

func (*WireKey) Marshal 

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

func (*WireKey) MarshalTo 

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

func (*WireKey) MarshalToSizedBuffer 

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

func (*WireKey) ProtoMessage 

func (*WireKey) ProtoMessage()

func (*WireKey) Reset 

func (m *WireKey) Reset()

func (*WireKey) Size 

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

func (*WireKey) String 

func (m *WireKey) String() string

func (*WireKey) Unmarshal 

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

func (*WireKey) XXX_DiscardUnknown 

func (m *WireKey) XXX_DiscardUnknown()

func (*WireKey) XXX_Marshal 

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

func (*WireKey) XXX_Merge 

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

func (*WireKey) XXX_Size 

func (m *WireKey) XXX_Size() int

func (*WireKey) XXX_Unmarshal 

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

type WireRequest 

type WireRequest struct {
	WireKey              *WireKey    `protobuf:"bytes,1,opt,name=wireKey,proto3" json:"wireKey,omitempty"`
	Endpoints            []*Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Mtu                  uint32      `protobuf:"varint,3,opt,name=mtu,proto3" json:"mtu,omitempty"`
	VpnID                uint32      `protobuf:"varint,4,opt,name=vpnID,proto3" json:"vpnID,omitempty"`
	Intercluster         bool        `protobuf:"varint,5,opt,name=intercluster,proto3" json:"intercluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WireRequest) Descriptor 

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

func (*WireRequest) GetEndpoints 

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

func (*WireRequest) GetIntercluster 

func (m *WireRequest) GetIntercluster() bool

func (*WireRequest) GetMtu 

func (m *WireRequest) GetMtu() uint32

func (*WireRequest) GetVpnID 

func (m *WireRequest) GetVpnID() uint32

func (*WireRequest) GetWireKey 

func (m *WireRequest) GetWireKey() *WireKey

func (*WireRequest) Marshal 

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

func (*WireRequest) MarshalTo 

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

func (*WireRequest) MarshalToSizedBuffer 

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

func (*WireRequest) ProtoMessage 

func (*WireRequest) ProtoMessage()

func (*WireRequest) Reset 

func (m *WireRequest) Reset()

func (*WireRequest) Size 

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

func (*WireRequest) String 

func (m *WireRequest) String() string

func (*WireRequest) Unmarshal 

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

func (*WireRequest) XXX_DiscardUnknown 

func (m *WireRequest) XXX_DiscardUnknown()

func (*WireRequest) XXX_Marshal 

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

func (*WireRequest) XXX_Merge 

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

func (*WireRequest) XXX_Size 

func (m *WireRequest) XXX_Size() int

func (*WireRequest) XXX_Unmarshal 

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

type WireResponse 

type WireResponse struct {
	WireKey              *WireKey          `protobuf:"bytes,1,opt,name=wireKey,proto3" json:"wireKey,omitempty"`
	EndpointsStatus      []*EndpointStatus `protobuf:"bytes,2,rep,name=endpointsStatus,proto3" json:"endpointsStatus,omitempty"`
	StatusCode           StatusCode        `protobuf:"varint,3,opt,name=statusCode,proto3,enum=wire.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 (*WireResponse) Descriptor 

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

func (*WireResponse) GetEndpointsStatus 

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

func (*WireResponse) GetReason 

func (m *WireResponse) GetReason() string

func (*WireResponse) GetStatusCode 

func (m *WireResponse) GetStatusCode() StatusCode

func (*WireResponse) GetWireKey 

func (m *WireResponse) GetWireKey() *WireKey

func (*WireResponse) Marshal 

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

func (*WireResponse) MarshalTo 

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

func (*WireResponse) MarshalToSizedBuffer 

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

func (*WireResponse) ProtoMessage 

func (*WireResponse) ProtoMessage()

func (*WireResponse) Reset 

func (m *WireResponse) Reset()

func (*WireResponse) Size 

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

func (*WireResponse) String 

func (m *WireResponse) String() string

func (*WireResponse) Unmarshal 

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

func (*WireResponse) XXX_DiscardUnknown 

func (m *WireResponse) XXX_DiscardUnknown()

func (*WireResponse) XXX_Marshal 

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

func (*WireResponse) XXX_Merge 

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

func (*WireResponse) XXX_Size 

func (m *WireResponse) XXX_Size() int

func (*WireResponse) XXX_Unmarshal 

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

type WireServer 

type WireServer interface {
	WireGet(context.Context, *WireRequest) (*WireResponse, error)
	WireCreate(context.Context, *WireRequest) (*EmptyResponse, error)
	WireDelete(context.Context, *WireRequest) (*EmptyResponse, error)
	WireWatch(*WatchRequest, Wire_WireWatchServer) error
	// contains filtered or unexported methods
}

WireServer is the server API for Wire service. All implementations must embed UnimplementedWireServer for forward compatibility

type Wire_WireWatchClient 

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

type Wire_WireWatchServer 

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

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.