v1

Documentation

Index

• Constants
• Variables
• func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer)
• type ObserverClient
  • func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient
• type ObserverServer
• type Observer_WatchClient
• type Observer_WatchServer
• type UnimplementedObserverServer
  • func (UnimplementedObserverServer) Watch(Observer_WatchServer) error
• type UnsafeObserverServer
• type WatchResponse
  • func (*WatchResponse) Descriptor() ([]byte, []int)
  • func (*WatchResponse) ProtoMessage()
  • func (x *WatchResponse) ProtoReflect() protoreflect.Message
  • func (x *WatchResponse) Reset()
  • func (x *WatchResponse) String() string

Constants

const (
	Observer_Watch_FullMethodName = "/observer.knita.io.Observer/Watch"
)

Variables

var File_observer_v1_observer_proto protoreflect.FileDescriptor

var Observer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "observer.knita.io.Observer",
	HandlerType: (*ObserverServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Observer_Watch_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "observer/v1/observer.proto",
}

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

Functions

func RegisterObserverServer

func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer)

Types

type ObserverClient

type ObserverClient interface {
	Watch(ctx context.Context, opts ...grpc.CallOption) (Observer_WatchClient, error)
}

ObserverClient is the client API for Observer 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 NewObserverClient

func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient

type ObserverServer

type ObserverServer interface {
	Watch(Observer_WatchServer) error
	// contains filtered or unexported methods
}

ObserverServer is the server API for Observer service. All implementations must embed UnimplementedObserverServer for forward compatibility

type Observer_WatchClient

type Observer_WatchClient interface {
	Send(*v1.Event) error
	CloseAndRecv() (*WatchResponse, error)
	grpc.ClientStream
}

type Observer_WatchServer

type Observer_WatchServer interface {
	SendAndClose(*WatchResponse) error
	Recv() (*v1.Event, error)
	grpc.ServerStream
}

type UnimplementedObserverServer

type UnimplementedObserverServer struct {
}

UnimplementedObserverServer must be embedded to have forward compatible implementations.

func (UnimplementedObserverServer) Watch

func (UnimplementedObserverServer) Watch(Observer_WatchServer) error

type UnsafeObserverServer

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

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

type WatchResponse

type WatchResponse struct {
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) ProtoMessage

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect

func (x *WatchResponse) ProtoReflect() protoreflect.Message

func (*WatchResponse) Reset

func (x *WatchResponse) Reset()

func (*WatchResponse) String

func (x *WatchResponse) String() string