v1

Nov 8, 2024

Changes in this version

+ const SideInput_IsReady_FullMethodName

+ const SideInput_RetrieveSideInput_FullMethodName

Aug 29, 2023

Changes in this version

+ var File_pkg_apis_proto_sideinput_v1_sideinput_proto protoreflect.FileDescriptor

+ var SideInput_ServiceDesc = grpc.ServiceDesc

+ func RegisterSideInputServer(s grpc.ServiceRegistrar, srv SideInputServer)

+ type ReadyResponse struct

+ Ready bool

+ func (*ReadyResponse) Descriptor() ([]byte, []int)

+ func (*ReadyResponse) ProtoMessage()

+ func (x *ReadyResponse) GetReady() bool

+ func (x *ReadyResponse) ProtoReflect() protoreflect.Message

+ func (x *ReadyResponse) Reset()

+ func (x *ReadyResponse) String() string

+ type SideInputClient interface

+ IsReady func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)

+ RetrieveSideInput func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SideInputResponse, error)

+ func NewSideInputClient(cc grpc.ClientConnInterface) SideInputClient

+ type SideInputResponse struct

+ NoBroadcast bool

+ Value []byte

+ func (*SideInputResponse) Descriptor() ([]byte, []int)

+ func (*SideInputResponse) ProtoMessage()

+ func (x *SideInputResponse) GetNoBroadcast() bool

+ func (x *SideInputResponse) GetValue() []byte

+ func (x *SideInputResponse) ProtoReflect() protoreflect.Message

+ func (x *SideInputResponse) Reset()

+ func (x *SideInputResponse) String() string

+ type SideInputServer interface

+ IsReady func(context.Context, *emptypb.Empty) (*ReadyResponse, error)

+ RetrieveSideInput func(context.Context, *emptypb.Empty) (*SideInputResponse, error)

+ type UnimplementedSideInputServer struct

+ func (UnimplementedSideInputServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)

+ func (UnimplementedSideInputServer) RetrieveSideInput(context.Context, *emptypb.Empty) (*SideInputResponse, error)

+ type UnsafeSideInputServer interface