// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 // - protoc v5.29.3 // source: mi.proto package mi import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" emptypb "google.golang.org/protobuf/types/known/emptypb" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.64.0 or later. const _ = grpc.SupportPackageIsVersion9 const ( SwitchTracker_Members_FullMethodName = "/within.website.x.mi.SwitchTracker/Members" SwitchTracker_WhoIsFront_FullMethodName = "/within.website.x.mi.SwitchTracker/WhoIsFront" SwitchTracker_Switch_FullMethodName = "/within.website.x.mi.SwitchTracker/Switch" SwitchTracker_GetSwitch_FullMethodName = "/within.website.x.mi.SwitchTracker/GetSwitch" SwitchTracker_ListSwitches_FullMethodName = "/within.website.x.mi.SwitchTracker/ListSwitches" ) // SwitchTrackerClient is the client API for SwitchTracker 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. type SwitchTrackerClient interface { Members(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MembersResp, error) WhoIsFront(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FrontChange, error) Switch(ctx context.Context, in *SwitchReq, opts ...grpc.CallOption) (*SwitchResp, error) GetSwitch(ctx context.Context, in *GetSwitchReq, opts ...grpc.CallOption) (*FrontChange, error) ListSwitches(ctx context.Context, in *ListSwitchesReq, opts ...grpc.CallOption) (*ListSwitchesResp, error) } type switchTrackerClient struct { cc grpc.ClientConnInterface } func NewSwitchTrackerClient(cc grpc.ClientConnInterface) SwitchTrackerClient { return &switchTrackerClient{cc} } func (c *switchTrackerClient) Members(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MembersResp, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MembersResp) err := c.cc.Invoke(ctx, SwitchTracker_Members_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *switchTrackerClient) WhoIsFront(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FrontChange, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(FrontChange) err := c.cc.Invoke(ctx, SwitchTracker_WhoIsFront_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *switchTrackerClient) Switch(ctx context.Context, in *SwitchReq, opts ...grpc.CallOption) (*SwitchResp, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(SwitchResp) err := c.cc.Invoke(ctx, SwitchTracker_Switch_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *switchTrackerClient) GetSwitch(ctx context.Context, in *GetSwitchReq, opts ...grpc.CallOption) (*FrontChange, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(FrontChange) err := c.cc.Invoke(ctx, SwitchTracker_GetSwitch_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *switchTrackerClient) ListSwitches(ctx context.Context, in *ListSwitchesReq, opts ...grpc.CallOption) (*ListSwitchesResp, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ListSwitchesResp) err := c.cc.Invoke(ctx, SwitchTracker_ListSwitches_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } // SwitchTrackerServer is the server API for SwitchTracker service. // All implementations must embed UnimplementedSwitchTrackerServer // for forward compatibility. type SwitchTrackerServer interface { Members(context.Context, *emptypb.Empty) (*MembersResp, error) WhoIsFront(context.Context, *emptypb.Empty) (*FrontChange, error) Switch(context.Context, *SwitchReq) (*SwitchResp, error) GetSwitch(context.Context, *GetSwitchReq) (*FrontChange, error) ListSwitches(context.Context, *ListSwitchesReq) (*ListSwitchesResp, error) mustEmbedUnimplementedSwitchTrackerServer() } // UnimplementedSwitchTrackerServer must be embedded to have // forward compatible implementations. // // NOTE: this should be embedded by value instead of pointer to avoid a nil // pointer dereference when methods are called. type UnimplementedSwitchTrackerServer struct{} func (UnimplementedSwitchTrackerServer) Members(context.Context, *emptypb.Empty) (*MembersResp, error) { return nil, status.Errorf(codes.Unimplemented, "method Members not implemented") } func (UnimplementedSwitchTrackerServer) WhoIsFront(context.Context, *emptypb.Empty) (*FrontChange, error) { return nil, status.Errorf(codes.Unimplemented, "method WhoIsFront not implemented") } func (UnimplementedSwitchTrackerServer) Switch(context.Context, *SwitchReq) (*SwitchResp, error) { return nil, status.Errorf(codes.Unimplemented, "method Switch not implemented") } func (UnimplementedSwitchTrackerServer) GetSwitch(context.Context, *GetSwitchReq) (*FrontChange, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSwitch not implemented") } func (UnimplementedSwitchTrackerServer) ListSwitches(context.Context, *ListSwitchesReq) (*ListSwitchesResp, error) { return nil, status.Errorf(codes.Unimplemented, "method ListSwitches not implemented") } func (UnimplementedSwitchTrackerServer) mustEmbedUnimplementedSwitchTrackerServer() {} func (UnimplementedSwitchTrackerServer) testEmbeddedByValue() {} // UnsafeSwitchTrackerServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to SwitchTrackerServer will // result in compilation errors. type UnsafeSwitchTrackerServer interface { mustEmbedUnimplementedSwitchTrackerServer() } func RegisterSwitchTrackerServer(s grpc.ServiceRegistrar, srv SwitchTrackerServer) { // If the following call pancis, it indicates UnimplementedSwitchTrackerServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { t.testEmbeddedByValue() } s.RegisterService(&SwitchTracker_ServiceDesc, srv) } func _SwitchTracker_Members_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SwitchTrackerServer).Members(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: SwitchTracker_Members_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SwitchTrackerServer).Members(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _SwitchTracker_WhoIsFront_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SwitchTrackerServer).WhoIsFront(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: SwitchTracker_WhoIsFront_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SwitchTrackerServer).WhoIsFront(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _SwitchTracker_Switch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SwitchReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SwitchTrackerServer).Switch(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: SwitchTracker_Switch_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SwitchTrackerServer).Switch(ctx, req.(*SwitchReq)) } return interceptor(ctx, in, info, handler) } func _SwitchTracker_GetSwitch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetSwitchReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SwitchTrackerServer).GetSwitch(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: SwitchTracker_GetSwitch_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SwitchTrackerServer).GetSwitch(ctx, req.(*GetSwitchReq)) } return interceptor(ctx, in, info, handler) } func _SwitchTracker_ListSwitches_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListSwitchesReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SwitchTrackerServer).ListSwitches(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: SwitchTracker_ListSwitches_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SwitchTrackerServer).ListSwitches(ctx, req.(*ListSwitchesReq)) } return interceptor(ctx, in, info, handler) } // SwitchTracker_ServiceDesc is the grpc.ServiceDesc for SwitchTracker service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var SwitchTracker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "within.website.x.mi.SwitchTracker", HandlerType: (*SwitchTrackerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Members", Handler: _SwitchTracker_Members_Handler, }, { MethodName: "WhoIsFront", Handler: _SwitchTracker_WhoIsFront_Handler, }, { MethodName: "Switch", Handler: _SwitchTracker_Switch_Handler, }, { MethodName: "GetSwitch", Handler: _SwitchTracker_GetSwitch_Handler, }, { MethodName: "ListSwitches", Handler: _SwitchTracker_ListSwitches_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mi.proto", } const ( POSSE_RefreshBlog_FullMethodName = "/within.website.x.mi.POSSE/RefreshBlog" ) // POSSEClient is the client API for POSSE 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. type POSSEClient interface { RefreshBlog(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) } type pOSSEClient struct { cc grpc.ClientConnInterface } func NewPOSSEClient(cc grpc.ClientConnInterface) POSSEClient { return &pOSSEClient{cc} } func (c *pOSSEClient) RefreshBlog(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(emptypb.Empty) err := c.cc.Invoke(ctx, POSSE_RefreshBlog_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } // POSSEServer is the server API for POSSE service. // All implementations must embed UnimplementedPOSSEServer // for forward compatibility. type POSSEServer interface { RefreshBlog(context.Context, *emptypb.Empty) (*emptypb.Empty, error) mustEmbedUnimplementedPOSSEServer() } // UnimplementedPOSSEServer must be embedded to have // forward compatible implementations. // // NOTE: this should be embedded by value instead of pointer to avoid a nil // pointer dereference when methods are called. type UnimplementedPOSSEServer struct{} func (UnimplementedPOSSEServer) RefreshBlog(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method RefreshBlog not implemented") } func (UnimplementedPOSSEServer) mustEmbedUnimplementedPOSSEServer() {} func (UnimplementedPOSSEServer) testEmbeddedByValue() {} // UnsafePOSSEServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to POSSEServer will // result in compilation errors. type UnsafePOSSEServer interface { mustEmbedUnimplementedPOSSEServer() } func RegisterPOSSEServer(s grpc.ServiceRegistrar, srv POSSEServer) { // If the following call pancis, it indicates UnimplementedPOSSEServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { t.testEmbeddedByValue() } s.RegisterService(&POSSE_ServiceDesc, srv) } func _POSSE_RefreshBlog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(POSSEServer).RefreshBlog(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: POSSE_RefreshBlog_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(POSSEServer).RefreshBlog(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } // POSSE_ServiceDesc is the grpc.ServiceDesc for POSSE service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var POSSE_ServiceDesc = grpc.ServiceDesc{ ServiceName: "within.website.x.mi.POSSE", HandlerType: (*POSSEServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RefreshBlog", Handler: _POSSE_RefreshBlog_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mi.proto", } const ( Events_Get_FullMethodName = "/within.website.x.mi.Events/Get" Events_Add_FullMethodName = "/within.website.x.mi.Events/Add" Events_Remove_FullMethodName = "/within.website.x.mi.Events/Remove" ) // EventsClient is the client API for Events 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. // // Events lets users fetch the current feed of events that Xe will be attending. type EventsClient interface { // Get fetches the current feed of upcoming events. Get(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*EventFeed, error) // Add adds an event to the feed. Add(ctx context.Context, in *Event, opts ...grpc.CallOption) (*emptypb.Empty, error) // Remove removes an event from the feed. Remove(ctx context.Context, in *Event, opts ...grpc.CallOption) (*emptypb.Empty, error) } type eventsClient struct { cc grpc.ClientConnInterface } func NewEventsClient(cc grpc.ClientConnInterface) EventsClient { return &eventsClient{cc} } func (c *eventsClient) Get(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*EventFeed, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(EventFeed) err := c.cc.Invoke(ctx, Events_Get_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *eventsClient) Add(ctx context.Context, in *Event, opts ...grpc.CallOption) (*emptypb.Empty, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Events_Add_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } func (c *eventsClient) Remove(ctx context.Context, in *Event, opts ...grpc.CallOption) (*emptypb.Empty, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Events_Remove_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } // EventsServer is the server API for Events service. // All implementations must embed UnimplementedEventsServer // for forward compatibility. // // Events lets users fetch the current feed of events that Xe will be attending. type EventsServer interface { // Get fetches the current feed of upcoming events. Get(context.Context, *emptypb.Empty) (*EventFeed, error) // Add adds an event to the feed. Add(context.Context, *Event) (*emptypb.Empty, error) // Remove removes an event from the feed. Remove(context.Context, *Event) (*emptypb.Empty, error) mustEmbedUnimplementedEventsServer() } // UnimplementedEventsServer must be embedded to have // forward compatible implementations. // // NOTE: this should be embedded by value instead of pointer to avoid a nil // pointer dereference when methods are called. type UnimplementedEventsServer struct{} func (UnimplementedEventsServer) Get(context.Context, *emptypb.Empty) (*EventFeed, error) { return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") } func (UnimplementedEventsServer) Add(context.Context, *Event) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method Add not implemented") } func (UnimplementedEventsServer) Remove(context.Context, *Event) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method Remove not implemented") } func (UnimplementedEventsServer) mustEmbedUnimplementedEventsServer() {} func (UnimplementedEventsServer) testEmbeddedByValue() {} // UnsafeEventsServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to EventsServer will // result in compilation errors. type UnsafeEventsServer interface { mustEmbedUnimplementedEventsServer() } func RegisterEventsServer(s grpc.ServiceRegistrar, srv EventsServer) { // If the following call pancis, it indicates UnimplementedEventsServer was // embedded by pointer and is nil. This will cause panics if an // unimplemented method is ever invoked, so we test this at initialization // time to prevent it from happening at runtime later due to I/O. if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { t.testEmbeddedByValue() } s.RegisterService(&Events_ServiceDesc, srv) } func _Events_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventsServer).Get(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Events_Get_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventsServer).Get(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Events_Add_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Event) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventsServer).Add(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Events_Add_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventsServer).Add(ctx, req.(*Event)) } return interceptor(ctx, in, info, handler) } func _Events_Remove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(Event) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(EventsServer).Remove(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Events_Remove_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(EventsServer).Remove(ctx, req.(*Event)) } return interceptor(ctx, in, info, handler) } // Events_ServiceDesc is the grpc.ServiceDesc for Events service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Events_ServiceDesc = grpc.ServiceDesc{ ServiceName: "within.website.x.mi.Events", HandlerType: (*EventsServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _Events_Get_Handler, }, { MethodName: "Add", Handler: _Events_Add_Handler, }, { MethodName: "Remove", Handler: _Events_Remove_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mi.proto", }