api_srpc.pb.go

// Code generated by protoc-gen-srpc. DO NOT EDIT.
// protoc-gen-srpc version: v0.19.1
// source: github.com/aperturerobotics/bifrost/pubsub/api/api.proto

package pubsub_api

import (
	context "context"

	srpc "github.com/aperturerobotics/starpc/srpc"
)

type SRPCPubSubServiceClient interface {
	SRPCClient() srpc.Client

	Subscribe(ctx context.Context) (SRPCPubSubService_SubscribeClient, error)
}

type srpcPubSubServiceClient struct {
	cc        srpc.Client
	serviceID string
}

func NewSRPCPubSubServiceClient(cc srpc.Client) SRPCPubSubServiceClient {
	return &srpcPubSubServiceClient{cc: cc, serviceID: SRPCPubSubServiceServiceID}
}

func NewSRPCPubSubServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPubSubServiceClient {
	if serviceID == "" {
		serviceID = SRPCPubSubServiceServiceID
	}
	return &srpcPubSubServiceClient{cc: cc, serviceID: serviceID}
}

func (c *srpcPubSubServiceClient) SRPCClient() srpc.Client { return c.cc }

func (c *srpcPubSubServiceClient) Subscribe(ctx context.Context) (SRPCPubSubService_SubscribeClient, error) {
	stream, err := c.cc.NewStream(ctx, c.serviceID, "Subscribe", nil)
	if err != nil {
		return nil, err
	}
	strm := &srpcPubSubService_SubscribeClient{stream}
	return strm, nil
}

type SRPCPubSubService_SubscribeClient interface {
	srpc.Stream
	Send(*SubscribeRequest) error
	Recv() (*SubscribeResponse, error)
	RecvTo(*SubscribeResponse) error
}

type srpcPubSubService_SubscribeClient struct {
	srpc.Stream
}

func (x *srpcPubSubService_SubscribeClient) Send(m *SubscribeRequest) error {
	return x.MsgSend(m)
}

func (x *srpcPubSubService_SubscribeClient) Recv() (*SubscribeResponse, error) {
	m := new(SubscribeResponse)
	if err := x.MsgRecv(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (x *srpcPubSubService_SubscribeClient) RecvTo(m *SubscribeResponse) error {
	return x.MsgRecv(m)
}

type SRPCPubSubServiceServer interface {
	Subscribe(SRPCPubSubService_SubscribeStream) error
}

type SRPCPubSubServiceUnimplementedServer struct{}

func (s *SRPCPubSubServiceUnimplementedServer) Subscribe(SRPCPubSubService_SubscribeStream) error {
	return srpc.ErrUnimplemented
}

const SRPCPubSubServiceServiceID = "pubsub.api.PubSubService"

type SRPCPubSubServiceHandler struct {
	serviceID string
	impl      SRPCPubSubServiceServer
}

// NewSRPCPubSubServiceHandler constructs a new RPC handler.
// serviceID: if empty, uses default: pubsub.api.PubSubService
func NewSRPCPubSubServiceHandler(impl SRPCPubSubServiceServer, serviceID string) srpc.Handler {
	if serviceID == "" {
		serviceID = SRPCPubSubServiceServiceID
	}
	return &SRPCPubSubServiceHandler{impl: impl, serviceID: serviceID}
}

// SRPCRegisterPubSubService registers the implementation with the mux.
// Uses the default serviceID: pubsub.api.PubSubService
func SRPCRegisterPubSubService(mux srpc.Mux, impl SRPCPubSubServiceServer) error {
	return mux.Register(NewSRPCPubSubServiceHandler(impl, ""))
}

func (d *SRPCPubSubServiceHandler) GetServiceID() string { return d.serviceID }

func (SRPCPubSubServiceHandler) GetMethodIDs() []string {
	return []string{
		"Subscribe",
	}
}

func (d *SRPCPubSubServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error) {
	if serviceID != "" && serviceID != d.GetServiceID() {
		return false, nil
	}

	switch methodID {
	case "Subscribe":
		return true, d.InvokeMethod_Subscribe(d.impl, strm)
	default:
		return false, nil
	}
}

func (SRPCPubSubServiceHandler) InvokeMethod_Subscribe(impl SRPCPubSubServiceServer, strm srpc.Stream) error {
	clientStrm := &srpcPubSubService_SubscribeStream{strm}
	return impl.Subscribe(clientStrm)
}

type SRPCPubSubService_SubscribeStream interface {
	srpc.Stream
	Send(*SubscribeResponse) error
	SendAndClose(*SubscribeResponse) error
	Recv() (*SubscribeRequest, error)
}

type srpcPubSubService_SubscribeStream struct {
	srpc.Stream
}

func (x *srpcPubSubService_SubscribeStream) Send(m *SubscribeResponse) error {
	return x.MsgSend(m)
}

func (x *srpcPubSubService_SubscribeStream) SendAndClose(m *SubscribeResponse) error {
	if err := x.MsgSend(m); err != nil {
		return err
	}
	return x.CloseSend()
}

func (x *srpcPubSubService_SubscribeStream) Recv() (*SubscribeRequest, error) {
	m := new(SubscribeRequest)
	if err := x.MsgRecv(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (x *srpcPubSubService_SubscribeStream) RecvTo(m *SubscribeRequest) error {
	return x.MsgRecv(m)
}