// Code generated by protoc-gen-go-grpc. DO NOT EDIT. package litrpc import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" ) // 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.32.0 or later. const _ = grpc.SupportPackageIsVersion7 // SessionsClient is the client API for Sessions 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 SessionsClient interface { // litcli: `sessions add` // AddSession adds and starts a new LNC session. AddSession(ctx context.Context, in *AddSessionRequest, opts ...grpc.CallOption) (*AddSessionResponse, error) // litcli: `sessions list` // ListSessions returns all sessions known to the session store. ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) // litcli: `sessions revoke` // RevokeSession revokes a single session and also stops it if it is currently // active. RevokeSession(ctx context.Context, in *RevokeSessionRequest, opts ...grpc.CallOption) (*RevokeSessionResponse, error) } type sessionsClient struct { cc grpc.ClientConnInterface } func NewSessionsClient(cc grpc.ClientConnInterface) SessionsClient { return &sessionsClient{cc} } func (c *sessionsClient) AddSession(ctx context.Context, in *AddSessionRequest, opts ...grpc.CallOption) (*AddSessionResponse, error) { out := new(AddSessionResponse) err := c.cc.Invoke(ctx, "/litrpc.Sessions/AddSession", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *sessionsClient) ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, error) { out := new(ListSessionsResponse) err := c.cc.Invoke(ctx, "/litrpc.Sessions/ListSessions", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *sessionsClient) RevokeSession(ctx context.Context, in *RevokeSessionRequest, opts ...grpc.CallOption) (*RevokeSessionResponse, error) { out := new(RevokeSessionResponse) err := c.cc.Invoke(ctx, "/litrpc.Sessions/RevokeSession", in, out, opts...) if err != nil { return nil, err } return out, nil } // SessionsServer is the server API for Sessions service. // All implementations must embed UnimplementedSessionsServer // for forward compatibility type SessionsServer interface { // litcli: `sessions add` // AddSession adds and starts a new LNC session. AddSession(context.Context, *AddSessionRequest) (*AddSessionResponse, error) // litcli: `sessions list` // ListSessions returns all sessions known to the session store. ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) // litcli: `sessions revoke` // RevokeSession revokes a single session and also stops it if it is currently // active. RevokeSession(context.Context, *RevokeSessionRequest) (*RevokeSessionResponse, error) mustEmbedUnimplementedSessionsServer() } // UnimplementedSessionsServer must be embedded to have forward compatible implementations. type UnimplementedSessionsServer struct { } func (UnimplementedSessionsServer) AddSession(context.Context, *AddSessionRequest) (*AddSessionResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method AddSession not implemented") } func (UnimplementedSessionsServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method ListSessions not implemented") } func (UnimplementedSessionsServer) RevokeSession(context.Context, *RevokeSessionRequest) (*RevokeSessionResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method RevokeSession not implemented") } func (UnimplementedSessionsServer) mustEmbedUnimplementedSessionsServer() {} // UnsafeSessionsServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to SessionsServer will // result in compilation errors. type UnsafeSessionsServer interface { mustEmbedUnimplementedSessionsServer() } func RegisterSessionsServer(s grpc.ServiceRegistrar, srv SessionsServer) { s.RegisterService(&Sessions_ServiceDesc, srv) } func _Sessions_AddSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AddSessionRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SessionsServer).AddSession(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/litrpc.Sessions/AddSession", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SessionsServer).AddSession(ctx, req.(*AddSessionRequest)) } return interceptor(ctx, in, info, handler) } func _Sessions_ListSessions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListSessionsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SessionsServer).ListSessions(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/litrpc.Sessions/ListSessions", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SessionsServer).ListSessions(ctx, req.(*ListSessionsRequest)) } return interceptor(ctx, in, info, handler) } func _Sessions_RevokeSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RevokeSessionRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(SessionsServer).RevokeSession(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/litrpc.Sessions/RevokeSession", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SessionsServer).RevokeSession(ctx, req.(*RevokeSessionRequest)) } return interceptor(ctx, in, info, handler) } // Sessions_ServiceDesc is the grpc.ServiceDesc for Sessions service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Sessions_ServiceDesc = grpc.ServiceDesc{ ServiceName: "litrpc.Sessions", HandlerType: (*SessionsServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddSession", Handler: _Sessions_AddSession_Handler, }, { MethodName: "ListSessions", Handler: _Sessions_ListSessions_Handler, }, { MethodName: "RevokeSession", Handler: _Sessions_RevokeSession_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "lit-sessions.proto", }